Versions in this module Expand all Collapse all v0 v0.1.0 Jul 14, 2023 Changes in this version + const SourceService_Stream_FullMethodName + var File_v1_stream_proto protoreflect.FileDescriptor + var SourceService_ServiceDesc = grpc.ServiceDesc + func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer) + type Ack struct + AckPosition []byte + func (*Ack) Descriptor() ([]byte, []int) + func (*Ack) ProtoMessage() + func (x *Ack) GetAckPosition() []byte + func (x *Ack) ProtoReflect() protoreflect.Message + func (x *Ack) Reset() + func (x *Ack) String() string + type MockSourceServiceClient struct + func NewMockSourceServiceClient(ctrl *gomock.Controller) *MockSourceServiceClient + func (m *MockSourceServiceClient) EXPECT() *MockSourceServiceClientMockRecorder + func (m *MockSourceServiceClient) Stream(ctx context.Context, opts ...grpc.CallOption) (SourceService_StreamClient, error) + type MockSourceServiceClientMockRecorder struct + func (mr *MockSourceServiceClientMockRecorder) Stream(ctx interface{}, opts ...interface{}) *gomock.Call + type MockSourceServiceServer struct + func NewMockSourceServiceServer(ctrl *gomock.Controller) *MockSourceServiceServer + func (m *MockSourceServiceServer) EXPECT() *MockSourceServiceServerMockRecorder + func (m *MockSourceServiceServer) Stream(arg0 SourceService_StreamServer) error + type MockSourceServiceServerMockRecorder struct + func (mr *MockSourceServiceServerMockRecorder) Stream(arg0 interface{}) *gomock.Call + type MockSourceService_StreamClient struct + func NewMockSourceService_StreamClient(ctrl *gomock.Controller) *MockSourceService_StreamClient + func (m *MockSourceService_StreamClient) CloseSend() error + func (m *MockSourceService_StreamClient) Context() context.Context + func (m *MockSourceService_StreamClient) EXPECT() *MockSourceService_StreamClientMockRecorder + func (m *MockSourceService_StreamClient) Header() (metadata.MD, error) + func (m *MockSourceService_StreamClient) Recv() (*Ack, error) + func (m *MockSourceService_StreamClient) Send(arg0 *v1.Record) error + func (m *MockSourceService_StreamClient) Trailer() metadata.MD + func (m_2 *MockSourceService_StreamClient) RecvMsg(m interface{}) error + func (m_2 *MockSourceService_StreamClient) SendMsg(m interface{}) error + type MockSourceService_StreamClientMockRecorder struct + func (mr *MockSourceService_StreamClientMockRecorder) CloseSend() *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) Context() *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) Header() *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) Recv() *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSourceService_StreamClientMockRecorder) Trailer() *gomock.Call + type MockSourceService_StreamServer struct + func NewMockSourceService_StreamServer(ctrl *gomock.Controller) *MockSourceService_StreamServer + func (m *MockSourceService_StreamServer) Context() context.Context + func (m *MockSourceService_StreamServer) EXPECT() *MockSourceService_StreamServerMockRecorder + func (m *MockSourceService_StreamServer) Recv() (*v1.Record, error) + func (m *MockSourceService_StreamServer) Send(arg0 *Ack) error + func (m *MockSourceService_StreamServer) SendHeader(arg0 metadata.MD) error + func (m *MockSourceService_StreamServer) SetHeader(arg0 metadata.MD) error + func (m *MockSourceService_StreamServer) SetTrailer(arg0 metadata.MD) + func (m_2 *MockSourceService_StreamServer) RecvMsg(m interface{}) error + func (m_2 *MockSourceService_StreamServer) SendMsg(m interface{}) error + type MockSourceService_StreamServerMockRecorder struct + func (mr *MockSourceService_StreamServerMockRecorder) Context() *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) Recv() *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) RecvMsg(m interface{}) *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) SendMsg(m interface{}) *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call + func (mr *MockSourceService_StreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call + type MockUnsafeSourceServiceServer struct + func NewMockUnsafeSourceServiceServer(ctrl *gomock.Controller) *MockUnsafeSourceServiceServer + func (m *MockUnsafeSourceServiceServer) EXPECT() *MockUnsafeSourceServiceServerMockRecorder + type MockUnsafeSourceServiceServerMockRecorder struct + type SourceServiceClient interface + Stream func(ctx context.Context, opts ...grpc.CallOption) (SourceService_StreamClient, error) + func NewSourceServiceClient(cc grpc.ClientConnInterface) SourceServiceClient + type SourceServiceServer interface + Stream func(SourceService_StreamServer) error + type SourceService_StreamClient interface + Recv func() (*Ack, error) + Send func(*v1.Record) error + type SourceService_StreamServer interface + Recv func() (*v1.Record, error) + Send func(*Ack) error + type UnimplementedSourceServiceServer struct + func (UnimplementedSourceServiceServer) Stream(SourceService_StreamServer) error + type UnsafeSourceServiceServer interface
Go to main page