Documentation
¶
Index ¶
- type MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) Apply(fn func(definition *testv2.MockStreamDefinition)) *MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) Build() *testv2.MockStreamDefinition
- func (b *MockStreamDefinitionBuilder) WithName(n types.NamespacedName) *MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) WithNoBackend() *MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) WithPhase(phase stream.Phase) *MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) WithSchedule(schedule string) *MockStreamDefinitionBuilder
- func (b *MockStreamDefinitionBuilder) WithSuspendedSpec(spec bool) *MockStreamDefinitionBuilder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockStreamDefinitionBuilder ¶
type MockStreamDefinitionBuilder struct {
// contains filtered or unexported fields
}
MockStreamDefinitionBuilder provides a fluent builder for constructing *testv2.MockStreamDefinition objects in tests.
func NewMockStreamDefinitionBuilder ¶
func NewMockStreamDefinitionBuilder(objectName types.NamespacedName) *MockStreamDefinitionBuilder
NewMockStreamDefinitionBuilder creates a new builder pre-populated with the same defaults used by SetupClient.
func (*MockStreamDefinitionBuilder) Apply ¶
func (b *MockStreamDefinitionBuilder) Apply(fn func(definition *testv2.MockStreamDefinition)) *MockStreamDefinitionBuilder
Apply runs an arbitrary mutation function on the underlying definition. This allows composing the builder with the existing functional-option style helpers in this package.
func (*MockStreamDefinitionBuilder) Build ¶
func (b *MockStreamDefinitionBuilder) Build() *testv2.MockStreamDefinition
Build returns the constructed *testv2.MockStreamDefinition. The result is computed on the first call and the same pointer is returned on subsequent calls.
func (*MockStreamDefinitionBuilder) WithName ¶
func (b *MockStreamDefinitionBuilder) WithName(n types.NamespacedName) *MockStreamDefinitionBuilder
WithName sets the name and namespace of the stream definition.
func (*MockStreamDefinitionBuilder) WithNoBackend ¶ added in v1.1.4
func (b *MockStreamDefinitionBuilder) WithNoBackend() *MockStreamDefinitionBuilder
WithNoBackend configures the stream definition with an empty backend, clearing both the batch job and cron job backends.
func (*MockStreamDefinitionBuilder) WithPhase ¶
func (b *MockStreamDefinitionBuilder) WithPhase(phase stream.Phase) *MockStreamDefinitionBuilder
WithPhase sets the status phase of the stream definition.
func (*MockStreamDefinitionBuilder) WithSchedule ¶
func (b *MockStreamDefinitionBuilder) WithSchedule(schedule string) *MockStreamDefinitionBuilder
WithSchedule configures the stream definition with a cron job backend using the provided schedule, clearing the batch job backend.
func (*MockStreamDefinitionBuilder) WithSuspendedSpec ¶
func (b *MockStreamDefinitionBuilder) WithSuspendedSpec(spec bool) *MockStreamDefinitionBuilder
WithSuspendedSpec sets the Suspended flag on the execution settings.
Source Files