Documentation
¶
Index ¶
- func WithActorRegistration(fn func() *rtv1.SubscribeActorEventsRequestInitialAlpha1) func(*options)
- func WithDaprdGRPCAddrFn(fn func() string) func(*options)
- func WithGRPCOptions(opts ...procgrpc.Option) func(*options)
- func WithHealthCheckFn(fn func(context.Context, *emptypb.Empty) (*rtv1.HealthCheckResponse, error)) func(*options)
- func WithListInputBindings(...) func(*options)
- func WithListTopicSubscriptions(...) func(*options)
- func WithOnActorDeactivateFn(...) func(*options)
- func WithOnActorInvokeFn(...) func(*options)
- func WithOnActorReminderFn(...) func(*options)
- func WithOnActorTimerFn(...) func(*options)
- func WithOnBindingEventFn(...) func(*options)
- func WithOnBulkTopicEventFn(...) func(*options)
- func WithOnInvokeFn(...) func(*options)
- func WithOnJobEventFn(...) func(*options)
- func WithOnTopicEventFn(...) func(*options)
- func WithPingFn(fn func(context.Context, *testpb.PingRequest) (*testpb.PingResponse, error)) func(*options)
- func WithRegister(fn func(s *grpc.Server)) func(*options)
- type App
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithActorRegistration ¶ added in v1.18.0
func WithActorRegistration(fn func() *rtv1.SubscribeActorEventsRequestInitialAlpha1) func(*options)
WithActorRegistration supplies the initial SubscribeActorEventsRequest message the harness sends when opening the actor callback stream. Must be combined with WithDaprdGRPCAddrFn.
func WithDaprdGRPCAddrFn ¶ added in v1.18.0
func WithDaprdGRPCAddrFn(fn func() string) func(*options)
WithDaprdGRPCAddrFn instructs the harness to open a SubscribeActorEventsAlpha1 stream against the daprd instance whose gRPC address is returned by fn. The closure is evaluated at Run time so tests can reference a daprd.Daprd that is created after the harness.
func WithGRPCOptions ¶
func WithHealthCheckFn ¶
func WithListInputBindings ¶
func WithOnActorDeactivateFn ¶ added in v1.18.0
func WithOnActorDeactivateFn(fn func(context.Context, *rtv1.SubscribeActorEventsResponseDeactivateRequestAlpha1) (*rtv1.SubscribeActorEventsRequestDeactivateResponseAlpha1, error)) func(*options)
WithOnActorDeactivateFn installs a handler for SubscribeActorEventsResponseDeactivateRequestAlpha1.
func WithOnActorInvokeFn ¶ added in v1.18.0
func WithOnActorInvokeFn(fn func(context.Context, *rtv1.SubscribeActorEventsResponseInvokeRequestAlpha1) (*rtv1.SubscribeActorEventsRequestInvokeResponseAlpha1, error)) func(*options)
WithOnActorInvokeFn installs a handler the harness invokes when daprd pushes an SubscribeActorEventsResponseInvokeRequestAlpha1 on the stream.
func WithOnActorReminderFn ¶ added in v1.18.0
func WithOnActorReminderFn(fn func(context.Context, *rtv1.SubscribeActorEventsResponseReminderRequestAlpha1) (*rtv1.SubscribeActorEventsRequestReminderResponseAlpha1, error)) func(*options)
WithOnActorReminderFn installs a handler for SubscribeActorEventsResponseReminderRequestAlpha1.
func WithOnActorTimerFn ¶ added in v1.18.0
func WithOnActorTimerFn(fn func(context.Context, *rtv1.SubscribeActorEventsResponseTimerRequestAlpha1) (*rtv1.SubscribeActorEventsRequestReminderResponseAlpha1, error)) func(*options)
WithOnActorTimerFn installs a handler for SubscribeActorEventsResponseTimerRequestAlpha1.
func WithOnBindingEventFn ¶
func WithOnBindingEventFn(fn func(context.Context, *rtv1.BindingEventRequest) (*rtv1.BindingEventResponse, error)) func(*options)
func WithOnBulkTopicEventFn ¶ added in v1.13.2
func WithOnBulkTopicEventFn(fn func(context.Context, *rtv1.TopicEventBulkRequest) (*rtv1.TopicEventBulkResponse, error)) func(*options)
func WithOnInvokeFn ¶
func WithOnInvokeFn(fn func(ctx context.Context, in *commonv1.InvokeRequest) (*commonv1.InvokeResponse, error)) func(*options)
func WithOnJobEventFn ¶ added in v1.14.0
func WithOnJobEventFn(fn func(ctx context.Context, in *rtv1.JobEventRequest) (*rtv1.JobEventResponse, error)) func(*options)
func WithOnTopicEventFn ¶
func WithOnTopicEventFn(fn func(context.Context, *rtv1.TopicEventRequest) (*rtv1.TopicEventResponse, error)) func(*options)
func WithPingFn ¶ added in v1.14.0
func WithPingFn(fn func(context.Context, *testpb.PingRequest) (*testpb.PingResponse, error)) func(*options)
Source Files
Directories