stateful

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
  • func NewStatefulClient(cc *grpc.ClientConn) StatefulClient
• type StatefulServer
• type UnimplementedStatefulServer
  • func (*UnimplementedStatefulServer) GetData(ctx context.Context, req *GetDataRequest) (*GetDataResponse, error)
  • func (*UnimplementedStatefulServer) SetData(ctx context.Context, req *SetDataRequest) (*empty.Empty, error)

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)