operator

package

v1.16.21 Latest Latest Go to latest Published: Oct 21, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Open Source Insights

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)
func WithSubscriptionUpdateFn(fn func(*operatorv1.SubscriptionUpdateRequest, ...) error) func(*options)
type Operator
- func New(t *testing.T, fopts ...Option) *Operator
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 WithGRPCOptions(opts ...procgrpc.Option) func(*options)

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 ¶

func WithSentry(sentry *sentry.Sentry) func(*options)

func WithSubscriptionUpdateFn ¶ added in v1.14.0

func WithSubscriptionUpdateFn(fn func(*operatorv1.SubscriptionUpdateRequest, operatorv1.Operator_SubscriptionUpdateServer) error) func(*options)

Types ¶

type Operator ¶

type Operator struct {
	*procgrpc.GRPC
	// contains filtered or unexported fields
}

Operator is a wrapper around a grpc.Server that implements the Operator API.

func New ¶

func New(t *testing.T, fopts ...Option) *Operator

func (*Operator) AddComponents ¶

func (o *Operator) AddComponents(cs ...compapi.Component)

Add Component adds a component to the publish list of installed components.

func (*Operator) AddSubscriptions ¶ added in v1.14.0

func (o *Operator) AddSubscriptions(subs ...subapi.Subscription)

func (*Operator) Cleanup ¶

func (o *Operator) Cleanup(t *testing.T)

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 ¶

func (o *Operator) Components() []compapi.Component

Components returns the list of installed components.

func (*Operator) SetComponents ¶

func (o *Operator) SetComponents(cs ...compapi.Component)

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 (o *Operator) SubscriptionUpdateEvent(t *testing.T, ctx context.Context, event *api.SubscriptionUpdateEvent)

func (*Operator) Subscriptions ¶ added in v1.14.0

func (o *Operator) Subscriptions() []subapi.Subscription

type Option ¶

type Option func(*options)

Option is a function that configures the process.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL