Documentation ¶
Index ¶
- Variables
- func RegisterAPIServer(s *grpc.Server, srv APIServer)
- type APIClient
- type APIServer
- type API_ListenClient
- type API_ListenServer
- type ListenRequest
- func (*ListenRequest) Descriptor() ([]byte, []int)
- func (m *ListenRequest) GetChannel() string
- func (m *ListenRequest) Marshal() (dAtA []byte, err error)
- func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *ListenRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListenRequest) ProtoMessage()
- func (m *ListenRequest) Reset()
- func (m *ListenRequest) Size() (n int)
- func (m *ListenRequest) String() string
- func (m *ListenRequest) Unmarshal(dAtA []byte) error
- func (m *ListenRequest) XXX_DiscardUnknown()
- func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListenRequest) XXX_Merge(src proto.Message)
- func (m *ListenRequest) XXX_Size() int
- func (m *ListenRequest) XXX_Unmarshal(b []byte) error
- type ListenResponse
- func (*ListenResponse) Descriptor() ([]byte, []int)
- func (m *ListenResponse) GetExtra() string
- func (m *ListenResponse) Marshal() (dAtA []byte, err error)
- func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (m *ListenResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListenResponse) ProtoMessage()
- func (m *ListenResponse) Reset()
- func (m *ListenResponse) Size() (n int)
- func (m *ListenResponse) String() string
- func (m *ListenResponse) Unmarshal(dAtA []byte) error
- func (m *ListenResponse) XXX_DiscardUnknown()
- func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListenResponse) XXX_Merge(src proto.Message)
- func (m *ListenResponse) XXX_Size() int
- func (m *ListenResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedAPIServer
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterAPIServer ¶
Types ¶
type APIClient ¶
type APIClient interface { // Listen streams database events. // It signals that it is internally set up by sending an initial empty ListenResponse. Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error) }
APIClient is the client API for API service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAPIClient ¶
func NewAPIClient(cc *grpc.ClientConn) APIClient
type APIServer ¶
type APIServer interface { // Listen streams database events. // It signals that it is internally set up by sending an initial empty ListenResponse. Listen(*ListenRequest, API_ListenServer) error }
APIServer is the server API for API service.
type API_ListenClient ¶
type API_ListenClient interface { Recv() (*ListenResponse, error) grpc.ClientStream }
type API_ListenServer ¶
type API_ListenServer interface { Send(*ListenResponse) error grpc.ServerStream }
type ListenRequest ¶
type ListenRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListenRequest) Descriptor ¶
func (*ListenRequest) Descriptor() ([]byte, []int)
func (*ListenRequest) GetChannel ¶
func (m *ListenRequest) GetChannel() string
func (*ListenRequest) Marshal ¶
func (m *ListenRequest) Marshal() (dAtA []byte, err error)
func (*ListenRequest) MarshalLogObject ¶
func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ListenRequest) MarshalToSizedBuffer ¶
func (m *ListenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListenRequest) ProtoMessage ¶
func (*ListenRequest) ProtoMessage()
func (*ListenRequest) Reset ¶
func (m *ListenRequest) Reset()
func (*ListenRequest) Size ¶
func (m *ListenRequest) Size() (n int)
func (*ListenRequest) String ¶
func (m *ListenRequest) String() string
func (*ListenRequest) Unmarshal ¶
func (m *ListenRequest) Unmarshal(dAtA []byte) error
func (*ListenRequest) XXX_DiscardUnknown ¶
func (m *ListenRequest) XXX_DiscardUnknown()
func (*ListenRequest) XXX_Marshal ¶
func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListenRequest) XXX_Merge ¶
func (m *ListenRequest) XXX_Merge(src proto.Message)
func (*ListenRequest) XXX_Size ¶
func (m *ListenRequest) XXX_Size() int
func (*ListenRequest) XXX_Unmarshal ¶
func (m *ListenRequest) XXX_Unmarshal(b []byte) error
type ListenResponse ¶
type ListenResponse struct { Extra string `protobuf:"bytes,1,opt,name=extra,proto3" json:"extra,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListenResponse) Descriptor ¶
func (*ListenResponse) Descriptor() ([]byte, []int)
func (*ListenResponse) GetExtra ¶
func (m *ListenResponse) GetExtra() string
func (*ListenResponse) Marshal ¶
func (m *ListenResponse) Marshal() (dAtA []byte, err error)
func (*ListenResponse) MarshalLogObject ¶
func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ListenResponse) MarshalToSizedBuffer ¶
func (m *ListenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListenResponse) ProtoMessage ¶
func (*ListenResponse) ProtoMessage()
func (*ListenResponse) Reset ¶
func (m *ListenResponse) Reset()
func (*ListenResponse) Size ¶
func (m *ListenResponse) Size() (n int)
func (*ListenResponse) String ¶
func (m *ListenResponse) String() string
func (*ListenResponse) Unmarshal ¶
func (m *ListenResponse) Unmarshal(dAtA []byte) error
func (*ListenResponse) XXX_DiscardUnknown ¶
func (m *ListenResponse) XXX_DiscardUnknown()
func (*ListenResponse) XXX_Marshal ¶
func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListenResponse) XXX_Merge ¶
func (m *ListenResponse) XXX_Merge(src proto.Message)
func (*ListenResponse) XXX_Size ¶
func (m *ListenResponse) XXX_Size() int
func (*ListenResponse) XXX_Unmarshal ¶
func (m *ListenResponse) XXX_Unmarshal(b []byte) error
type UnimplementedAPIServer ¶
type UnimplementedAPIServer struct { }
UnimplementedAPIServer can be embedded to have forward compatible implementations.
func (*UnimplementedAPIServer) Listen ¶
func (*UnimplementedAPIServer) Listen(req *ListenRequest, srv API_ListenServer) error
Click to show internal directories.
Click to hide internal directories.