| //Generated by gRPC Go plugin |
| //If you make any local changes, they will be lost |
| //source: monster_test |
| |
| package Example |
| |
| import ( |
| context "context" |
| flatbuffers "github.com/google/flatbuffers/go" |
| grpc "google.golang.org/grpc" |
| "google.golang.org/grpc/codes" |
| "google.golang.org/grpc/status" |
| ) |
| |
| // Client API for MonsterStorage service |
| type MonsterStorageClient interface { |
| Store(ctx context.Context, in *flatbuffers.Builder, |
| opts ...grpc.CallOption) (*Stat, error) |
| Retrieve(ctx context.Context, in *flatbuffers.Builder, |
| opts ...grpc.CallOption) (MonsterStorage_RetrieveClient, error) |
| GetMaxHitPoint(ctx context.Context, |
| opts ...grpc.CallOption) (MonsterStorage_GetMaxHitPointClient, error) |
| GetMinMaxHitPoints(ctx context.Context, |
| opts ...grpc.CallOption) (MonsterStorage_GetMinMaxHitPointsClient, error) |
| } |
| |
| type monsterStorageClient struct { |
| cc grpc.ClientConnInterface |
| } |
| |
| func NewMonsterStorageClient(cc grpc.ClientConnInterface) MonsterStorageClient { |
| return &monsterStorageClient{cc} |
| } |
| |
| func (c *monsterStorageClient) Store(ctx context.Context, in *flatbuffers.Builder, |
| opts ...grpc.CallOption) (*Stat, error) { |
| out := new(Stat) |
| err := c.cc.Invoke(ctx, "/MyGame.Example.MonsterStorage/Store", in, out, opts...) |
| if err != nil { |
| return nil, err |
| } |
| return out, nil |
| } |
| |
| func (c *monsterStorageClient) Retrieve(ctx context.Context, in *flatbuffers.Builder, |
| opts ...grpc.CallOption) (MonsterStorage_RetrieveClient, error) { |
| stream, err := c.cc.NewStream(ctx, &_MonsterStorage_serviceDesc.Streams[0], "/MyGame.Example.MonsterStorage/Retrieve", opts...) |
| if err != nil { |
| return nil, err |
| } |
| x := &monsterStorageRetrieveClient{stream} |
| if err := x.ClientStream.SendMsg(in); err != nil { |
| return nil, err |
| } |
| if err := x.ClientStream.CloseSend(); err != nil { |
| return nil, err |
| } |
| return x, nil |
| } |
| |
| type MonsterStorage_RetrieveClient interface { |
| Recv() (*Monster, error) |
| grpc.ClientStream |
| } |
| |
| type monsterStorageRetrieveClient struct { |
| grpc.ClientStream |
| } |
| |
| func (x *monsterStorageRetrieveClient) Recv() (*Monster, error) { |
| m := new(Monster) |
| if err := x.ClientStream.RecvMsg(m); err != nil { |
| return nil, err |
| } |
| return m, nil |
| } |
| |
| func (c *monsterStorageClient) GetMaxHitPoint(ctx context.Context, |
| opts ...grpc.CallOption) (MonsterStorage_GetMaxHitPointClient, error) { |
| stream, err := c.cc.NewStream(ctx, &_MonsterStorage_serviceDesc.Streams[1], "/MyGame.Example.MonsterStorage/GetMaxHitPoint", opts...) |
| if err != nil { |
| return nil, err |
| } |
| x := &monsterStorageGetMaxHitPointClient{stream} |
| return x, nil |
| } |
| |
| type MonsterStorage_GetMaxHitPointClient interface { |
| Send(*flatbuffers.Builder) error |
| CloseAndRecv() (*Stat, error) |
| grpc.ClientStream |
| } |
| |
| type monsterStorageGetMaxHitPointClient struct { |
| grpc.ClientStream |
| } |
| |
| func (x *monsterStorageGetMaxHitPointClient) Send(m *flatbuffers.Builder) error { |
| return x.ClientStream.SendMsg(m) |
| } |
| |
| func (x *monsterStorageGetMaxHitPointClient) CloseAndRecv() (*Stat, error) { |
| if err := x.ClientStream.CloseSend(); err != nil { |
| return nil, err |
| } |
| m := new(Stat) |
| if err := x.ClientStream.RecvMsg(m); err != nil { |
| return nil, err |
| } |
| return m, nil |
| } |
| |
| func (c *monsterStorageClient) GetMinMaxHitPoints(ctx context.Context, |
| opts ...grpc.CallOption) (MonsterStorage_GetMinMaxHitPointsClient, error) { |
| stream, err := c.cc.NewStream(ctx, &_MonsterStorage_serviceDesc.Streams[2], "/MyGame.Example.MonsterStorage/GetMinMaxHitPoints", opts...) |
| if err != nil { |
| return nil, err |
| } |
| x := &monsterStorageGetMinMaxHitPointsClient{stream} |
| return x, nil |
| } |
| |
| type MonsterStorage_GetMinMaxHitPointsClient interface { |
| Send(*flatbuffers.Builder) error |
| Recv() (*Stat, error) |
| grpc.ClientStream |
| } |
| |
| type monsterStorageGetMinMaxHitPointsClient struct { |
| grpc.ClientStream |
| } |
| |
| func (x *monsterStorageGetMinMaxHitPointsClient) Send(m *flatbuffers.Builder) error { |
| return x.ClientStream.SendMsg(m) |
| } |
| |
| func (x *monsterStorageGetMinMaxHitPointsClient) Recv() (*Stat, error) { |
| m := new(Stat) |
| if err := x.ClientStream.RecvMsg(m); err != nil { |
| return nil, err |
| } |
| return m, nil |
| } |
| |
| // Server API for MonsterStorage service |
| type MonsterStorageServer interface { |
| Store(context.Context, *Monster) (*flatbuffers.Builder, error) |
| Retrieve(*Stat, MonsterStorage_RetrieveServer) error |
| GetMaxHitPoint(MonsterStorage_GetMaxHitPointServer) error |
| GetMinMaxHitPoints(MonsterStorage_GetMinMaxHitPointsServer) error |
| mustEmbedUnimplementedMonsterStorageServer() |
| } |
| |
| type UnimplementedMonsterStorageServer struct { |
| } |
| |
| func (UnimplementedMonsterStorageServer) Store(context.Context, *Monster) (*flatbuffers.Builder, error) { |
| return nil, status.Errorf(codes.Unimplemented, "method Store not implemented") |
| } |
| |
| func (UnimplementedMonsterStorageServer) Retrieve(*Stat, MonsterStorage_RetrieveServer) error { |
| return status.Errorf(codes.Unimplemented, "method Retrieve not implemented") |
| } |
| |
| func (UnimplementedMonsterStorageServer) GetMaxHitPoint(MonsterStorage_GetMaxHitPointServer) error { |
| return status.Errorf(codes.Unimplemented, "method GetMaxHitPoint not implemented") |
| } |
| |
| func (UnimplementedMonsterStorageServer) GetMinMaxHitPoints(MonsterStorage_GetMinMaxHitPointsServer) error { |
| return status.Errorf(codes.Unimplemented, "method GetMinMaxHitPoints not implemented") |
| } |
| |
| func (UnimplementedMonsterStorageServer) mustEmbedUnimplementedMonsterStorageServer() {} |
| |
| type UnsafeMonsterStorageServer interface { |
| mustEmbedUnimplementedMonsterStorageServer() |
| } |
| |
| func RegisterMonsterStorageServer(s grpc.ServiceRegistrar, srv MonsterStorageServer) { |
| s.RegisterService(&_MonsterStorage_serviceDesc, srv) |
| } |
| |
| func _MonsterStorage_Store_Handler(srv interface{}, ctx context.Context, |
| dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| in := new(Monster) |
| if err := dec(in); err != nil { |
| return nil, err |
| } |
| if interceptor == nil { |
| return srv.(MonsterStorageServer).Store(ctx, in) |
| } |
| info := &grpc.UnaryServerInfo{ |
| Server: srv, |
| FullMethod: "/MyGame.Example.MonsterStorage/Store", |
| } |
| |
| handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| return srv.(MonsterStorageServer).Store(ctx, req.(*Monster)) |
| } |
| return interceptor(ctx, in, info, handler) |
| } |
| func _MonsterStorage_Retrieve_Handler(srv interface{}, stream grpc.ServerStream) error { |
| m := new(Stat) |
| if err := stream.RecvMsg(m); err != nil { |
| return err |
| } |
| return srv.(MonsterStorageServer).Retrieve(m, &monsterStorageRetrieveServer{stream}) |
| } |
| |
| type MonsterStorage_RetrieveServer interface { |
| Send(*flatbuffers.Builder) error |
| grpc.ServerStream |
| } |
| |
| type monsterStorageRetrieveServer struct { |
| grpc.ServerStream |
| } |
| |
| func (x *monsterStorageRetrieveServer) Send(m *flatbuffers.Builder) error { |
| return x.ServerStream.SendMsg(m) |
| } |
| |
| func _MonsterStorage_GetMaxHitPoint_Handler(srv interface{}, stream grpc.ServerStream) error { |
| return srv.(MonsterStorageServer).GetMaxHitPoint(&monsterStorageGetMaxHitPointServer{stream}) |
| } |
| |
| type MonsterStorage_GetMaxHitPointServer interface { |
| Recv() (*Monster, error) |
| SendAndClose(*flatbuffers.Builder) error |
| grpc.ServerStream |
| } |
| |
| type monsterStorageGetMaxHitPointServer struct { |
| grpc.ServerStream |
| } |
| |
| func (x *monsterStorageGetMaxHitPointServer) Recv() (*Monster, error) { |
| m := new(Monster) |
| if err := x.ServerStream.RecvMsg(m); err != nil { |
| return nil, err |
| } |
| return m, nil |
| } |
| |
| func (x *monsterStorageGetMaxHitPointServer) SendAndClose(m *flatbuffers.Builder) error { |
| return x.ServerStream.SendMsg(m) |
| } |
| |
| func _MonsterStorage_GetMinMaxHitPoints_Handler(srv interface{}, stream grpc.ServerStream) error { |
| return srv.(MonsterStorageServer).GetMinMaxHitPoints(&monsterStorageGetMinMaxHitPointsServer{stream}) |
| } |
| |
| type MonsterStorage_GetMinMaxHitPointsServer interface { |
| Send(*flatbuffers.Builder) error |
| Recv() (*Monster, error) |
| grpc.ServerStream |
| } |
| |
| type monsterStorageGetMinMaxHitPointsServer struct { |
| grpc.ServerStream |
| } |
| |
| func (x *monsterStorageGetMinMaxHitPointsServer) Send(m *flatbuffers.Builder) error { |
| return x.ServerStream.SendMsg(m) |
| } |
| |
| func (x *monsterStorageGetMinMaxHitPointsServer) Recv() (*Monster, error) { |
| m := new(Monster) |
| if err := x.ServerStream.RecvMsg(m); err != nil { |
| return nil, err |
| } |
| return m, nil |
| } |
| |
| var _MonsterStorage_serviceDesc = grpc.ServiceDesc{ |
| ServiceName: "MyGame.Example.MonsterStorage", |
| HandlerType: (*MonsterStorageServer)(nil), |
| Methods: []grpc.MethodDesc{ |
| { |
| MethodName: "Store", |
| Handler: _MonsterStorage_Store_Handler, |
| }, |
| }, |
| Streams: []grpc.StreamDesc{ |
| { |
| StreamName: "Retrieve", |
| Handler: _MonsterStorage_Retrieve_Handler, |
| ServerStreams: true, |
| }, |
| { |
| StreamName: "GetMaxHitPoint", |
| Handler: _MonsterStorage_GetMaxHitPoint_Handler, |
| ClientStreams: true, |
| }, |
| { |
| StreamName: "GetMinMaxHitPoints", |
| Handler: _MonsterStorage_GetMinMaxHitPoints_Handler, |
| ServerStreams: true, |
| ClientStreams: true, |
| }, |
| }, |
| } |