syncstate

package
v1.3.0-rc4 Latest Latest
Warning

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

 Go to latest Published: Aug 21, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Package syncstate is a generated GoMock package.

Index

Constants

This section is empty.

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) BulkUpdateSyncStateLastCheckedAt 

func (m *MockService) BulkUpdateSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKeys []string, t time.Time) domain.Status

BulkUpdateSyncStateLastCheckedAt mocks base method.

func (*MockService) BulkUpsertSyncState 

func (m *MockService) BulkUpsertSyncState(ctx context.Context, orgId uuid.UUID, states []model.SyncState) domain.Status

BulkUpsertSyncState mocks base method.

func (*MockService) EXPECT 

func (m *MockService) EXPECT() *MockServiceMockRecorder

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

func (*MockService) GetSyncState 

func (m *MockService) GetSyncState(ctx context.Context, orgId uuid.UUID, resourceKey string) (*model.SyncState, domain.Status)

GetSyncState mocks base method.

func (*MockService) SetSyncState 

func (m *MockService) SetSyncState(ctx context.Context, orgId uuid.UUID, state *model.SyncState) domain.Status

SetSyncState mocks base method.

func (*MockService) SetSyncStateLastCheckedAt 

func (m *MockService) SetSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKey string, t time.Time) domain.Status

SetSyncStateLastCheckedAt mocks base method.

type MockServiceMockRecorder 

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

MockServiceMockRecorder is the mock recorder for MockService.

func (*MockServiceMockRecorder) BulkUpdateSyncStateLastCheckedAt 

func (mr *MockServiceMockRecorder) BulkUpdateSyncStateLastCheckedAt(ctx, orgId, resourceKeys, t any) *gomock.Call

BulkUpdateSyncStateLastCheckedAt indicates an expected call of BulkUpdateSyncStateLastCheckedAt.

func (*MockServiceMockRecorder) BulkUpsertSyncState 

func (mr *MockServiceMockRecorder) BulkUpsertSyncState(ctx, orgId, states any) *gomock.Call

BulkUpsertSyncState indicates an expected call of BulkUpsertSyncState.

func (*MockServiceMockRecorder) GetSyncState 

func (mr *MockServiceMockRecorder) GetSyncState(ctx, orgId, resourceKey any) *gomock.Call

GetSyncState indicates an expected call of GetSyncState.

func (*MockServiceMockRecorder) SetSyncState 

func (mr *MockServiceMockRecorder) SetSyncState(ctx, orgId, state any) *gomock.Call

SetSyncState indicates an expected call of SetSyncState.

func (*MockServiceMockRecorder) SetSyncStateLastCheckedAt 

func (mr *MockServiceMockRecorder) SetSyncStateLastCheckedAt(ctx, orgId, resourceKey, t any) *gomock.Call

SetSyncStateLastCheckedAt indicates an expected call of SetSyncStateLastCheckedAt.

type Service 

type Service interface {
	GetSyncState(ctx context.Context, orgId uuid.UUID, resourceKey string) (*model.SyncState, domain.Status)
	SetSyncState(ctx context.Context, orgId uuid.UUID, state *model.SyncState) domain.Status
	SetSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKey string, t time.Time) domain.Status
	BulkUpsertSyncState(ctx context.Context, orgId uuid.UUID, states []model.SyncState) domain.Status
	BulkUpdateSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKeys []string, t time.Time) domain.Status
}

func WrapWithTracing 

func WrapWithTracing(inner Service) Service

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 syncstatestore.Store) *ServiceHandler

NewServiceHandler creates a new syncstate ServiceHandler instance.

func (*ServiceHandler) BulkUpdateSyncStateLastCheckedAt 

func (h *ServiceHandler) BulkUpdateSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKeys []string, t time.Time) domain.Status

func (*ServiceHandler) BulkUpsertSyncState 

func (h *ServiceHandler) BulkUpsertSyncState(ctx context.Context, orgId uuid.UUID, states []model.SyncState) domain.Status

func (*ServiceHandler) GetSyncState 

func (h *ServiceHandler) GetSyncState(ctx context.Context, orgId uuid.UUID, resourceKey string) (*model.SyncState, domain.Status)

func (*ServiceHandler) SetSyncState 

func (h *ServiceHandler) SetSyncState(ctx context.Context, orgId uuid.UUID, state *model.SyncState) domain.Status

func (*ServiceHandler) SetSyncStateLastCheckedAt 

func (h *ServiceHandler) SetSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKey string, t time.Time) domain.Status

type TracedService 

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

TracedService wraps a Service implementation with OpenTelemetry tracing.

func (*TracedService) BulkUpdateSyncStateLastCheckedAt 

func (_d *TracedService) BulkUpdateSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKeys []string, t time.Time) (s1 domain.Status)

func (*TracedService) BulkUpsertSyncState 

func (_d *TracedService) BulkUpsertSyncState(ctx context.Context, orgId uuid.UUID, states []model.SyncState) (s1 domain.Status)

func (*TracedService) GetSyncState 

func (_d *TracedService) GetSyncState(ctx context.Context, orgId uuid.UUID, resourceKey string) (sp1 *model.SyncState, s1 domain.Status)

func (*TracedService) SetSyncState 

func (_d *TracedService) SetSyncState(ctx context.Context, orgId uuid.UUID, state *model.SyncState) (s1 domain.Status)

func (*TracedService) SetSyncStateLastCheckedAt 

func (_d *TracedService) SetSyncStateLastCheckedAt(ctx context.Context, orgId uuid.UUID, resourceKey string, t time.Time) (s1 domain.Status)

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.