Documentation ¶
Index ¶
- func RegisterStateServer(s *grpc.Server, srv StateServer)
- type Command
- func (*Command) Descriptor() ([]byte, []int)
- func (m *Command) GetID() int64
- func (m *Command) GetKind() string
- func (*Command) ProtoMessage()
- func (m *Command) Reset()
- func (m *Command) String() string
- func (m *Command) XXX_DiscardUnknown()
- func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Command) XXX_Merge(src proto.Message)
- func (m *Command) XXX_Size() int
- func (m *Command) XXX_Unmarshal(b []byte) error
- type Data
- func (*Data) Descriptor() ([]byte, []int)
- func (m *Data) GetContent() []byte
- func (*Data) ProtoMessage()
- func (m *Data) Reset()
- func (m *Data) String() string
- func (m *Data) XXX_DiscardUnknown()
- func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Data) XXX_Merge(src proto.Message)
- func (m *Data) XXX_Size() int
- func (m *Data) XXX_Unmarshal(b []byte) error
- type Domain
- func (*Domain) Descriptor() ([]byte, []int)
- func (m *Domain) GetName() string
- func (*Domain) ProtoMessage()
- func (m *Domain) Reset()
- func (m *Domain) String() string
- func (m *Domain) XXX_DiscardUnknown()
- func (m *Domain) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Domain) XXX_Merge(src proto.Message)
- func (m *Domain) XXX_Size() int
- func (m *Domain) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type Kind
- func (*Kind) Descriptor() ([]byte, []int)
- func (m *Kind) GetName() string
- func (*Kind) ProtoMessage()
- func (m *Kind) Reset()
- func (m *Kind) String() string
- func (m *Kind) XXX_DiscardUnknown()
- func (m *Kind) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Kind) XXX_Merge(src proto.Message)
- func (m *Kind) XXX_Size() int
- func (m *Kind) XXX_Unmarshal(b []byte) error
- type StateClient
- type StateServer
- type State_DrainClient
- type State_DrainServer
- type UnimplementedStateServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterStateServer ¶
func RegisterStateServer(s *grpc.Server, srv StateServer)
Types ¶
type Command ¶
type Command struct { Kind string `protobuf:"bytes,1,opt,name=Kind,proto3" json:"Kind,omitempty"` ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Command) Descriptor ¶
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
func (*Command) XXX_DiscardUnknown ¶
func (m *Command) XXX_DiscardUnknown()
func (*Command) XXX_Marshal ¶
func (*Command) XXX_Unmarshal ¶
type Data ¶
type Data struct { Content []byte `protobuf:"bytes,1,opt,name=Content,proto3" json:"Content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Data) Descriptor ¶
func (*Data) GetContent ¶
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) XXX_DiscardUnknown ¶
func (m *Data) XXX_DiscardUnknown()
func (*Data) XXX_Unmarshal ¶
type Domain ¶
type Domain struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Domain) Descriptor ¶
func (*Domain) ProtoMessage ¶
func (*Domain) ProtoMessage()
func (*Domain) XXX_DiscardUnknown ¶
func (m *Domain) XXX_DiscardUnknown()
func (*Domain) XXX_Marshal ¶
func (*Domain) XXX_Unmarshal ¶
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type Kind ¶
type Kind struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Kind) Descriptor ¶
func (*Kind) ProtoMessage ¶
func (*Kind) ProtoMessage()
func (*Kind) XXX_DiscardUnknown ¶
func (m *Kind) XXX_DiscardUnknown()
func (*Kind) XXX_Unmarshal ¶
type StateClient ¶
type StateClient interface { GetDomain(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Domain, error) Drain(ctx context.Context, in *Kind, opts ...grpc.CallOption) (State_DrainClient, error) SendCommand(ctx context.Context, in *Command, opts ...grpc.CallOption) (*Empty, error) }
StateClient is the client API for State service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStateClient ¶
func NewStateClient(cc *grpc.ClientConn) StateClient
type StateServer ¶
type StateServer interface { GetDomain(context.Context, *Empty) (*Domain, error) Drain(*Kind, State_DrainServer) error SendCommand(context.Context, *Command) (*Empty, error) }
StateServer is the server API for State service.
type State_DrainClient ¶
type State_DrainClient interface { Recv() (*Data, error) grpc.ClientStream }
type State_DrainServer ¶
type State_DrainServer interface { Send(*Data) error grpc.ServerStream }
type UnimplementedStateServer ¶
type UnimplementedStateServer struct { }
UnimplementedStateServer can be embedded to have forward compatible implementations.
func (*UnimplementedStateServer) Drain ¶
func (*UnimplementedStateServer) Drain(req *Kind, srv State_DrainServer) error
func (*UnimplementedStateServer) SendCommand ¶
Click to show internal directories.
Click to hide internal directories.