app

Documentation

Index

• 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 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
  • 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

Functions

func WithGRPCOptions

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

func WithHealthCheckFn

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

func WithListInputBindings

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

func WithListTopicSubscriptions

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

func WithOnBindingEventFn

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

func WithOnBulkTopicEventFn

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

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

func WithPingFn(fn func(context.Context, *testpb.PingRequest) (*testpb.PingResponse, error)) func(*options)

func WithRegister

func WithRegister(fn func(s *grpc.Server)) func(*options)

Types

type App

type App struct {
	// contains filtered or unexported fields
}

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

func New

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

func (*App) Cleanup

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

func (*App) Port

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

func (*App) Run

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

type Option

type Option func(*options)

Option is a function that configures the process.