app

package

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

Details

This section is empty.

This section is empty.

func WithGRPCOptions(opts ...procgrpc.Option) func(*options)

func WithHealthCheckFn(fn func(context.Context, *emptypb.Empty) (*rtv1.HealthCheckResponse, error)) func(*options)

func WithListInputBindings(fn func(context.Context, *emptypb.Empty) (*rtv1.ListInputBindingsResponse, error)) func(*options)

func WithListTopicSubscriptions(fn func(ctx context.Context, in *emptypb.Empty) (*rtv1.ListTopicSubscriptionsResponse, error)) func(*options)

func WithOnBindingEventFn(fn func(context.Context, *rtv1.BindingEventRequest) (*rtv1.BindingEventResponse, error)) func(*options)

func WithOnBulkTopicEventFn(fn func(context.Context, *rtv1.TopicEventBulkRequest) (*rtv1.TopicEventBulkResponse, error)) func(*options)

func WithOnInvokeFn(fn func(ctx context.Context, in *commonv1.InvokeRequest) (*commonv1.InvokeResponse, error)) func(*options)

func WithOnJobEventFn(fn func(ctx context.Context, in *rtv1.JobEventRequest) (*rtv1.JobEventResponse, error)) func(*options)

func WithOnTopicEventFn(fn func(context.Context, *rtv1.TopicEventRequest) (*rtv1.TopicEventResponse, error)) 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 struct {
	// contains filtered or unexported fields
}

App is a wrapper around a grpc.Server that implements a Dapr App.

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

func (a *App) Cleanup(t *testing.T)

func (a *App) Port(t *testing.T) int

func (a *App) Run(t *testing.T, ctx context.Context)

type Option func(*options)

Option is a function that configures the process.

Path	Synopsis
proto