Documentation ¶
Index ¶
- func RegisterAppServer(s *grpc.Server, srv AppServer)
- func RegisterExposedAppServer(s *grpc.Server, srv ExposedAppServer)
- type AppClient
- type AppServer
- type App_BroadcastClient
- type App_BroadcastServer
- type App_ConvertToStringClient
- type App_ConvertToStringServer
- type App_FeedClient
- type App_FeedServer
- type BroadcastData
- func (*BroadcastData) Descriptor() ([]byte, []int)
- func (m *BroadcastData) GetRawData() []byte
- func (*BroadcastData) ProtoMessage()
- func (m *BroadcastData) Reset()
- func (m *BroadcastData) String() string
- func (m *BroadcastData) XXX_DiscardUnknown()
- func (m *BroadcastData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BroadcastData) XXX_Merge(src proto.Message)
- func (m *BroadcastData) XXX_Size() int
- func (m *BroadcastData) XXX_Unmarshal(b []byte) error
- type BroadcastRequest
- func (*BroadcastRequest) Descriptor() ([]byte, []int)
- func (m *BroadcastRequest) GetId() string
- func (*BroadcastRequest) ProtoMessage()
- func (m *BroadcastRequest) Reset()
- func (m *BroadcastRequest) String() string
- func (m *BroadcastRequest) XXX_DiscardUnknown()
- func (m *BroadcastRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BroadcastRequest) XXX_Merge(src proto.Message)
- func (m *BroadcastRequest) XXX_Size() int
- func (m *BroadcastRequest) XXX_Unmarshal(b []byte) error
- type ConvertInput
- func (*ConvertInput) Descriptor() ([]byte, []int)
- func (m *ConvertInput) GetRawData() []byte
- func (*ConvertInput) ProtoMessage()
- func (m *ConvertInput) Reset()
- func (m *ConvertInput) String() string
- func (m *ConvertInput) XXX_DiscardUnknown()
- func (m *ConvertInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConvertInput) XXX_Merge(src proto.Message)
- func (m *ConvertInput) XXX_Size() int
- func (m *ConvertInput) XXX_Unmarshal(b []byte) error
- type ConvertOutput
- func (*ConvertOutput) Descriptor() ([]byte, []int)
- func (m *ConvertOutput) GetConvertedData() string
- func (*ConvertOutput) ProtoMessage()
- func (m *ConvertOutput) Reset()
- func (m *ConvertOutput) String() string
- func (m *ConvertOutput) XXX_DiscardUnknown()
- func (m *ConvertOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConvertOutput) XXX_Merge(src proto.Message)
- func (m *ConvertOutput) XXX_Size() int
- func (m *ConvertOutput) XXX_Unmarshal(b []byte) error
- type ExposedAppClient
- type ExposedAppServer
- type ExposedApp_GetBroadcastClient
- type ExposedApp_GetBroadcastServer
- type ExposedApp_PostConvertToStringClient
- type ExposedApp_PostConvertToStringServer
- type ExposedApp_PostFeedClient
- type ExposedApp_PostFeedServer
- type FeedData
- func (*FeedData) Descriptor() ([]byte, []int)
- func (m *FeedData) GetDataType() uint64
- func (m *FeedData) GetId() string
- func (m *FeedData) GetRawData() []byte
- func (*FeedData) ProtoMessage()
- func (m *FeedData) Reset()
- func (m *FeedData) String() string
- func (m *FeedData) XXX_DiscardUnknown()
- func (m *FeedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FeedData) XXX_Merge(src proto.Message)
- func (m *FeedData) XXX_Size() int
- func (m *FeedData) XXX_Unmarshal(b []byte) error
- type FeedResponse
- func (*FeedResponse) Descriptor() ([]byte, []int)
- func (*FeedResponse) ProtoMessage()
- func (m *FeedResponse) Reset()
- func (m *FeedResponse) String() string
- func (m *FeedResponse) XXX_DiscardUnknown()
- func (m *FeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FeedResponse) XXX_Merge(src proto.Message)
- func (m *FeedResponse) XXX_Size() int
- func (m *FeedResponse) XXX_Unmarshal(b []byte) error
- type FibonacciRequest
- func (*FibonacciRequest) Descriptor() ([]byte, []int)
- func (m *FibonacciRequest) GetN() uint64
- func (*FibonacciRequest) ProtoMessage()
- func (m *FibonacciRequest) Reset()
- func (m *FibonacciRequest) String() string
- func (m *FibonacciRequest) XXX_DiscardUnknown()
- func (m *FibonacciRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FibonacciRequest) XXX_Merge(src proto.Message)
- func (m *FibonacciRequest) XXX_Size() int
- func (m *FibonacciRequest) XXX_Unmarshal(b []byte) error
- type FibonacciResponse
- func (*FibonacciResponse) Descriptor() ([]byte, []int)
- func (m *FibonacciResponse) GetNumber() uint64
- func (*FibonacciResponse) ProtoMessage()
- func (m *FibonacciResponse) Reset()
- func (m *FibonacciResponse) String() string
- func (m *FibonacciResponse) XXX_DiscardUnknown()
- func (m *FibonacciResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FibonacciResponse) XXX_Merge(src proto.Message)
- func (m *FibonacciResponse) XXX_Size() int
- func (m *FibonacciResponse) XXX_Unmarshal(b []byte) error
- type Handle
- func (h *Handle) Broadcast(in *BroadcastRequest, stream App_BroadcastServer) error
- func (h *Handle) ConvertToString(stream App_ConvertToStringServer) error
- func (h *Handle) Feed(stream App_FeedServer) error
- func (h *Handle) Fibonacci(ctx context.Context, in *FibonacciRequest) (*FibonacciResponse, error)
- func (h *Handle) MakeClientConn() (*grpc.ClientConn, error)
- func (h *Handle) Random(ctx context.Context, in *RandomRequest) (*RandomResponse, error)
- func (h *Handle) Start() error
- func (h *Handle) Stop()
- func (h *Handle) UploadPhoto(ctx context.Context, in *UploadPhotoRequest) (*UploadPhotoResponse, error)
- type RandomRequest
- func (*RandomRequest) Descriptor() ([]byte, []int)
- func (m *RandomRequest) GetLowerBound() int64
- func (m *RandomRequest) GetUpperBound() int64
- func (*RandomRequest) ProtoMessage()
- func (m *RandomRequest) Reset()
- func (m *RandomRequest) String() string
- func (m *RandomRequest) XXX_DiscardUnknown()
- func (m *RandomRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RandomRequest) XXX_Merge(src proto.Message)
- func (m *RandomRequest) XXX_Size() int
- func (m *RandomRequest) XXX_Unmarshal(b []byte) error
- type RandomResponse
- func (*RandomResponse) Descriptor() ([]byte, []int)
- func (m *RandomResponse) GetNumber() int64
- func (*RandomResponse) ProtoMessage()
- func (m *RandomResponse) Reset()
- func (m *RandomResponse) String() string
- func (m *RandomResponse) XXX_DiscardUnknown()
- func (m *RandomResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RandomResponse) XXX_Merge(src proto.Message)
- func (m *RandomResponse) XXX_Size() int
- func (m *RandomResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedAppServer
- func (*UnimplementedAppServer) Broadcast(req *BroadcastRequest, srv App_BroadcastServer) error
- func (*UnimplementedAppServer) ConvertToString(srv App_ConvertToStringServer) error
- func (*UnimplementedAppServer) Feed(srv App_FeedServer) error
- func (*UnimplementedAppServer) Fibonacci(ctx context.Context, req *FibonacciRequest) (*FibonacciResponse, error)
- func (*UnimplementedAppServer) Random(ctx context.Context, req *RandomRequest) (*RandomResponse, error)
- func (*UnimplementedAppServer) UploadPhoto(ctx context.Context, req *UploadPhotoRequest) (*UploadPhotoResponse, error)
- type UnimplementedExposedAppServer
- func (*UnimplementedExposedAppServer) GetBroadcast(req *BroadcastRequest, srv ExposedApp_GetBroadcastServer) error
- func (*UnimplementedExposedAppServer) GetRandom(ctx context.Context, req *RandomRequest) (*RandomResponse, error)
- func (*UnimplementedExposedAppServer) PostConvertToString(srv ExposedApp_PostConvertToStringServer) error
- func (*UnimplementedExposedAppServer) PostFeed(srv ExposedApp_PostFeedServer) error
- func (*UnimplementedExposedAppServer) PostUploadPhoto(ctx context.Context, req *UploadPhotoRequest) (*UploadPhotoResponse, error)
- type UploadPhotoRequest
- func (*UploadPhotoRequest) Descriptor() ([]byte, []int)
- func (m *UploadPhotoRequest) GetData() []byte
- func (*UploadPhotoRequest) ProtoMessage()
- func (m *UploadPhotoRequest) Reset()
- func (m *UploadPhotoRequest) String() string
- func (m *UploadPhotoRequest) XXX_DiscardUnknown()
- func (m *UploadPhotoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UploadPhotoRequest) XXX_Merge(src proto.Message)
- func (m *UploadPhotoRequest) XXX_Size() int
- func (m *UploadPhotoRequest) XXX_Unmarshal(b []byte) error
- type UploadPhotoResponse
- func (*UploadPhotoResponse) Descriptor() ([]byte, []int)
- func (m *UploadPhotoResponse) GetUuid() string
- func (*UploadPhotoResponse) ProtoMessage()
- func (m *UploadPhotoResponse) Reset()
- func (m *UploadPhotoResponse) String() string
- func (m *UploadPhotoResponse) XXX_DiscardUnknown()
- func (m *UploadPhotoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UploadPhotoResponse) XXX_Merge(src proto.Message)
- func (m *UploadPhotoResponse) XXX_Size() int
- func (m *UploadPhotoResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAppServer ¶ added in v0.3.0
func RegisterExposedAppServer ¶ added in v0.3.0
func RegisterExposedAppServer(s *grpc.Server, srv ExposedAppServer)
Types ¶
type AppClient ¶ added in v0.3.0
type AppClient interface { // Fibonacci returns the nth number in the Fibonacci sequence. It does not start with an HTTP method and is therefore not exposed Fibonacci(ctx context.Context, in *FibonacciRequest, opts ...grpc.CallOption) (*FibonacciResponse, error) // Random returns a random integer in the desired range. It may be accessed via a Get request to the proxy at, for example, /api/Service/Random Random(ctx context.Context, in *RandomRequest, opts ...grpc.CallOption) (*RandomResponse, error) // UploadPhoto allows the upload of a photo to some persistence store. It may be accessed via Post request to the proxy at, for example, /api/Service/UploadPhoto UploadPhoto(ctx context.Context, in *UploadPhotoRequest, opts ...grpc.CallOption) (*UploadPhotoResponse, error) // Feed sends streamed inputs Feed(ctx context.Context, opts ...grpc.CallOption) (App_FeedClient, error) // Broadcast asks the App to broadcast data in a stream Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (App_BroadcastClient, error) // ConvertToString streams conversions of the input stream to strings ConvertToString(ctx context.Context, opts ...grpc.CallOption) (App_ConvertToStringClient, error) }
AppClient is the client API for App service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAppClient ¶ added in v0.3.0
func NewAppClient(cc *grpc.ClientConn) AppClient
type AppServer ¶ added in v0.3.0
type AppServer interface { // Fibonacci returns the nth number in the Fibonacci sequence. It does not start with an HTTP method and is therefore not exposed Fibonacci(context.Context, *FibonacciRequest) (*FibonacciResponse, error) // Random returns a random integer in the desired range. It may be accessed via a Get request to the proxy at, for example, /api/Service/Random Random(context.Context, *RandomRequest) (*RandomResponse, error) // UploadPhoto allows the upload of a photo to some persistence store. It may be accessed via Post request to the proxy at, for example, /api/Service/UploadPhoto UploadPhoto(context.Context, *UploadPhotoRequest) (*UploadPhotoResponse, error) // Feed sends streamed inputs Feed(App_FeedServer) error // Broadcast asks the App to broadcast data in a stream Broadcast(*BroadcastRequest, App_BroadcastServer) error // ConvertToString streams conversions of the input stream to strings ConvertToString(App_ConvertToStringServer) error }
AppServer is the server API for App service.
type App_BroadcastClient ¶ added in v0.4.0
type App_BroadcastClient interface { Recv() (*BroadcastData, error) grpc.ClientStream }
type App_BroadcastServer ¶ added in v0.4.0
type App_BroadcastServer interface { Send(*BroadcastData) error grpc.ServerStream }
type App_ConvertToStringClient ¶ added in v0.4.0
type App_ConvertToStringClient interface { Send(*ConvertInput) error Recv() (*ConvertOutput, error) grpc.ClientStream }
type App_ConvertToStringServer ¶ added in v0.4.0
type App_ConvertToStringServer interface { Send(*ConvertOutput) error Recv() (*ConvertInput, error) grpc.ServerStream }
type App_FeedClient ¶ added in v0.4.0
type App_FeedClient interface { Send(*FeedData) error CloseAndRecv() (*FeedResponse, error) grpc.ClientStream }
type App_FeedServer ¶ added in v0.4.0
type App_FeedServer interface { SendAndClose(*FeedResponse) error Recv() (*FeedData, error) grpc.ServerStream }
type BroadcastData ¶ added in v0.4.0
type BroadcastData struct { RawData []byte `protobuf:"bytes,1,opt,name=raw_data,json=rawData,proto3" json:"raw_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BroadcastData) Descriptor ¶ added in v0.4.0
func (*BroadcastData) Descriptor() ([]byte, []int)
func (*BroadcastData) GetRawData ¶ added in v0.4.0
func (m *BroadcastData) GetRawData() []byte
func (*BroadcastData) ProtoMessage ¶ added in v0.4.0
func (*BroadcastData) ProtoMessage()
func (*BroadcastData) Reset ¶ added in v0.4.0
func (m *BroadcastData) Reset()
func (*BroadcastData) String ¶ added in v0.4.0
func (m *BroadcastData) String() string
func (*BroadcastData) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *BroadcastData) XXX_DiscardUnknown()
func (*BroadcastData) XXX_Marshal ¶ added in v0.4.0
func (m *BroadcastData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BroadcastData) XXX_Merge ¶ added in v0.4.0
func (m *BroadcastData) XXX_Merge(src proto.Message)
func (*BroadcastData) XXX_Size ¶ added in v0.4.0
func (m *BroadcastData) XXX_Size() int
func (*BroadcastData) XXX_Unmarshal ¶ added in v0.4.0
func (m *BroadcastData) XXX_Unmarshal(b []byte) error
type BroadcastRequest ¶ added in v0.4.0
type BroadcastRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BroadcastRequest) Descriptor ¶ added in v0.4.0
func (*BroadcastRequest) Descriptor() ([]byte, []int)
func (*BroadcastRequest) GetId ¶ added in v0.4.0
func (m *BroadcastRequest) GetId() string
func (*BroadcastRequest) ProtoMessage ¶ added in v0.4.0
func (*BroadcastRequest) ProtoMessage()
func (*BroadcastRequest) Reset ¶ added in v0.4.0
func (m *BroadcastRequest) Reset()
func (*BroadcastRequest) String ¶ added in v0.4.0
func (m *BroadcastRequest) String() string
func (*BroadcastRequest) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *BroadcastRequest) XXX_DiscardUnknown()
func (*BroadcastRequest) XXX_Marshal ¶ added in v0.4.0
func (m *BroadcastRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BroadcastRequest) XXX_Merge ¶ added in v0.4.0
func (m *BroadcastRequest) XXX_Merge(src proto.Message)
func (*BroadcastRequest) XXX_Size ¶ added in v0.4.0
func (m *BroadcastRequest) XXX_Size() int
func (*BroadcastRequest) XXX_Unmarshal ¶ added in v0.4.0
func (m *BroadcastRequest) XXX_Unmarshal(b []byte) error
type ConvertInput ¶ added in v0.4.0
type ConvertInput struct { RawData []byte `protobuf:"bytes,1,opt,name=raw_data,json=rawData,proto3" json:"raw_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConvertInput) Descriptor ¶ added in v0.4.0
func (*ConvertInput) Descriptor() ([]byte, []int)
func (*ConvertInput) GetRawData ¶ added in v0.4.0
func (m *ConvertInput) GetRawData() []byte
func (*ConvertInput) ProtoMessage ¶ added in v0.4.0
func (*ConvertInput) ProtoMessage()
func (*ConvertInput) Reset ¶ added in v0.4.0
func (m *ConvertInput) Reset()
func (*ConvertInput) String ¶ added in v0.4.0
func (m *ConvertInput) String() string
func (*ConvertInput) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *ConvertInput) XXX_DiscardUnknown()
func (*ConvertInput) XXX_Marshal ¶ added in v0.4.0
func (m *ConvertInput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConvertInput) XXX_Merge ¶ added in v0.4.0
func (m *ConvertInput) XXX_Merge(src proto.Message)
func (*ConvertInput) XXX_Size ¶ added in v0.4.0
func (m *ConvertInput) XXX_Size() int
func (*ConvertInput) XXX_Unmarshal ¶ added in v0.4.0
func (m *ConvertInput) XXX_Unmarshal(b []byte) error
type ConvertOutput ¶ added in v0.4.0
type ConvertOutput struct { ConvertedData string `protobuf:"bytes,1,opt,name=converted_data,json=convertedData,proto3" json:"converted_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConvertOutput) Descriptor ¶ added in v0.4.0
func (*ConvertOutput) Descriptor() ([]byte, []int)
func (*ConvertOutput) GetConvertedData ¶ added in v0.4.0
func (m *ConvertOutput) GetConvertedData() string
func (*ConvertOutput) ProtoMessage ¶ added in v0.4.0
func (*ConvertOutput) ProtoMessage()
func (*ConvertOutput) Reset ¶ added in v0.4.0
func (m *ConvertOutput) Reset()
func (*ConvertOutput) String ¶ added in v0.4.0
func (m *ConvertOutput) String() string
func (*ConvertOutput) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *ConvertOutput) XXX_DiscardUnknown()
func (*ConvertOutput) XXX_Marshal ¶ added in v0.4.0
func (m *ConvertOutput) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConvertOutput) XXX_Merge ¶ added in v0.4.0
func (m *ConvertOutput) XXX_Merge(src proto.Message)
func (*ConvertOutput) XXX_Size ¶ added in v0.4.0
func (m *ConvertOutput) XXX_Size() int
func (*ConvertOutput) XXX_Unmarshal ¶ added in v0.4.0
func (m *ConvertOutput) XXX_Unmarshal(b []byte) error
type ExposedAppClient ¶ added in v0.3.0
type ExposedAppClient interface { GetRandom(ctx context.Context, in *RandomRequest, opts ...grpc.CallOption) (*RandomResponse, error) PostUploadPhoto(ctx context.Context, in *UploadPhotoRequest, opts ...grpc.CallOption) (*UploadPhotoResponse, error) PostFeed(ctx context.Context, opts ...grpc.CallOption) (ExposedApp_PostFeedClient, error) GetBroadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (ExposedApp_GetBroadcastClient, error) PostConvertToString(ctx context.Context, opts ...grpc.CallOption) (ExposedApp_PostConvertToStringClient, error) }
ExposedAppClient is the client API for ExposedApp service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExposedAppClient ¶ added in v0.3.0
func NewExposedAppClient(cc *grpc.ClientConn) ExposedAppClient
type ExposedAppServer ¶ added in v0.3.0
type ExposedAppServer interface { GetRandom(context.Context, *RandomRequest) (*RandomResponse, error) PostUploadPhoto(context.Context, *UploadPhotoRequest) (*UploadPhotoResponse, error) PostFeed(ExposedApp_PostFeedServer) error GetBroadcast(*BroadcastRequest, ExposedApp_GetBroadcastServer) error PostConvertToString(ExposedApp_PostConvertToStringServer) error }
ExposedAppServer is the server API for ExposedApp service.
type ExposedApp_GetBroadcastClient ¶ added in v0.4.0
type ExposedApp_GetBroadcastClient interface { Recv() (*BroadcastData, error) grpc.ClientStream }
type ExposedApp_GetBroadcastServer ¶ added in v0.4.0
type ExposedApp_GetBroadcastServer interface { Send(*BroadcastData) error grpc.ServerStream }
type ExposedApp_PostConvertToStringClient ¶ added in v0.4.0
type ExposedApp_PostConvertToStringClient interface { Send(*ConvertInput) error Recv() (*ConvertOutput, error) grpc.ClientStream }
type ExposedApp_PostConvertToStringServer ¶ added in v0.4.0
type ExposedApp_PostConvertToStringServer interface { Send(*ConvertOutput) error Recv() (*ConvertInput, error) grpc.ServerStream }
type ExposedApp_PostFeedClient ¶ added in v0.4.0
type ExposedApp_PostFeedClient interface { Send(*FeedData) error CloseAndRecv() (*FeedResponse, error) grpc.ClientStream }
type ExposedApp_PostFeedServer ¶ added in v0.4.0
type ExposedApp_PostFeedServer interface { SendAndClose(*FeedResponse) error Recv() (*FeedData, error) grpc.ServerStream }
type FeedData ¶ added in v0.4.0
type FeedData struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DataType uint64 `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty"` RawData []byte `protobuf:"bytes,3,opt,name=raw_data,json=rawData,proto3" json:"raw_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FeedData) Descriptor ¶ added in v0.4.0
func (*FeedData) GetDataType ¶ added in v0.4.0
func (*FeedData) GetRawData ¶ added in v0.4.0
func (*FeedData) ProtoMessage ¶ added in v0.4.0
func (*FeedData) ProtoMessage()
func (*FeedData) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *FeedData) XXX_DiscardUnknown()
func (*FeedData) XXX_Marshal ¶ added in v0.4.0
func (*FeedData) XXX_Unmarshal ¶ added in v0.4.0
type FeedResponse ¶ added in v0.4.0
type FeedResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FeedResponse) Descriptor ¶ added in v0.4.0
func (*FeedResponse) Descriptor() ([]byte, []int)
func (*FeedResponse) ProtoMessage ¶ added in v0.4.0
func (*FeedResponse) ProtoMessage()
func (*FeedResponse) Reset ¶ added in v0.4.0
func (m *FeedResponse) Reset()
func (*FeedResponse) String ¶ added in v0.4.0
func (m *FeedResponse) String() string
func (*FeedResponse) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *FeedResponse) XXX_DiscardUnknown()
func (*FeedResponse) XXX_Marshal ¶ added in v0.4.0
func (m *FeedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FeedResponse) XXX_Merge ¶ added in v0.4.0
func (m *FeedResponse) XXX_Merge(src proto.Message)
func (*FeedResponse) XXX_Size ¶ added in v0.4.0
func (m *FeedResponse) XXX_Size() int
func (*FeedResponse) XXX_Unmarshal ¶ added in v0.4.0
func (m *FeedResponse) XXX_Unmarshal(b []byte) error
type FibonacciRequest ¶
type FibonacciRequest struct { // The 1-indexed point in the Fibonacci sequence N uint64 `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FibonacciRequest) Descriptor ¶
func (*FibonacciRequest) Descriptor() ([]byte, []int)
func (*FibonacciRequest) GetN ¶
func (m *FibonacciRequest) GetN() uint64
func (*FibonacciRequest) ProtoMessage ¶
func (*FibonacciRequest) ProtoMessage()
func (*FibonacciRequest) Reset ¶
func (m *FibonacciRequest) Reset()
func (*FibonacciRequest) String ¶
func (m *FibonacciRequest) String() string
func (*FibonacciRequest) XXX_DiscardUnknown ¶
func (m *FibonacciRequest) XXX_DiscardUnknown()
func (*FibonacciRequest) XXX_Marshal ¶
func (m *FibonacciRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FibonacciRequest) XXX_Merge ¶
func (m *FibonacciRequest) XXX_Merge(src proto.Message)
func (*FibonacciRequest) XXX_Size ¶
func (m *FibonacciRequest) XXX_Size() int
func (*FibonacciRequest) XXX_Unmarshal ¶
func (m *FibonacciRequest) XXX_Unmarshal(b []byte) error
type FibonacciResponse ¶
type FibonacciResponse struct { // The number found in the nth place of the sequence Number uint64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FibonacciResponse) Descriptor ¶
func (*FibonacciResponse) Descriptor() ([]byte, []int)
func (*FibonacciResponse) GetNumber ¶
func (m *FibonacciResponse) GetNumber() uint64
func (*FibonacciResponse) ProtoMessage ¶
func (*FibonacciResponse) ProtoMessage()
func (*FibonacciResponse) Reset ¶
func (m *FibonacciResponse) Reset()
func (*FibonacciResponse) String ¶
func (m *FibonacciResponse) String() string
func (*FibonacciResponse) XXX_DiscardUnknown ¶
func (m *FibonacciResponse) XXX_DiscardUnknown()
func (*FibonacciResponse) XXX_Marshal ¶
func (m *FibonacciResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FibonacciResponse) XXX_Merge ¶
func (m *FibonacciResponse) XXX_Merge(src proto.Message)
func (*FibonacciResponse) XXX_Size ¶
func (m *FibonacciResponse) XXX_Size() int
func (*FibonacciResponse) XXX_Unmarshal ¶
func (m *FibonacciResponse) XXX_Unmarshal(b []byte) error
type Handle ¶
type Handle struct {
// contains filtered or unexported fields
}
Handle is an example GRPC server for a microservice
func (*Handle) Broadcast ¶ added in v0.4.0
func (h *Handle) Broadcast(in *BroadcastRequest, stream App_BroadcastServer) error
Broadcast asks the App to broadcast data in a stream
func (*Handle) ConvertToString ¶ added in v0.4.0
func (h *Handle) ConvertToString(stream App_ConvertToStringServer) error
ConvertToString streams conversions of the input stream to strings
func (*Handle) Feed ¶ added in v0.4.0
func (h *Handle) Feed(stream App_FeedServer) error
Feed handles streamed inputs
func (*Handle) Fibonacci ¶
func (h *Handle) Fibonacci(ctx context.Context, in *FibonacciRequest) (*FibonacciResponse, error)
Fibonacci returns the nth number in the Fibonacci sequence. It does not start with an HTTP method and is therefore not exposed
func (*Handle) MakeClientConn ¶
func (h *Handle) MakeClientConn() (*grpc.ClientConn, error)
MakeClientConn returns a client connection to this service
func (*Handle) Random ¶
func (h *Handle) Random(ctx context.Context, in *RandomRequest) (*RandomResponse, error)
Random returns a random integer in the desired range. It may be accessed via a Get request to the proxy at, for example, /api/Service/Random
func (*Handle) UploadPhoto ¶
func (h *Handle) UploadPhoto(ctx context.Context, in *UploadPhotoRequest) (*UploadPhotoResponse, error)
UploadPhoto allows the upload of a photo to some persistence store. It may be accessed via Post request to the proxy at, for example, /api/Service/UploadPhoto
type RandomRequest ¶
type RandomRequest struct { // The lowest inclusive integer for the resulting random number LowerBound int64 `protobuf:"varint,1,opt,name=lower_bound,json=lowerBound,proto3" json:"lower_bound,omitempty"` // The highest inclusive integer for the resulting random number UpperBound int64 `protobuf:"varint,2,opt,name=upper_bound,json=upperBound,proto3" json:"upper_bound,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RandomRequest) Descriptor ¶
func (*RandomRequest) Descriptor() ([]byte, []int)
func (*RandomRequest) GetLowerBound ¶
func (m *RandomRequest) GetLowerBound() int64
func (*RandomRequest) GetUpperBound ¶
func (m *RandomRequest) GetUpperBound() int64
func (*RandomRequest) ProtoMessage ¶
func (*RandomRequest) ProtoMessage()
func (*RandomRequest) Reset ¶
func (m *RandomRequest) Reset()
func (*RandomRequest) String ¶
func (m *RandomRequest) String() string
func (*RandomRequest) XXX_DiscardUnknown ¶
func (m *RandomRequest) XXX_DiscardUnknown()
func (*RandomRequest) XXX_Marshal ¶
func (m *RandomRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RandomRequest) XXX_Merge ¶
func (m *RandomRequest) XXX_Merge(src proto.Message)
func (*RandomRequest) XXX_Size ¶
func (m *RandomRequest) XXX_Size() int
func (*RandomRequest) XXX_Unmarshal ¶
func (m *RandomRequest) XXX_Unmarshal(b []byte) error
type RandomResponse ¶
type RandomResponse struct { // The generated number Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RandomResponse) Descriptor ¶
func (*RandomResponse) Descriptor() ([]byte, []int)
func (*RandomResponse) GetNumber ¶
func (m *RandomResponse) GetNumber() int64
func (*RandomResponse) ProtoMessage ¶
func (*RandomResponse) ProtoMessage()
func (*RandomResponse) Reset ¶
func (m *RandomResponse) Reset()
func (*RandomResponse) String ¶
func (m *RandomResponse) String() string
func (*RandomResponse) XXX_DiscardUnknown ¶
func (m *RandomResponse) XXX_DiscardUnknown()
func (*RandomResponse) XXX_Marshal ¶
func (m *RandomResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RandomResponse) XXX_Merge ¶
func (m *RandomResponse) XXX_Merge(src proto.Message)
func (*RandomResponse) XXX_Size ¶
func (m *RandomResponse) XXX_Size() int
func (*RandomResponse) XXX_Unmarshal ¶
func (m *RandomResponse) XXX_Unmarshal(b []byte) error
type UnimplementedAppServer ¶ added in v0.3.0
type UnimplementedAppServer struct { }
UnimplementedAppServer can be embedded to have forward compatible implementations.
func (*UnimplementedAppServer) Broadcast ¶ added in v0.4.0
func (*UnimplementedAppServer) Broadcast(req *BroadcastRequest, srv App_BroadcastServer) error
func (*UnimplementedAppServer) ConvertToString ¶ added in v0.4.0
func (*UnimplementedAppServer) ConvertToString(srv App_ConvertToStringServer) error
func (*UnimplementedAppServer) Feed ¶ added in v0.4.0
func (*UnimplementedAppServer) Feed(srv App_FeedServer) error
func (*UnimplementedAppServer) Fibonacci ¶ added in v0.3.0
func (*UnimplementedAppServer) Fibonacci(ctx context.Context, req *FibonacciRequest) (*FibonacciResponse, error)
func (*UnimplementedAppServer) Random ¶ added in v0.3.0
func (*UnimplementedAppServer) Random(ctx context.Context, req *RandomRequest) (*RandomResponse, error)
func (*UnimplementedAppServer) UploadPhoto ¶ added in v0.3.0
func (*UnimplementedAppServer) UploadPhoto(ctx context.Context, req *UploadPhotoRequest) (*UploadPhotoResponse, error)
type UnimplementedExposedAppServer ¶ added in v0.3.0
type UnimplementedExposedAppServer struct { }
UnimplementedExposedAppServer can be embedded to have forward compatible implementations.
func (*UnimplementedExposedAppServer) GetBroadcast ¶ added in v0.4.0
func (*UnimplementedExposedAppServer) GetBroadcast(req *BroadcastRequest, srv ExposedApp_GetBroadcastServer) error
func (*UnimplementedExposedAppServer) GetRandom ¶ added in v0.3.0
func (*UnimplementedExposedAppServer) GetRandom(ctx context.Context, req *RandomRequest) (*RandomResponse, error)
func (*UnimplementedExposedAppServer) PostConvertToString ¶ added in v0.4.0
func (*UnimplementedExposedAppServer) PostConvertToString(srv ExposedApp_PostConvertToStringServer) error
func (*UnimplementedExposedAppServer) PostFeed ¶ added in v0.4.0
func (*UnimplementedExposedAppServer) PostFeed(srv ExposedApp_PostFeedServer) error
func (*UnimplementedExposedAppServer) PostUploadPhoto ¶ added in v0.3.0
func (*UnimplementedExposedAppServer) PostUploadPhoto(ctx context.Context, req *UploadPhotoRequest) (*UploadPhotoResponse, error)
type UploadPhotoRequest ¶
type UploadPhotoRequest struct { // The raw bytes of the photo Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UploadPhotoRequest) Descriptor ¶
func (*UploadPhotoRequest) Descriptor() ([]byte, []int)
func (*UploadPhotoRequest) GetData ¶
func (m *UploadPhotoRequest) GetData() []byte
func (*UploadPhotoRequest) ProtoMessage ¶
func (*UploadPhotoRequest) ProtoMessage()
func (*UploadPhotoRequest) Reset ¶
func (m *UploadPhotoRequest) Reset()
func (*UploadPhotoRequest) String ¶
func (m *UploadPhotoRequest) String() string
func (*UploadPhotoRequest) XXX_DiscardUnknown ¶
func (m *UploadPhotoRequest) XXX_DiscardUnknown()
func (*UploadPhotoRequest) XXX_Marshal ¶
func (m *UploadPhotoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UploadPhotoRequest) XXX_Merge ¶
func (m *UploadPhotoRequest) XXX_Merge(src proto.Message)
func (*UploadPhotoRequest) XXX_Size ¶
func (m *UploadPhotoRequest) XXX_Size() int
func (*UploadPhotoRequest) XXX_Unmarshal ¶
func (m *UploadPhotoRequest) XXX_Unmarshal(b []byte) error
type UploadPhotoResponse ¶
type UploadPhotoResponse struct { // The uuid generated to identify and retreive this photo Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UploadPhotoResponse) Descriptor ¶
func (*UploadPhotoResponse) Descriptor() ([]byte, []int)
func (*UploadPhotoResponse) GetUuid ¶
func (m *UploadPhotoResponse) GetUuid() string
func (*UploadPhotoResponse) ProtoMessage ¶
func (*UploadPhotoResponse) ProtoMessage()
func (*UploadPhotoResponse) Reset ¶
func (m *UploadPhotoResponse) Reset()
func (*UploadPhotoResponse) String ¶
func (m *UploadPhotoResponse) String() string
func (*UploadPhotoResponse) XXX_DiscardUnknown ¶
func (m *UploadPhotoResponse) XXX_DiscardUnknown()
func (*UploadPhotoResponse) XXX_Marshal ¶
func (m *UploadPhotoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UploadPhotoResponse) XXX_Merge ¶
func (m *UploadPhotoResponse) XXX_Merge(src proto.Message)
func (*UploadPhotoResponse) XXX_Size ¶
func (m *UploadPhotoResponse) XXX_Size() int
func (*UploadPhotoResponse) XXX_Unmarshal ¶
func (m *UploadPhotoResponse) XXX_Unmarshal(b []byte) error