Versions in this module Expand all Collapse all v1 v1.0.1 Mar 28, 2020 v1.0.0 Mar 28, 2020 Changes in this version + func RegisterPushPullServer(s *grpc.Server, srv PushPullServer) + type PullRequest struct + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PullRequest) Descriptor() ([]byte, []int) + func (*PullRequest) ProtoMessage() + func (m *PullRequest) GetTopic() string + func (m *PullRequest) Reset() + func (m *PullRequest) String() string + func (m *PullRequest) XXX_DiscardUnknown() + func (m *PullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PullRequest) XXX_Merge(src proto.Message) + func (m *PullRequest) XXX_Size() int + func (m *PullRequest) XXX_Unmarshal(b []byte) error + type PullResponse struct + Payload []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PullResponse) Descriptor() ([]byte, []int) + func (*PullResponse) ProtoMessage() + func (m *PullResponse) GetPayload() []byte + func (m *PullResponse) Reset() + func (m *PullResponse) String() string + func (m *PullResponse) XXX_DiscardUnknown() + func (m *PullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PullResponse) XXX_Merge(src proto.Message) + func (m *PullResponse) XXX_Size() int + func (m *PullResponse) XXX_Unmarshal(b []byte) error + type PushPullClient interface + Pull func(ctx context.Context, in *PullRequest, opts ...grpc.CallOption) (PushPull_PullClient, error) + Push func(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*empty.Empty, error) + func NewPushPullClient(cc grpc.ClientConnInterface) PushPullClient + type PushPullServer interface + Pull func(*PullRequest, PushPull_PullServer) error + Push func(context.Context, *PushRequest) (*empty.Empty, error) + type PushPull_PullClient interface + Recv func() (*PullResponse, error) + type PushPull_PullServer interface + Send func(*PullResponse) error + type PushRequest struct + Payload []byte + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PushRequest) Descriptor() ([]byte, []int) + func (*PushRequest) ProtoMessage() + func (m *PushRequest) GetPayload() []byte + func (m *PushRequest) GetTopic() string + func (m *PushRequest) Reset() + func (m *PushRequest) String() string + func (m *PushRequest) XXX_DiscardUnknown() + func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PushRequest) XXX_Merge(src proto.Message) + func (m *PushRequest) XXX_Size() int + func (m *PushRequest) XXX_Unmarshal(b []byte) error + type UnimplementedPushPullServer struct + func (*UnimplementedPushPullServer) Pull(req *PullRequest, srv PushPull_PullServer) error + func (*UnimplementedPushPullServer) Push(ctx context.Context, req *PushRequest) (*empty.Empty, error)
Go to main page