batch

type MockSyncer ¶

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

MockSyncer is a mock of Syncer interface.

func NewMockSyncer(ctrl *gomock.Controller) *MockSyncer

func (m *MockSyncer) EXPECT() *MockSyncerMockRecorder

func (m *MockSyncer) OnSync(ctx context.Context) error

type MockSyncerMockRecorder ¶

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

MockSyncerMockRecorder is the mock recorder for MockSyncer.

func (mr *MockSyncerMockRecorder) OnSync(ctx any) *gomock.Call

type Syncer ¶

type Syncer interface {
	// OnSync Syncs RadixBatch
	OnSync(ctx context.Context) error
}

Syncer of RadixBatch

func NewSyncer(kubeclient kubernetes.Interface, kubeUtil *kube.Kube, radixClient radixclient.Interface, registration *radixv1.RadixRegistration, radixBatch *radixv1.RadixBatch, config config.Config, options ...SyncerOption) Syncer

type SyncerOption ¶ added in v1.67.0

type SyncerOption func(syncer *syncer)

func WithClock(clock clock.Clock) SyncerOption