Versions in this module Expand all Collapse all v0 v0.0.2 Jun 17, 2026 v0.0.1 Jun 17, 2026 Changes in this version + type FakeK8sConnector struct + SetupCustomResourceDefinitionStub func(context.Context) error + func (fake *FakeK8sConnector) Invocations() map[string][][]interface{} + func (fake *FakeK8sConnector) SetupCustomResourceDefinition(arg1 context.Context) error + func (fake *FakeK8sConnector) SetupCustomResourceDefinitionArgsForCall(i int) context.Context + func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCallCount() int + func (fake *FakeK8sConnector) SetupCustomResourceDefinitionCalls(stub func(context.Context) error) + func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturns(result1 error) + func (fake *FakeK8sConnector) SetupCustomResourceDefinitionReturnsOnCall(i int, result1 error) + type FakeScheduleStore struct + ListStub func(context.Context) ([]schedule.TaskDefinition, error) + func (fake *FakeScheduleStore) Invocations() map[string][][]interface{} + func (fake *FakeScheduleStore) List(arg1 context.Context) ([]schedule.TaskDefinition, error) + func (fake *FakeScheduleStore) ListArgsForCall(i int) context.Context + func (fake *FakeScheduleStore) ListCallCount() int + func (fake *FakeScheduleStore) ListCalls(stub func(context.Context) ([]schedule.TaskDefinition, error)) + func (fake *FakeScheduleStore) ListReturns(result1 []schedule.TaskDefinition, result2 error) + func (fake *FakeScheduleStore) ListReturnsOnCall(i int, result1 []schedule.TaskDefinition, result2 error) + type PublisherPublisher struct + PublishStub func(context.Context, schedule.TaskDefinition, schedule.Date) error + func (fake *PublisherPublisher) Invocations() map[string][][]interface{} + func (fake *PublisherPublisher) Publish(arg1 context.Context, arg2 schedule.TaskDefinition, arg3 schedule.Date) error + func (fake *PublisherPublisher) PublishArgsForCall(i int) (context.Context, schedule.TaskDefinition, schedule.Date) + func (fake *PublisherPublisher) PublishCallCount() int + func (fake *PublisherPublisher) PublishCalls(stub func(context.Context, schedule.TaskDefinition, schedule.Date) error) + func (fake *PublisherPublisher) PublishReturns(result1 error) + func (fake *PublisherPublisher) PublishReturnsOnCall(i int, result1 error) + type TickMetrics struct + IncPublishedStub func(string, string) + SetLastTickTimestampStub func(float64) + func (fake *TickMetrics) IncPublished(arg1 string, arg2 string) + func (fake *TickMetrics) IncPublishedArgsForCall(i int) (string, string) + func (fake *TickMetrics) IncPublishedCallCount() int + func (fake *TickMetrics) IncPublishedCalls(stub func(string, string)) + func (fake *TickMetrics) Invocations() map[string][][]interface{} + func (fake *TickMetrics) SetLastTickTimestamp(arg1 float64) + func (fake *TickMetrics) SetLastTickTimestampArgsForCall(i int) float64 + func (fake *TickMetrics) SetLastTickTimestampCallCount() int + func (fake *TickMetrics) SetLastTickTimestampCalls(stub func(float64)) + type TickTick struct + RunOnceStub func(context.Context) error + RunStub func(context.Context) error + func (fake *TickTick) Invocations() map[string][][]interface{} + func (fake *TickTick) Run(arg1 context.Context) error + func (fake *TickTick) RunArgsForCall(i int) context.Context + func (fake *TickTick) RunCallCount() int + func (fake *TickTick) RunCalls(stub func(context.Context) error) + func (fake *TickTick) RunOnce(arg1 context.Context) error + func (fake *TickTick) RunOnceArgsForCall(i int) context.Context + func (fake *TickTick) RunOnceCallCount() int + func (fake *TickTick) RunOnceCalls(stub func(context.Context) error) + func (fake *TickTick) RunOnceReturns(result1 error) + func (fake *TickTick) RunOnceReturnsOnCall(i int, result1 error) + func (fake *TickTick) RunReturns(result1 error) + func (fake *TickTick) RunReturnsOnCall(i int, result1 error)
Go to main page