nexustest

Documentation

Index

• func AllocListenAddress(t *testing.T) string
• func NewNexusServer(t *testing.T, listenAddr string, handler nexus.Handler)
• type Handler
  • func (h Handler) CancelOperation(ctx context.Context, service, operation, operationID string, ...) error
  • func (h Handler) StartOperation(ctx context.Context, service, operation string, input *nexus.LazyValue, ...) (nexus.HandlerStartOperationResult[any], error)

Functions

func AllocListenAddress

func AllocListenAddress(t *testing.T) string

func NewNexusServer

func NewNexusServer(t *testing.T, listenAddr string, handler nexus.Handler)

Types

type Handler

type Handler struct {
	nexus.UnimplementedHandler
	OnStartOperation  func(ctx context.Context, service, operation string, input *nexus.LazyValue, options nexus.StartOperationOptions) (nexus.HandlerStartOperationResult[any], error)
	OnCancelOperation func(ctx context.Context, service, operation, operationID string, options nexus.CancelOperationOptions) error
}

func (Handler) CancelOperation

func (h Handler) CancelOperation(ctx context.Context, service, operation, operationID string, options nexus.CancelOperationOptions) error

func (Handler) StartOperation

func (h Handler) StartOperation(ctx context.Context, service, operation string, input *nexus.LazyValue, options nexus.StartOperationOptions) (nexus.HandlerStartOperationResult[any], error)