Documentation
¶
Overview ¶
Package checkpoint is a generated GoMock package.
Index ¶
- Constants
- type MockService
- func (m *MockService) EXPECT() *MockServiceMockRecorder
- func (m *MockService) GetCheckpoint(ctx context.Context, consumer, key string) ([]byte, domain.Status)
- func (m *MockService) GetDatabaseTime(ctx context.Context) (time.Time, domain.Status)
- func (m *MockService) SetCheckpoint(ctx context.Context, consumer, key string, value []byte) domain.Status
- type MockServiceMockRecorder
- type Service
- type ServiceHandler
- func (h *ServiceHandler) GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, domain.Status)
- func (h *ServiceHandler) GetDatabaseTime(ctx context.Context) (time.Time, domain.Status)
- func (h *ServiceHandler) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) domain.Status
- type TracedService
- func (_d *TracedService) GetCheckpoint(ctx context.Context, consumer string, key string) (ba1 []byte, s1 domain.Status)
- func (_d *TracedService) GetDatabaseTime(ctx context.Context) (t1 time.Time, s1 domain.Status)
- func (_d *TracedService) SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) (s1 domain.Status)
Constants ¶
const CheckpointKind = "Checkpoint"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockService ¶
type MockService struct {
// contains filtered or unexported fields
}
MockService is a mock of Service interface.
func NewMockService ¶
func NewMockService(ctrl *gomock.Controller) *MockService
NewMockService creates a new mock instance.
func (*MockService) EXPECT ¶
func (m *MockService) EXPECT() *MockServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockService) GetCheckpoint ¶
func (m *MockService) GetCheckpoint(ctx context.Context, consumer, key string) ([]byte, domain.Status)
GetCheckpoint mocks base method.
func (*MockService) GetDatabaseTime ¶
GetDatabaseTime mocks base method.
func (*MockService) SetCheckpoint ¶
func (m *MockService) SetCheckpoint(ctx context.Context, consumer, key string, value []byte) domain.Status
SetCheckpoint mocks base method.
type MockServiceMockRecorder ¶
type MockServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockServiceMockRecorder is the mock recorder for MockService.
func (*MockServiceMockRecorder) GetCheckpoint ¶
func (mr *MockServiceMockRecorder) GetCheckpoint(ctx, consumer, key any) *gomock.Call
GetCheckpoint indicates an expected call of GetCheckpoint.
func (*MockServiceMockRecorder) GetDatabaseTime ¶
func (mr *MockServiceMockRecorder) GetDatabaseTime(ctx any) *gomock.Call
GetDatabaseTime indicates an expected call of GetDatabaseTime.
func (*MockServiceMockRecorder) SetCheckpoint ¶
func (mr *MockServiceMockRecorder) SetCheckpoint(ctx, consumer, key, value any) *gomock.Call
SetCheckpoint indicates an expected call of SetCheckpoint.
type Service ¶
type Service interface {
GetCheckpoint(ctx context.Context, consumer string, key string) ([]byte, domain.Status)
SetCheckpoint(ctx context.Context, consumer string, key string, value []byte) domain.Status
GetDatabaseTime(ctx context.Context) (time.Time, domain.Status)
}
func WrapWithTracing ¶
WrapWithTracing returns a Service that wraps inner with tracing spans, or nil if inner is nil.
type ServiceHandler ¶
type ServiceHandler struct {
// contains filtered or unexported fields
}
func NewServiceHandler ¶
func NewServiceHandler(store checkpointstore.Store) *ServiceHandler
NewServiceHandler creates a new checkpoint ServiceHandler instance.
func (*ServiceHandler) GetCheckpoint ¶
func (*ServiceHandler) GetDatabaseTime ¶
func (*ServiceHandler) SetCheckpoint ¶
type TracedService ¶
type TracedService struct {
// contains filtered or unexported fields
}
TracedService wraps a Service implementation with OpenTelemetry tracing.
Source Files