Evans: more expressive gRPC client

at Go 1.10 Release Party in Tokyo more expressive gRPC
client Evans

XIPBNJ !cJE LUS@ ձ௡େֶֶ෦೥ ιϥϛπגࣜձࣾαʔόΤϯδχΞ

at Go 1.10 Release Party in Tokyo more expressive gRPC
client Evans

ΞδΣϯμ w H31$ͱΫϥΠΞϯτπʔϧ܈ w &WBOTͱ&WBOT͕໨ࢦͨ͠΋ͷ w &WBOTͷΞʔΩςΫνϟͱ࣮૷

gRPC DMJFOUTFSWFSؒͰಁաతʹ௨৴Ͱ͖ΔγεςϜΛ ߏங͢ΔͨΊͷ31$ϑϨʔϜϫʔΫ

gRPC *%-Ͱ"1*εΩʔϚΛఆٛ͢Δ ΫϥΠΞϯταʔόͷίʔυΛੜ੒͢Δ αʔόͷϩδοΫΛ࣮૷͢Δ

H31$3FNPUF1SPDFEVSF$BMMT PGDPVSTF IUUQTHSQDJPGBR

gRPC ͷྑ͍ͱ͜Ζ w"1*࢓༷ͱ࣮૷ͷဃ཭Λ๷͙͜ͱ͕Ͱ͖Δ wΫϥΠΞϯταʔόؒͷ*'͕෗ഊ͠ͳ͍ w4USFBNJOH31$ wFUD

gRPC ͷͭΒ͍ͱ͜Ζ w)551͔͠αϙʔτ͍ͯ͠ͳ͍ wπʔϧɾϛυϧ΢ΣΞ܈͕ॆ࣮͍ͯ͠ͳ͍ w"1*ͷσόοά͕ͮ͠Β͍

API ͷσόοά͕ͮ͠Β͍ wH31$͸σʔλΛγϦΞϥΠζͯ͠΍ΓͱΓ͢Δ wDVSM΍XHFU౳ͰςετͰ͖ͳ͍ wΫϥΠΞϯτίʔυΛ࣮૷͢ΔPSπʔϧͷར༻

grpc-ecosystem / polyglot w "'"*, ࠷΋ߴػೳͳΫϥΠΞϯτ w+BWB੡ wͨ͘͞ΜͷΦϓγϣϯΛίϚϯυϥΠϯͰࢦఆ͢ Δඞཁ͕͋ͬͯ൥ࡶ

grpc-ecosystem / polyglot 1 $ echo <json-request> | java -jar
polyglot.jar \ 2 --command=call \ 3 --endpoint=<host>:<port> \ 4 --full_method=<some.package.Service/doSomething> \ 5 --proto_discovery_root=<path>

njpatel / grpcc w/PEFKT੡ w3&1-PS$-*Ͱͷ࣮ߦ͕Մೳ w3&1-Ͱ+BWB4DSJQUΛॻ͘ඞཁ͕͋Δ wิ׬͕ͳ͍

njpatel / grpcc

͍·͍ͪͬ͘͠Γ͜ͳ͍

ސ٬ ͕ຊ౰ʹཉ͔ͬͨ͠΋ͷ

ސ٬ ͕ຊ౰ʹཉ͔ͬͨ͠΋ͷ ָʹςετͰ͖ΔΫϥΠΞϯτ

Ұ͔Βͭ͘Δͧ

LUSFWBOT

ktr0731 / evans w(P੡ wָʹ͔ͭ͑ΔΫϥΠΞϯτ w1SPUPDPM#V⒎FST

Ϣʔεέʔε wσόοά ɺςετ wγΣϧεΫϦϓτ΁ͷ૊ΈࠐΈ

σόοάɺςετ wجຊతʹखಈͰ"1*Λୟ͘ wͰ͖Δ͚ͩλΠϓͨ͘͠ͳ͍ w๛෋ͳิ׬͕ཉ͍͠ wෳ਺ͷ"1*Λୟ͖͍ͨ৔߹΋͋Δ

γΣϧεΫϦϓτ΁ͷ૊ΈࠐΈ wTUEJOPSpMFTUEPVU w૊ΈࠐΈ΍͍͢ΠϯλʔϑΣʔε͕ඞཁ

Ϣʔεέʔε wσόοά ɺςετ 3&1-Ϟʔυ wγΣϧεΫϦϓτ΁ͷ૊ΈࠐΈ ίϚϯυϥΠϯϞʔυ

EFNP LUSFWBOTEFNP

Evans Internal w εΩʔϚͷϩʔυ w &WBOTͷϞσϧ΁ͷม׵ w 31$ͷൃߦ $-*Ϟʔυ PS
3&1-ͷىಈ 3&1-Ϟʔυ

DBTF3&1-31$DBMM

εΩʔϚͷϩʔυ 1 func runProtoc(args []string) ([]byte, error) { 2 buf,
errBuf := new(bytes.Buffer), new(bytes.Buffer) 3 4 // with "--descriptor_set_out=/dev/stdout" 5 cmd := exec.Command("protoc", args...) 6 cmd.Stdout = buf 7 cmd.Stderr = errBuf 8 if err := cmd.Run(); err != nil { 9 if errBuf.Len() != 0 { 10 return nil, errors.New(errBuf.String()) 11 } 12 return nil, err 13 } 14 return buf.Bytes(), nil 15 }

wHPMBOHQSPUPCVGEFTDSJQUPS wHPMBOHQSPUPCVGQSPUP εΩʔϚͷϩʔυ 1 code, _ := runProtoc(args) 2 ds
:= descriptor.FileDescriptorSet{} 3 proto.Unmarshal(code, &ds)

Ϟσϧ΁ͷม׵ wΞϓϦέʔγϣϯ͔Βѻ͍΍͘͢͢ΔͨΊ wKIVNQQSPUPSFqFDU΁ͷґଘΛͳͨ͘͢Ί ޙड़

REPL: read wDCBUBHPQSPNQU

REPL: read / eval wϑΟʔϧυΛ࠶ؼతʹḷΔ wϓϦϛςΟϒܕͰ͋Ε͹஋Λೖྗͤ͞Δ

1 message User { 2 string first_name = 1; 3
string last_name = 2; 4 Gender gender = 3; 5 } 6 7 message RegisterUsersRequest { 8 repeated User users = 1; 9 } type = "double" | "float" | "int32" | "int64" | "uint32" | "uint64" | "sint32" | "sint64" | "fixed32" | "fixed64" | "sfixed32" | "sfixed64" | "bool" | "string" | "bytes" | messageType | enumType

type = "double" | "float" | "int32" | "int64" |
"uint32" | "uint64" | "sint32" | "sint64" | "fixed32" | "fixed64" | "sfixed32" | "sfixed64" | "bool" | "string" | "bytes" | messageType | enumType 1 message User { 2 string first_name = 1; 3 string last_name = 2; 4 Gender gender = 3; 5 } 6 7 message RegisterUsersRequest { 8 repeated User users = 1; 9 }

ϓϦϛςΟϒܕͷೖྗ wೖྗΛड͚͚ͭΔ DCBUBHPQSPNQU wରԠ͢Δܕ΁ม׵ wϑΟʔϧυʹ஋Ληοτ͢Δ KIVNQQSPUPSFqFDU wೖྗର৅ͷϝοηʔδ͸ಈతʹܾఆ͞ΕΔ

ϝοηʔδͷಈతͳߏங wKIVNQQSPUPSFqFDUEZOBNJD.FTTBHF wQSPUP.BSTIBMFS࣮૷Λ࣋ͭ

ϝοηʔδͷಈతͳߏங ֤ϑΟʔϧυ஋ΛEZOBNJD.FTTBHF͕อ࣋ #V⒎FS.BSTIBM΁QSPUP.FTTBHFͱͯ͠౉͞ΕΔ .BSTIBM͕QSPUP.BSTIBMFSͷ࣮૷ΛݺͿ EZOBNJD.FTTBHF.BSTIBMʹΑΓγϦΞϥΠζ

QSPUP.FTTBHF QSPUP.BSTIBMFS EZOBNJD.FTTBHF Marshal() ([]byte, error) CVG WBMVFT encode marshal
each field values ϝοηʔδͷಈతͳߏங

ΞʔΩςΫνϟ w $MFBO"SDIJUFDUVSF w )FYBHPOBM"SDIJUFDUVSF

ͳͥ CA / HA ͔ʁ w ࠜװΛࢧ͑ΔϥΠϒϥϦ͕ະ੒ख़ w $-*Ϟʔυɺ3&1-Ϟʔυ͕͋Δ w
ίϯϙʔωϯτ͕ଟ͍

JOQVUUFS*' 3&1- 1SPNQU*OQVUUFS DCBUBHPQSPNQU $-* +40/JOQVUUFS FODPEJOHKTPO Entity layer Adapter
layer UseCase layer EFTDSJQUPST KIVNQQSPUPSFqFDU pFMET NFTTBHF TFSWJDF*'

TODOs w ετϦʔϜछ w 5-4ରԠ w ϦϑϨΫγϣϯαʔόରԠ w FUD

TODOs w ετϦʔϜछ w 5-4ରԠ w ϦϑϨΫγϣϯαʔόରԠ w FUD 1VMM3FRVFTUT*TTVFT
XFMDPNF

·ͱΊ w ݸਓతʹ͸ ָʹ͔ͭ͑ΔΫϥΠΞϯτ͕Ͱ͖ͨ w ڊਓͷݞʹ৐͍ͬͯΔ͓͔͛Ͱ͢ w ͱ͸͍͑50%0͸·ͩଟ͍

·ͱΊ w ݸਓతʹ͸ ָʹ͔ͭ͑ΔΫϥΠΞϯτ͕Ͱ͖ͨ w ڊਓͷݞʹ৐͍ͬͯΔ͓͔͛Ͱ͢ w ͱ͸͍͑50%0͸·ͩଟ͍ ΍͍ͬͯͧ͘ʂʂ

Evans: more expressive gRPC client

Evans: more expressive gRPC client

More Decks by ktr

Other Decks in Programming

Featured

Transcript