server

Documentation

Index

• func NewUserVerbServer(moduleName string, handlers ...Handler) plugin.Constructor[ftlv1connect.VerbServiceHandler, UserVerbConfig]
• type Handler
  • func HandleCall[Req, Resp any](verb func(ctx context.Context, req Req) (Resp, error)) Handler
  • func HandleEmpty(empty func(ctx context.Context) error) Handler
  • func HandleSink[Req any](sink func(ctx context.Context, req Req) error) Handler
  • func HandleSource[Resp any](source func(ctx context.Context) (Resp, error)) Handler
• type UserVerbConfig

Functions

func NewUserVerbServer

func NewUserVerbServer(moduleName string, handlers ...Handler) plugin.Constructor[ftlv1connect.VerbServiceHandler, UserVerbConfig]

NewUserVerbServer starts a new code-generated drive for user Verbs.

This function is intended to be used by the code generator.

Types

type Handler

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

Handler for a Verb.

func HandleCall

func HandleCall[Req, Resp any](verb func(ctx context.Context, req Req) (Resp, error)) Handler

HandleCall creates a Handler from a Verb.

func HandleEmpty

func HandleEmpty(empty func(ctx context.Context) error) Handler

HandleEmpty creates a Handler from a Verb with no request or response.

func HandleSink

func HandleSink[Req any](sink func(ctx context.Context, req Req) error) Handler

HandleSink creates a Handler from a Sink with no response.

func HandleSource

func HandleSource[Resp any](source func(ctx context.Context) (Resp, error)) Handler

HandleSource creates a Handler from a Source with no request.

type UserVerbConfig

type UserVerbConfig struct {
	FTLEndpoint         *url.URL             `help:"FTL endpoint." env:"FTL_ENDPOINT" required:""`
	ObservabilityConfig observability.Config `embed:"" prefix:"o11y-"`
	Config              []string             `` /* 139-byte string literal not displayed */
}