Last active
August 29, 2015 14:13
-
-
Save captncraig/e2bc7e7d1a0cb2c8127b to your computer and use it in GitHub Desktop.
Thrift Go Generator Changes
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type BarServiceProcessor struct { | |
| *FooServiceProcessor | |
| handler BarService | |
| } | |
| func (p *BarServiceProcessor) GetProcessorFunction(key string) (processor func(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException), ok bool) { | |
| switch key { | |
| case "ping": | |
| return p.Process_Ping, true | |
| default: | |
| return p.FooServiceProcessor.GetProcessorFunction(key) | |
| } | |
| } | |
| func NewBarServiceProcessor(handler BarService) *BarServiceProcessor { | |
| return &BarServiceProcessor{NewFooServiceProcessor(handler), handler} | |
| } | |
| func (p *BarServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| name, _, seqId, err := iprot.ReadMessageBegin() | |
| if err != nil { | |
| return false, err | |
| } | |
| if processor, ok := p.GetProcessorFunction(name); ok { | |
| return processor(seqId, iprot, oprot) | |
| } | |
| iprot.Skip(thrift.STRUCT) | |
| iprot.ReadMessageEnd() | |
| x8 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function "+name) | |
| oprot.WriteMessageBegin(name, thrift.EXCEPTION, seqId) | |
| x8.Write(oprot) | |
| oprot.WriteMessageEnd() | |
| oprot.Flush() | |
| return false, x8 | |
| } | |
| func (p *BarServiceProcessor) Process_Ping(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| //... | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type BarServiceProcessor struct { | |
| *FooServiceProcessor | |
| } | |
| func NewBarServiceProcessor(handler BarService) *BarServiceProcessor { | |
| self7 := &BarServiceProcessor{NewFooServiceProcessor(handler)} | |
| self7.AddToProcessorMap("ping", &barServiceProcessorPing{handler: handler}) | |
| return self7 | |
| } | |
| type barServiceProcessorPing struct { | |
| handler BarService | |
| } | |
| func (p *barServiceProcessorPing) Process(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| //Body Unaffected | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| namespace * foo | |
| service FooService{ | |
| i32 add1(1: i32 x) | |
| } | |
| service BarService extends FooService{ | |
| void ping() | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type FooServiceProcessor struct { | |
| handler FooService | |
| } | |
| func (p *FooServiceProcessor) GetProcessorFunction(key string) (processor func(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException), ok bool) { | |
| switch key { | |
| case "add1": | |
| return p.Process_Add1, true | |
| default: | |
| return nil, false | |
| } | |
| } | |
| func NewFooServiceProcessor(handler FooService) *FooServiceProcessor { | |
| return &FooServiceProcessor{handler: handler} | |
| } | |
| func (p *FooServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| name, _, seqId, err := iprot.ReadMessageBegin() | |
| if err != nil { | |
| return false, err | |
| } | |
| if processor, ok := p.GetProcessorFunction(name); ok { | |
| return processor(seqId, iprot, oprot) | |
| } | |
| //unchanged... | |
| } | |
| func (p *FooServiceProcessor) Process_Add1(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| //Body Unaffected | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type FooServiceProcessor struct { | |
| processorMap map[string]thrift.TProcessorFunction | |
| handler FooService | |
| } | |
| func (p *FooServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) { | |
| p.processorMap[key] = processor | |
| } | |
| func (p *FooServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) { | |
| processor, ok = p.processorMap[key] | |
| return processor, ok | |
| } | |
| func (p *FooServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction { | |
| return p.processorMap | |
| } | |
| func NewFooServiceProcessor(handler FooService) *FooServiceProcessor { | |
| self2 := &FooServiceProcessor{handler: handler, processorMap: make(map[string]thrift.TProcessorFunction)} | |
| self2.processorMap["add1"] = &fooServiceProcessorAdd1{handler: handler} | |
| return self2 | |
| } | |
| func (p *FooServiceProcessor) Process(iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| name, _, seqId, err := iprot.ReadMessageBegin() | |
| if err != nil { | |
| return false, err | |
| } | |
| if processor, ok := p.GetProcessorFunction(name); ok { | |
| return processor.Process(seqId, iprot, oprot) | |
| } | |
| //unchanged... | |
| } | |
| type fooServiceProcessorAdd1 struct { | |
| handler FooService | |
| } | |
| func (p *fooServiceProcessorAdd1) Process(seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { | |
| //Body Unaffected | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment