Documentation
¶
Index ¶
- func RegisterStatefulServer(s *grpc.Server, srv StatefulServer)
- type GetDataRequest
- func (*GetDataRequest) Descriptor() ([]byte, []int)
- func (m *GetDataRequest) GetDevice() string
- func (*GetDataRequest) ProtoMessage()
- func (m *GetDataRequest) Reset()
- func (m *GetDataRequest) String() string
- func (m *GetDataRequest) XXX_DiscardUnknown()
- func (m *GetDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDataRequest) XXX_Merge(src proto.Message)
- func (m *GetDataRequest) XXX_Size() int
- func (m *GetDataRequest) XXX_Unmarshal(b []byte) error
- type GetDataResponse
- func (*GetDataResponse) Descriptor() ([]byte, []int)
- func (m *GetDataResponse) GetData() []byte
- func (*GetDataResponse) ProtoMessage()
- func (m *GetDataResponse) Reset()
- func (m *GetDataResponse) String() string
- func (m *GetDataResponse) XXX_DiscardUnknown()
- func (m *GetDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDataResponse) XXX_Merge(src proto.Message)
- func (m *GetDataResponse) XXX_Size() int
- func (m *GetDataResponse) XXX_Unmarshal(b []byte) error
- type SetDataRequest
- func (*SetDataRequest) Descriptor() ([]byte, []int)
- func (m *SetDataRequest) GetData() []byte
- func (m *SetDataRequest) GetDevice() string
- func (*SetDataRequest) ProtoMessage()
- func (m *SetDataRequest) Reset()
- func (m *SetDataRequest) String() string
- func (m *SetDataRequest) XXX_DiscardUnknown()
- func (m *SetDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetDataRequest) XXX_Merge(src proto.Message)
- func (m *SetDataRequest) XXX_Size() int
- func (m *SetDataRequest) XXX_Unmarshal(b []byte) error
- type StatefulClient
- type StatefulServer
- type UnimplementedStatefulServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterStatefulServer ¶
func RegisterStatefulServer(s *grpc.Server, srv StatefulServer)
Types ¶
type GetDataRequest ¶
type GetDataRequest struct {
Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetDataRequest) Descriptor ¶
func (*GetDataRequest) Descriptor() ([]byte, []int)
func (*GetDataRequest) GetDevice ¶
func (m *GetDataRequest) GetDevice() string
func (*GetDataRequest) ProtoMessage ¶
func (*GetDataRequest) ProtoMessage()
func (*GetDataRequest) Reset ¶
func (m *GetDataRequest) Reset()
func (*GetDataRequest) String ¶
func (m *GetDataRequest) String() string
func (*GetDataRequest) XXX_DiscardUnknown ¶
func (m *GetDataRequest) XXX_DiscardUnknown()
func (*GetDataRequest) XXX_Marshal ¶
func (m *GetDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDataRequest) XXX_Merge ¶
func (m *GetDataRequest) XXX_Merge(src proto.Message)
func (*GetDataRequest) XXX_Size ¶
func (m *GetDataRequest) XXX_Size() int
func (*GetDataRequest) XXX_Unmarshal ¶
func (m *GetDataRequest) XXX_Unmarshal(b []byte) error
type GetDataResponse ¶
type GetDataResponse struct {
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 (*GetDataResponse) Descriptor ¶
func (*GetDataResponse) Descriptor() ([]byte, []int)
func (*GetDataResponse) GetData ¶
func (m *GetDataResponse) GetData() []byte
func (*GetDataResponse) ProtoMessage ¶
func (*GetDataResponse) ProtoMessage()
func (*GetDataResponse) Reset ¶
func (m *GetDataResponse) Reset()
func (*GetDataResponse) String ¶
func (m *GetDataResponse) String() string
func (*GetDataResponse) XXX_DiscardUnknown ¶
func (m *GetDataResponse) XXX_DiscardUnknown()
func (*GetDataResponse) XXX_Marshal ¶
func (m *GetDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDataResponse) XXX_Merge ¶
func (m *GetDataResponse) XXX_Merge(src proto.Message)
func (*GetDataResponse) XXX_Size ¶
func (m *GetDataResponse) XXX_Size() int
func (*GetDataResponse) XXX_Unmarshal ¶
func (m *GetDataResponse) XXX_Unmarshal(b []byte) error
type SetDataRequest ¶
type SetDataRequest struct {
Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SetDataRequest) Descriptor ¶
func (*SetDataRequest) Descriptor() ([]byte, []int)
func (*SetDataRequest) GetData ¶
func (m *SetDataRequest) GetData() []byte
func (*SetDataRequest) GetDevice ¶
func (m *SetDataRequest) GetDevice() string
func (*SetDataRequest) ProtoMessage ¶
func (*SetDataRequest) ProtoMessage()
func (*SetDataRequest) Reset ¶
func (m *SetDataRequest) Reset()
func (*SetDataRequest) String ¶
func (m *SetDataRequest) String() string
func (*SetDataRequest) XXX_DiscardUnknown ¶
func (m *SetDataRequest) XXX_DiscardUnknown()
func (*SetDataRequest) XXX_Marshal ¶
func (m *SetDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetDataRequest) XXX_Merge ¶
func (m *SetDataRequest) XXX_Merge(src proto.Message)
func (*SetDataRequest) XXX_Size ¶
func (m *SetDataRequest) XXX_Size() int
func (*SetDataRequest) XXX_Unmarshal ¶
func (m *SetDataRequest) XXX_Unmarshal(b []byte) error
type StatefulClient ¶
type StatefulClient interface {
SetData(ctx context.Context, in *SetDataRequest, opts ...grpc.CallOption) (*empty.Empty, error)
GetData(ctx context.Context, in *GetDataRequest, opts ...grpc.CallOption) (*GetDataResponse, error)
}
StatefulClient is the client API for Stateful service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStatefulClient ¶
func NewStatefulClient(cc *grpc.ClientConn) StatefulClient
type StatefulServer ¶
type StatefulServer interface {
SetData(context.Context, *SetDataRequest) (*empty.Empty, error)
GetData(context.Context, *GetDataRequest) (*GetDataResponse, error)
}
StatefulServer is the server API for Stateful service.
type UnimplementedStatefulServer ¶
type UnimplementedStatefulServer struct {
}
UnimplementedStatefulServer can be embedded to have forward compatible implementations.
func (*UnimplementedStatefulServer) GetData ¶
func (*UnimplementedStatefulServer) GetData(ctx context.Context, req *GetDataRequest) (*GetDataResponse, error)
func (*UnimplementedStatefulServer) SetData ¶
func (*UnimplementedStatefulServer) SetData(ctx context.Context, req *SetDataRequest) (*empty.Empty, error)
Source Files
Click to show internal directories.
Click to hide internal directories.