v1

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 14, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package v1 is a generated GoMock package.

Index

Constants

View Source 
const (
	SourceService_Stream_FullMethodName = "/protov1.SourceService/Stream"
)

Variables

View Source 
var File_v1_stream_proto protoreflect.FileDescriptor
View Source 
var SourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protov1.SourceService",
	HandlerType: (*SourceServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _SourceService_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "v1/stream.proto",
}

SourceService_ServiceDesc is the grpc.ServiceDesc for SourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSourceServiceServer 

func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)

Types

type Ack 

type Ack struct {
	AckPosition []byte `protobuf:"bytes,1,opt,name=ack_position,json=ackPosition,proto3" json:"ack_position,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor deprecated 

func (*Ack) Descriptor() ([]byte, []int)

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetAckPosition 

func (x *Ack) GetAckPosition() []byte

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect 

func (x *Ack) ProtoReflect() protoreflect.Message

func (*Ack) Reset 

func (x *Ack) Reset()

func (*Ack) String 

func (x *Ack) String() string

type MockSourceServiceClient 

type MockSourceServiceClient struct {
	// contains filtered or unexported fields
}

MockSourceServiceClient is a mock of SourceServiceClient interface.

func NewMockSourceServiceClient 

func NewMockSourceServiceClient(ctrl *gomock.Controller) *MockSourceServiceClient

NewMockSourceServiceClient creates a new mock instance.

func (*MockSourceServiceClient) EXPECT 

func (m *MockSourceServiceClient) EXPECT() *MockSourceServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSourceServiceClient) Stream 

func (m *MockSourceServiceClient) Stream(ctx context.Context, opts ...grpc.CallOption) (SourceService_StreamClient, error)

Stream mocks base method.

type MockSourceServiceClientMockRecorder 

type MockSourceServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSourceServiceClientMockRecorder is the mock recorder for MockSourceServiceClient.

func (*MockSourceServiceClientMockRecorder) Stream 

func (mr *MockSourceServiceClientMockRecorder) Stream(ctx interface{}, opts ...interface{}) *gomock.Call

Stream indicates an expected call of Stream.

type MockSourceServiceServer 

type MockSourceServiceServer struct {
	// contains filtered or unexported fields
}

MockSourceServiceServer is a mock of SourceServiceServer interface.

func NewMockSourceServiceServer 

func NewMockSourceServiceServer(ctrl *gomock.Controller) *MockSourceServiceServer

NewMockSourceServiceServer creates a new mock instance.

func (*MockSourceServiceServer) EXPECT 

func (m *MockSourceServiceServer) EXPECT() *MockSourceServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSourceServiceServer) Stream 

func (m *MockSourceServiceServer) Stream(arg0 SourceService_StreamServer) error

Stream mocks base method.

type MockSourceServiceServerMockRecorder 

type MockSourceServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSourceServiceServerMockRecorder is the mock recorder for MockSourceServiceServer.

func (*MockSourceServiceServerMockRecorder) Stream 

func (mr *MockSourceServiceServerMockRecorder) Stream(arg0 interface{}) *gomock.Call

Stream indicates an expected call of Stream.

type MockSourceService_StreamClient 

type MockSourceService_StreamClient struct {
	// contains filtered or unexported fields
}

MockSourceService_StreamClient is a mock of SourceService_StreamClient interface.

func NewMockSourceService_StreamClient 

func NewMockSourceService_StreamClient(ctrl *gomock.Controller) *MockSourceService_StreamClient

NewMockSourceService_StreamClient creates a new mock instance.

func (*MockSourceService_StreamClient) CloseSend 

func (m *MockSourceService_StreamClient) CloseSend() error

CloseSend mocks base method.

func (*MockSourceService_StreamClient) Context 

func (m *MockSourceService_StreamClient) Context() context.Context

Context mocks base method.

func (*MockSourceService_StreamClient) EXPECT 

func (m *MockSourceService_StreamClient) EXPECT() *MockSourceService_StreamClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSourceService_StreamClient) Header 

func (m *MockSourceService_StreamClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockSourceService_StreamClient) Recv 

func (m *MockSourceService_StreamClient) Recv() (*Ack, error)

Recv mocks base method.

func (*MockSourceService_StreamClient) RecvMsg 

func (m_2 *MockSourceService_StreamClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockSourceService_StreamClient) Send 

func (m *MockSourceService_StreamClient) Send(arg0 *v1.Record) error

Send mocks base method.

func (*MockSourceService_StreamClient) SendMsg 

func (m_2 *MockSourceService_StreamClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockSourceService_StreamClient) Trailer 

func (m *MockSourceService_StreamClient) Trailer() metadata.MD

Trailer mocks base method.

type MockSourceService_StreamClientMockRecorder 

type MockSourceService_StreamClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSourceService_StreamClientMockRecorder is the mock recorder for MockSourceService_StreamClient.

func (*MockSourceService_StreamClientMockRecorder) CloseSend 

func (mr *MockSourceService_StreamClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockSourceService_StreamClientMockRecorder) Context 

func (mr *MockSourceService_StreamClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockSourceService_StreamClientMockRecorder) Header 

func (mr *MockSourceService_StreamClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockSourceService_StreamClientMockRecorder) Recv 

func (mr *MockSourceService_StreamClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockSourceService_StreamClientMockRecorder) RecvMsg 

func (mr *MockSourceService_StreamClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockSourceService_StreamClientMockRecorder) Send 

func (mr *MockSourceService_StreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockSourceService_StreamClientMockRecorder) SendMsg 

func (mr *MockSourceService_StreamClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockSourceService_StreamClientMockRecorder) Trailer 

func (mr *MockSourceService_StreamClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockSourceService_StreamServer 

type MockSourceService_StreamServer struct {
	// contains filtered or unexported fields
}

MockSourceService_StreamServer is a mock of SourceService_StreamServer interface.

func NewMockSourceService_StreamServer 

func NewMockSourceService_StreamServer(ctrl *gomock.Controller) *MockSourceService_StreamServer

NewMockSourceService_StreamServer creates a new mock instance.

func (*MockSourceService_StreamServer) Context 

func (m *MockSourceService_StreamServer) Context() context.Context

Context mocks base method.

func (*MockSourceService_StreamServer) EXPECT 

func (m *MockSourceService_StreamServer) EXPECT() *MockSourceService_StreamServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSourceService_StreamServer) Recv 

func (m *MockSourceService_StreamServer) Recv() (*v1.Record, error)

Recv mocks base method.

func (*MockSourceService_StreamServer) RecvMsg 

func (m_2 *MockSourceService_StreamServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockSourceService_StreamServer) Send 

func (m *MockSourceService_StreamServer) Send(arg0 *Ack) error

Send mocks base method.

func (*MockSourceService_StreamServer) SendHeader 

func (m *MockSourceService_StreamServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockSourceService_StreamServer) SendMsg 

func (m_2 *MockSourceService_StreamServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockSourceService_StreamServer) SetHeader 

func (m *MockSourceService_StreamServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockSourceService_StreamServer) SetTrailer 

func (m *MockSourceService_StreamServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockSourceService_StreamServerMockRecorder 

type MockSourceService_StreamServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSourceService_StreamServerMockRecorder is the mock recorder for MockSourceService_StreamServer.

func (*MockSourceService_StreamServerMockRecorder) Context 

func (mr *MockSourceService_StreamServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockSourceService_StreamServerMockRecorder) Recv 

func (mr *MockSourceService_StreamServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockSourceService_StreamServerMockRecorder) RecvMsg 

func (mr *MockSourceService_StreamServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockSourceService_StreamServerMockRecorder) Send 

func (mr *MockSourceService_StreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockSourceService_StreamServerMockRecorder) SendHeader 

func (mr *MockSourceService_StreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockSourceService_StreamServerMockRecorder) SendMsg 

func (mr *MockSourceService_StreamServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockSourceService_StreamServerMockRecorder) SetHeader 

func (mr *MockSourceService_StreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockSourceService_StreamServerMockRecorder) SetTrailer 

func (mr *MockSourceService_StreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafeSourceServiceServer 

type MockUnsafeSourceServiceServer struct {
	// contains filtered or unexported fields
}

MockUnsafeSourceServiceServer is a mock of UnsafeSourceServiceServer interface.

func NewMockUnsafeSourceServiceServer 

func NewMockUnsafeSourceServiceServer(ctrl *gomock.Controller) *MockUnsafeSourceServiceServer

NewMockUnsafeSourceServiceServer creates a new mock instance.

func (*MockUnsafeSourceServiceServer) EXPECT 

func (m *MockUnsafeSourceServiceServer) EXPECT() *MockUnsafeSourceServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeSourceServiceServerMockRecorder 

type MockUnsafeSourceServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeSourceServiceServerMockRecorder is the mock recorder for MockUnsafeSourceServiceServer.

type SourceServiceClient 

type SourceServiceClient interface {
	Stream(ctx context.Context, opts ...grpc.CallOption) (SourceService_StreamClient, error)
}

SourceServiceClient is the client API for SourceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSourceServiceClient 

func NewSourceServiceClient(cc grpc.ClientConnInterface) SourceServiceClient

type SourceServiceServer 

type SourceServiceServer interface {
	Stream(SourceService_StreamServer) error
	// contains filtered or unexported methods
}

SourceServiceServer is the server API for SourceService service. All implementations must embed UnimplementedSourceServiceServer for forward compatibility

type SourceService_StreamClient 

type SourceService_StreamClient interface {
	Send(*v1.Record) error
	Recv() (*Ack, error)
	grpc.ClientStream
}

type SourceService_StreamServer 

type SourceService_StreamServer interface {
	Send(*Ack) error
	Recv() (*v1.Record, error)
	grpc.ServerStream
}

type UnimplementedSourceServiceServer 

type UnimplementedSourceServiceServer struct {
}

UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServiceServer) Stream 

func (UnimplementedSourceServiceServer) Stream(SourceService_StreamServer) error

type UnsafeSourceServiceServer 

type UnsafeSourceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SourceServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.