Documentation
¶
Index ¶
- func WithComponentUpdateFn(...) func(*options)
- func WithConfigurationUpdateFn(fn func(*operatorv1.ConfigurationUpdateRequest, ...) error) 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 WithListMCPServersFn(...) func(*options)
- func WithListResiliencyFn(...) func(*options)
- func WithListSubscriptionsFn(...) func(*options)
- func WithListSubscriptionsV2Fn(...) func(*options)
- func WithListWorkflowAccessPoliciesFn(...) func(*options)
- func WithMCPServerUpdateFn(...) func(*options)
- func WithResiliencyUpdateFn(fn func(*operatorv1.ResiliencyUpdateRequest, ...) error) func(*options)
- func WithSentry(sentry *sentry.Sentry) func(*options)
- func WithSubscriptionUpdateFn(fn func(*operatorv1.SubscriptionUpdateRequest, ...) error) func(*options)
- func WithWorkflowAccessPolicyUpdateFn(fn func(*operatorv1.WorkflowAccessPolicyUpdateRequest, ...) error) func(*options)
- type MCPServerUpdateEvent
- type Operator
- func (o *Operator) AddComponents(cs ...compapi.Component)
- func (o *Operator) AddMCPServers(servers ...mcpserverapi.MCPServer)
- func (o *Operator) AddSubscriptions(subs ...subapi.Subscription)
- 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) MCPServerUpdateEvent(t *testing.T, ctx context.Context, event *MCPServerUpdateEvent)
- func (o *Operator) SetComponents(cs ...compapi.Component)
- func (o *Operator) SetSubscriptions(subs ...subapi.Subscription)
- func (o *Operator) SubscriptionUpdateEvent(t *testing.T, ctx context.Context, event *SubscriptionUpdateEvent)
- func (o *Operator) Subscriptions() []subapi.Subscription
- type Option
- type SubscriptionUpdateEvent
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 WithConfigurationUpdateFn ¶
func WithConfigurationUpdateFn(fn func(*operatorv1.ConfigurationUpdateRequest, operatorv1.Operator_ConfigurationUpdateServer) 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 WithListMCPServersFn ¶
func WithListMCPServersFn(fn func(context.Context, *operatorv1.ListMCPServersRequest) (*operatorv1.ListMCPServersResponse, 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 WithListWorkflowAccessPoliciesFn ¶
func WithListWorkflowAccessPoliciesFn(fn func(context.Context, *operatorv1.ListWorkflowAccessPolicyRequest) (*operatorv1.ListWorkflowAccessPolicyResponse, error)) func(*options)
func WithMCPServerUpdateFn ¶
func WithMCPServerUpdateFn(fn func(*operatorv1.MCPServerUpdateRequest, operatorv1.Operator_MCPServerUpdateServer) error) func(*options)
func WithResiliencyUpdateFn ¶
func WithResiliencyUpdateFn(fn func(*operatorv1.ResiliencyUpdateRequest, operatorv1.Operator_ResiliencyUpdateServer) error) func(*options)
func WithSentry ¶
func WithSubscriptionUpdateFn ¶ added in v1.14.0
func WithSubscriptionUpdateFn(fn func(*operatorv1.SubscriptionUpdateRequest, operatorv1.Operator_SubscriptionUpdateServer) error) func(*options)
func WithWorkflowAccessPolicyUpdateFn ¶
func WithWorkflowAccessPolicyUpdateFn(fn func(*operatorv1.WorkflowAccessPolicyUpdateRequest, operatorv1.Operator_WorkflowAccessPolicyUpdateServer) error) func(*options)
Types ¶
type MCPServerUpdateEvent ¶
type MCPServerUpdateEvent struct {
MCPServer *mcpserverapi.MCPServer
EventType operatorv1.ResourceEventType
}
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) AddMCPServers ¶
func (o *Operator) AddMCPServers(servers ...mcpserverapi.MCPServer)
func (*Operator) AddSubscriptions ¶ added in v1.14.0
func (o *Operator) AddSubscriptions(subs ...subapi.Subscription)
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) MCPServerUpdateEvent ¶
func (*Operator) SetComponents ¶
SetComponents sets the list of installed components.
func (*Operator) SetSubscriptions ¶ added in v1.14.0
func (o *Operator) SetSubscriptions(subs ...subapi.Subscription)
func (*Operator) SubscriptionUpdateEvent ¶ added in v1.14.0
func (*Operator) Subscriptions ¶ added in v1.14.0
func (o *Operator) Subscriptions() []subapi.Subscription
type SubscriptionUpdateEvent ¶
type SubscriptionUpdateEvent struct {
Subscription *subapi.Subscription
EventType operatorv1.ResourceEventType
}
Source Files
Click to show internal directories.
Click to hide internal directories.