mocks

package
v0.0.10 Latest Latest
Warning

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

 Go to latest Published: May 29, 2022 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChiefOfStateServiceClient 

type ChiefOfStateServiceClient struct {
	mock.Mock
}

ChiefOfStateServiceClient is an autogenerated mock type for the ChiefOfStateServiceClient type

func NewChiefOfStateServiceClient 

func NewChiefOfStateServiceClient(t NewChiefOfStateServiceClientT) *ChiefOfStateServiceClient

NewChiefOfStateServiceClient creates a new instance of ChiefOfStateServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ChiefOfStateServiceClient) GetState 

func (_m *ChiefOfStateServiceClient) GetState(ctx context.Context, in *chief_of_statev1.GetStateRequest, opts ...grpc.CallOption) (*chief_of_statev1.GetStateResponse, error)

GetState provides a mock function with given fields: ctx, in, opts

func (*ChiefOfStateServiceClient) ProcessCommand 

func (_m *ChiefOfStateServiceClient) ProcessCommand(ctx context.Context, in *chief_of_statev1.ProcessCommandRequest, opts ...grpc.CallOption) (*chief_of_statev1.ProcessCommandResponse, error)

ProcessCommand provides a mock function with given fields: ctx, in, opts

type ChiefOfStateServiceServer 

type ChiefOfStateServiceServer struct {
	mock.Mock
}

ChiefOfStateServiceServer is an autogenerated mock type for the ChiefOfStateServiceServer type

func NewChiefOfStateServiceServer 

func NewChiefOfStateServiceServer(t NewChiefOfStateServiceServerT) *ChiefOfStateServiceServer

NewChiefOfStateServiceServer creates a new instance of ChiefOfStateServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ChiefOfStateServiceServer) GetState 

func (_m *ChiefOfStateServiceServer) GetState(_a0 context.Context, _a1 *chief_of_statev1.GetStateRequest) (*chief_of_statev1.GetStateResponse, error)

GetState provides a mock function with given fields: _a0, _a1

func (*ChiefOfStateServiceServer) ProcessCommand 

func (_m *ChiefOfStateServiceServer) ProcessCommand(_a0 context.Context, _a1 *chief_of_statev1.ProcessCommandRequest) (*chief_of_statev1.ProcessCommandResponse, error)

ProcessCommand provides a mock function with given fields: _a0, _a1

type ClientIFace added in v0.0.9 

type ClientIFace[T protoreflect.ProtoMessage] struct {
	mock.Mock
}

ClientIFace is an autogenerated mock type for the ClientIFace type

func NewClientIFace added in v0.0.9 

func NewClientIFace[T protoreflect.ProtoMessage](t NewClientIFaceT) *ClientIFace[T]

NewClientIFace creates a new instance of ClientIFace. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ClientIFace[T]) GetState added in v0.0.9 

func (_m *ClientIFace[T]) GetState(ctx context.Context, entityID string) (T, *chief_of_statev1.MetaData, error)

GetState provides a mock function with given fields: ctx, entityID

func (*ClientIFace[T]) ProcessCommand added in v0.0.9 

func (_m *ClientIFace[T]) ProcessCommand(ctx context.Context, entityID string, command protoreflect.ProtoMessage) (T, *chief_of_statev1.MetaData, error)

ProcessCommand provides a mock function with given fields: ctx, entityID, command

type NewChiefOfStateServiceClientT added in v0.0.9 

type NewChiefOfStateServiceClientT interface {
	mock.TestingT
	Cleanup(func())
}

type NewChiefOfStateServiceServerT added in v0.0.9 

type NewChiefOfStateServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewClientIFaceT added in v0.0.9 

type NewClientIFaceT interface {
	mock.TestingT
	Cleanup(func())
}

type NewReadSideHandlerServiceClientT added in v0.0.9 

type NewReadSideHandlerServiceClientT interface {
	mock.TestingT
	Cleanup(func())
}

type NewReadSideHandlerServiceServerT added in v0.0.9 

type NewReadSideHandlerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewReadSideManagerServiceClientT added in v0.0.9 

type NewReadSideManagerServiceClientT interface {
	mock.TestingT
	Cleanup(func())
}

type NewReadSideManagerServiceServerT added in v0.0.9 

type NewReadSideManagerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewUnsafeChiefOfStateServiceServerT added in v0.0.9 

type NewUnsafeChiefOfStateServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewUnsafeReadSideHandlerServiceServerT added in v0.0.9 

type NewUnsafeReadSideHandlerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewUnsafeReadSideManagerServiceServerT added in v0.0.9 

type NewUnsafeReadSideManagerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewUnsafeWriteSideHandlerServiceServerT added in v0.0.9 

type NewUnsafeWriteSideHandlerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type NewWriteSideHandlerServiceClientT added in v0.0.9 

type NewWriteSideHandlerServiceClientT interface {
	mock.TestingT
	Cleanup(func())
}

type NewWriteSideHandlerServiceServerT added in v0.0.9 

type NewWriteSideHandlerServiceServerT interface {
	mock.TestingT
	Cleanup(func())
}

type ReadSideHandlerServiceClient 

type ReadSideHandlerServiceClient struct {
	mock.Mock
}

ReadSideHandlerServiceClient is an autogenerated mock type for the ReadSideHandlerServiceClient type

func NewReadSideHandlerServiceClient 

func NewReadSideHandlerServiceClient(t NewReadSideHandlerServiceClientT) *ReadSideHandlerServiceClient

NewReadSideHandlerServiceClient creates a new instance of ReadSideHandlerServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ReadSideHandlerServiceClient) HandleReadSide 

func (_m *ReadSideHandlerServiceClient) HandleReadSide(ctx context.Context, in *chief_of_statev1.HandleReadSideRequest, opts ...grpc.CallOption) (*chief_of_statev1.HandleReadSideResponse, error)

HandleReadSide provides a mock function with given fields: ctx, in, opts

type ReadSideHandlerServiceServer 

type ReadSideHandlerServiceServer struct {
	mock.Mock
}

ReadSideHandlerServiceServer is an autogenerated mock type for the ReadSideHandlerServiceServer type

func NewReadSideHandlerServiceServer 

func NewReadSideHandlerServiceServer(t NewReadSideHandlerServiceServerT) *ReadSideHandlerServiceServer

NewReadSideHandlerServiceServer creates a new instance of ReadSideHandlerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ReadSideHandlerServiceServer) HandleReadSide 

func (_m *ReadSideHandlerServiceServer) HandleReadSide(_a0 context.Context, _a1 *chief_of_statev1.HandleReadSideRequest) (*chief_of_statev1.HandleReadSideResponse, error)

HandleReadSide provides a mock function with given fields: _a0, _a1

type ReadSideManagerServiceClient 

type ReadSideManagerServiceClient struct {
	mock.Mock
}

ReadSideManagerServiceClient is an autogenerated mock type for the ReadSideManagerServiceClient type

func NewReadSideManagerServiceClient 

func NewReadSideManagerServiceClient(t NewReadSideManagerServiceClientT) *ReadSideManagerServiceClient

NewReadSideManagerServiceClient creates a new instance of ReadSideManagerServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ReadSideManagerServiceClient) GetLatestOffset 

func (_m *ReadSideManagerServiceClient) GetLatestOffset(ctx context.Context, in *chief_of_statev1.GetLatestOffsetRequest, opts ...grpc.CallOption) (*chief_of_statev1.GetLatestOffsetResponse, error)

GetLatestOffset provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) GetLatestOffsetByShard 

func (_m *ReadSideManagerServiceClient) GetLatestOffsetByShard(ctx context.Context, in *chief_of_statev1.GetLatestOffsetByShardRequest, opts ...grpc.CallOption) (*chief_of_statev1.GetLatestOffsetByShardResponse, error)

GetLatestOffsetByShard provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) PauseReadSide 

func (_m *ReadSideManagerServiceClient) PauseReadSide(ctx context.Context, in *chief_of_statev1.PauseReadSideRequest, opts ...grpc.CallOption) (*chief_of_statev1.PauseReadSideResponse, error)

PauseReadSide provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) PauseReadSideByShard 

func (_m *ReadSideManagerServiceClient) PauseReadSideByShard(ctx context.Context, in *chief_of_statev1.PauseReadSideByShardRequest, opts ...grpc.CallOption) (*chief_of_statev1.PauseReadSideByShardResponse, error)

PauseReadSideByShard provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) RestartReadSide 

func (_m *ReadSideManagerServiceClient) RestartReadSide(ctx context.Context, in *chief_of_statev1.RestartReadSideRequest, opts ...grpc.CallOption) (*chief_of_statev1.RestartReadSideResponse, error)

RestartReadSide provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) RestartReadSideByShard 

func (_m *ReadSideManagerServiceClient) RestartReadSideByShard(ctx context.Context, in *chief_of_statev1.RestartReadSideByShardRequest, opts ...grpc.CallOption) (*chief_of_statev1.RestartReadSideByShardResponse, error)

RestartReadSideByShard provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) ResumeReadSide 

func (_m *ReadSideManagerServiceClient) ResumeReadSide(ctx context.Context, in *chief_of_statev1.ResumeReadSideRequest, opts ...grpc.CallOption) (*chief_of_statev1.ResumeReadSideResponse, error)

ResumeReadSide provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) ResumeReadSideByShard 

func (_m *ReadSideManagerServiceClient) ResumeReadSideByShard(ctx context.Context, in *chief_of_statev1.ResumeReadSideByShardRequest, opts ...grpc.CallOption) (*chief_of_statev1.ResumeReadSideByShardResponse, error)

ResumeReadSideByShard provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) SkipOffset 

func (_m *ReadSideManagerServiceClient) SkipOffset(ctx context.Context, in *chief_of_statev1.SkipOffsetRequest, opts ...grpc.CallOption) (*chief_of_statev1.SkipOffsetResponse, error)

SkipOffset provides a mock function with given fields: ctx, in, opts

func (*ReadSideManagerServiceClient) SkipOffsetByShard 

func (_m *ReadSideManagerServiceClient) SkipOffsetByShard(ctx context.Context, in *chief_of_statev1.SkipOffsetByShardRequest, opts ...grpc.CallOption) (*chief_of_statev1.SkipOffsetByShardResponse, error)

SkipOffsetByShard provides a mock function with given fields: ctx, in, opts

type ReadSideManagerServiceServer 

type ReadSideManagerServiceServer struct {
	mock.Mock
}

ReadSideManagerServiceServer is an autogenerated mock type for the ReadSideManagerServiceServer type

func NewReadSideManagerServiceServer 

func NewReadSideManagerServiceServer(t NewReadSideManagerServiceServerT) *ReadSideManagerServiceServer

NewReadSideManagerServiceServer creates a new instance of ReadSideManagerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ReadSideManagerServiceServer) GetLatestOffset 

func (_m *ReadSideManagerServiceServer) GetLatestOffset(_a0 context.Context, _a1 *chief_of_statev1.GetLatestOffsetRequest) (*chief_of_statev1.GetLatestOffsetResponse, error)

GetLatestOffset provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) GetLatestOffsetByShard 

func (_m *ReadSideManagerServiceServer) GetLatestOffsetByShard(_a0 context.Context, _a1 *chief_of_statev1.GetLatestOffsetByShardRequest) (*chief_of_statev1.GetLatestOffsetByShardResponse, error)

GetLatestOffsetByShard provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) PauseReadSide 

func (_m *ReadSideManagerServiceServer) PauseReadSide(_a0 context.Context, _a1 *chief_of_statev1.PauseReadSideRequest) (*chief_of_statev1.PauseReadSideResponse, error)

PauseReadSide provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) PauseReadSideByShard 

func (_m *ReadSideManagerServiceServer) PauseReadSideByShard(_a0 context.Context, _a1 *chief_of_statev1.PauseReadSideByShardRequest) (*chief_of_statev1.PauseReadSideByShardResponse, error)

PauseReadSideByShard provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) RestartReadSide 

func (_m *ReadSideManagerServiceServer) RestartReadSide(_a0 context.Context, _a1 *chief_of_statev1.RestartReadSideRequest) (*chief_of_statev1.RestartReadSideResponse, error)

RestartReadSide provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) RestartReadSideByShard 

func (_m *ReadSideManagerServiceServer) RestartReadSideByShard(_a0 context.Context, _a1 *chief_of_statev1.RestartReadSideByShardRequest) (*chief_of_statev1.RestartReadSideByShardResponse, error)

RestartReadSideByShard provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) ResumeReadSide 

func (_m *ReadSideManagerServiceServer) ResumeReadSide(_a0 context.Context, _a1 *chief_of_statev1.ResumeReadSideRequest) (*chief_of_statev1.ResumeReadSideResponse, error)

ResumeReadSide provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) ResumeReadSideByShard 

func (_m *ReadSideManagerServiceServer) ResumeReadSideByShard(_a0 context.Context, _a1 *chief_of_statev1.ResumeReadSideByShardRequest) (*chief_of_statev1.ResumeReadSideByShardResponse, error)

ResumeReadSideByShard provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) SkipOffset 

func (_m *ReadSideManagerServiceServer) SkipOffset(_a0 context.Context, _a1 *chief_of_statev1.SkipOffsetRequest) (*chief_of_statev1.SkipOffsetResponse, error)

SkipOffset provides a mock function with given fields: _a0, _a1

func (*ReadSideManagerServiceServer) SkipOffsetByShard 

func (_m *ReadSideManagerServiceServer) SkipOffsetByShard(_a0 context.Context, _a1 *chief_of_statev1.SkipOffsetByShardRequest) (*chief_of_statev1.SkipOffsetByShardResponse, error)

SkipOffsetByShard provides a mock function with given fields: _a0, _a1

type UnsafeChiefOfStateServiceServer 

type UnsafeChiefOfStateServiceServer struct {
	mock.Mock
}

UnsafeChiefOfStateServiceServer is an autogenerated mock type for the UnsafeChiefOfStateServiceServer type

func NewUnsafeChiefOfStateServiceServer 

func NewUnsafeChiefOfStateServiceServer(t NewUnsafeChiefOfStateServiceServerT) *UnsafeChiefOfStateServiceServer

NewUnsafeChiefOfStateServiceServer creates a new instance of UnsafeChiefOfStateServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

type UnsafeReadSideHandlerServiceServer 

type UnsafeReadSideHandlerServiceServer struct {
	mock.Mock
}

UnsafeReadSideHandlerServiceServer is an autogenerated mock type for the UnsafeReadSideHandlerServiceServer type

func NewUnsafeReadSideHandlerServiceServer 

func NewUnsafeReadSideHandlerServiceServer(t NewUnsafeReadSideHandlerServiceServerT) *UnsafeReadSideHandlerServiceServer

NewUnsafeReadSideHandlerServiceServer creates a new instance of UnsafeReadSideHandlerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

type UnsafeReadSideManagerServiceServer 

type UnsafeReadSideManagerServiceServer struct {
	mock.Mock
}

UnsafeReadSideManagerServiceServer is an autogenerated mock type for the UnsafeReadSideManagerServiceServer type

func NewUnsafeReadSideManagerServiceServer 

func NewUnsafeReadSideManagerServiceServer(t NewUnsafeReadSideManagerServiceServerT) *UnsafeReadSideManagerServiceServer

NewUnsafeReadSideManagerServiceServer creates a new instance of UnsafeReadSideManagerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

type UnsafeWriteSideHandlerServiceServer 

type UnsafeWriteSideHandlerServiceServer struct {
	mock.Mock
}

UnsafeWriteSideHandlerServiceServer is an autogenerated mock type for the UnsafeWriteSideHandlerServiceServer type

func NewUnsafeWriteSideHandlerServiceServer 

func NewUnsafeWriteSideHandlerServiceServer(t NewUnsafeWriteSideHandlerServiceServerT) *UnsafeWriteSideHandlerServiceServer

NewUnsafeWriteSideHandlerServiceServer creates a new instance of UnsafeWriteSideHandlerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

type WriteSideHandlerServiceClient 

type WriteSideHandlerServiceClient struct {
	mock.Mock
}

WriteSideHandlerServiceClient is an autogenerated mock type for the WriteSideHandlerServiceClient type

func NewWriteSideHandlerServiceClient 

func NewWriteSideHandlerServiceClient(t NewWriteSideHandlerServiceClientT) *WriteSideHandlerServiceClient

NewWriteSideHandlerServiceClient creates a new instance of WriteSideHandlerServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*WriteSideHandlerServiceClient) HandleCommand 

func (_m *WriteSideHandlerServiceClient) HandleCommand(ctx context.Context, in *chief_of_statev1.HandleCommandRequest, opts ...grpc.CallOption) (*chief_of_statev1.HandleCommandResponse, error)

HandleCommand provides a mock function with given fields: ctx, in, opts

func (*WriteSideHandlerServiceClient) HandleEvent 

func (_m *WriteSideHandlerServiceClient) HandleEvent(ctx context.Context, in *chief_of_statev1.HandleEventRequest, opts ...grpc.CallOption) (*chief_of_statev1.HandleEventResponse, error)

HandleEvent provides a mock function with given fields: ctx, in, opts

type WriteSideHandlerServiceServer 

type WriteSideHandlerServiceServer struct {
	mock.Mock
}

WriteSideHandlerServiceServer is an autogenerated mock type for the WriteSideHandlerServiceServer type

func NewWriteSideHandlerServiceServer 

func NewWriteSideHandlerServiceServer(t NewWriteSideHandlerServiceServerT) *WriteSideHandlerServiceServer

NewWriteSideHandlerServiceServer creates a new instance of WriteSideHandlerServiceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*WriteSideHandlerServiceServer) HandleCommand 

func (_m *WriteSideHandlerServiceServer) HandleCommand(_a0 context.Context, _a1 *chief_of_statev1.HandleCommandRequest) (*chief_of_statev1.HandleCommandResponse, error)

HandleCommand provides a mock function with given fields: _a0, _a1

func (*WriteSideHandlerServiceServer) HandleEvent 

func (_m *WriteSideHandlerServiceServer) HandleEvent(_a0 context.Context, _a1 *chief_of_statev1.HandleEventRequest) (*chief_of_statev1.HandleEventResponse, error)

HandleEvent provides a mock function with given fields: _a0, _a1

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.