nexustest

Documentation

Index

• func AllocListenAddress(t *testing.T) string
• func NewNexusServer(t *testing.T, listenAddr string, handler nexus.Handler)
• type FakeEndpointRegistry
  • func (f FakeEndpointRegistry) GetByID(ctx context.Context, endpointID string) (*persistencespb.NexusEndpointEntry, error)
  • func (f FakeEndpointRegistry) GetByName(ctx context.Context, namespaceID namespace.ID, endpointName string) (*persistencespb.NexusEndpointEntry, error)
  • func (f FakeEndpointRegistry) StartLifecycle()
  • func (f FakeEndpointRegistry) StopLifecycle()
• 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 FakeEndpointRegistry

type FakeEndpointRegistry struct {
	OnGetByID   func(ctx context.Context, endpointID string) (*persistencespb.NexusEndpointEntry, error)
	OnGetByName func(ctx context.Context, namespaceID namespace.ID, endpointName string) (*persistencespb.NexusEndpointEntry, error)
}

func (FakeEndpointRegistry) GetByID

func (f FakeEndpointRegistry) GetByID(ctx context.Context, endpointID string) (*persistencespb.NexusEndpointEntry, error)

func (FakeEndpointRegistry) GetByName

func (f FakeEndpointRegistry) GetByName(ctx context.Context, namespaceID namespace.ID, endpointName string) (*persistencespb.NexusEndpointEntry, error)

func (FakeEndpointRegistry) StartLifecycle

func (f FakeEndpointRegistry) StartLifecycle()

func (FakeEndpointRegistry) StopLifecycle

func (f FakeEndpointRegistry) StopLifecycle()

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)