Documentation
¶
Index ¶
- func WithComponentUpdateFn(...) func(*options)
- func WithGRPCOptions(opts ...procgrpc.Option) func(*options)
- func WithGetConfigurationFn(...) func(*options)
- func WithGetResiliencyFn(...) func(*options)
- func WithHTTPEndpointUpdateFn(fn func(*operatorv1.HTTPEndpointUpdateRequest, ...) error) func(*options)
- func WithListComponentsFn(...) func(*options)
- func WithListHTTPEndpointsFn(...) func(*options)
- func WithListResiliencyFn(...) func(*options)
- func WithListSubscriptionsFn(...) func(*options)
- func WithListSubscriptionsV2Fn(...) func(*options)
- func WithSentry(sentry *sentry.Sentry) func(*options)
- type Operator
- func (o *Operator) AddComponents(cs ...compapi.Component)
- func (o *Operator) Cleanup(t *testing.T)
- func (o *Operator) ComponentUpdateEvent(t *testing.T, ctx context.Context, event *api.ComponentUpdateEvent)
- func (o *Operator) Components() []compapi.Component
- func (o *Operator) SetComponents(cs ...compapi.Component)
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithComponentUpdateFn ¶
func WithComponentUpdateFn(fn func(*operatorv1.ComponentUpdateRequest, operatorv1.Operator_ComponentUpdateServer) error) func(*options)
func WithGRPCOptions ¶
func WithGetConfigurationFn ¶
func WithGetConfigurationFn(fn func(context.Context, *operatorv1.GetConfigurationRequest) (*operatorv1.GetConfigurationResponse, error)) func(*options)
func WithGetResiliencyFn ¶
func WithGetResiliencyFn(fn func(context.Context, *operatorv1.GetResiliencyRequest) (*operatorv1.GetResiliencyResponse, error)) func(*options)
func WithHTTPEndpointUpdateFn ¶
func WithHTTPEndpointUpdateFn(fn func(*operatorv1.HTTPEndpointUpdateRequest, operatorv1.Operator_HTTPEndpointUpdateServer) error) func(*options)
func WithListComponentsFn ¶
func WithListComponentsFn(fn func(context.Context, *operatorv1.ListComponentsRequest) (*operatorv1.ListComponentResponse, error)) func(*options)
func WithListHTTPEndpointsFn ¶
func WithListHTTPEndpointsFn(fn func(context.Context, *operatorv1.ListHTTPEndpointsRequest) (*operatorv1.ListHTTPEndpointsResponse, error)) func(*options)
func WithListResiliencyFn ¶
func WithListResiliencyFn(fn func(context.Context, *operatorv1.ListResiliencyRequest) (*operatorv1.ListResiliencyResponse, error)) func(*options)
func WithListSubscriptionsFn ¶
func WithListSubscriptionsFn(fn func(context.Context, *emptypb.Empty) (*operatorv1.ListSubscriptionsResponse, error)) func(*options)
func WithListSubscriptionsV2Fn ¶
func WithListSubscriptionsV2Fn(fn func(context.Context, *operatorv1.ListSubscriptionsRequest) (*operatorv1.ListSubscriptionsResponse, error)) func(*options)
func WithSentry ¶
Types ¶
type Operator ¶
Operator is a wrapper around a grpc.Server that implements the Operator API.
func (*Operator) AddComponents ¶
Add Component adds a component to the publish list of installed components.
func (*Operator) ComponentUpdateEvent ¶
func (o *Operator) ComponentUpdateEvent(t *testing.T, ctx context.Context, event *api.ComponentUpdateEvent)
ComponentUpdateEvent sends a component update event to the operator which will be piped to clients listening on ComponentUpdate.
func (*Operator) Components ¶
Components returns the list of installed components.
func (*Operator) SetComponents ¶
SetComponents sets the list of installed components.
Source Files
Click to show internal directories.
Click to hide internal directories.