server

Documentation

Index

• func Call[Req, Resp any](ref reflection.Ref) func(ctx context.Context, req Req) (resp Resp, err error)
• func EmptyClient[Verb any]() reflection.VerbResource
• func NewUserVerbServer(projectName string, moduleName string, handlers ...Handler) plugin.Constructor[ftlv1connect.VerbServiceHandler, UserVerbConfig]
• func SinkClient[Verb, Req any]() reflection.VerbResource
• func SourceClient[Verb, Resp any]() reflection.VerbResource
• func VerbClient[Verb, Req, Resp any]() reflection.VerbResource
• type Handler
  • func HandleCall[Req, Resp any](verb any) Handler
  • func HandleEmpty(verb any) Handler
  • func HandleSink[Req any](verb any) Handler
  • func HandleSource[Resp any](verb any) Handler
• type UserVerbConfig

Functions

func Call

func Call[Req, Resp any](ref reflection.Ref) func(ctx context.Context, req Req) (resp Resp, err error)

func EmptyClient

func EmptyClient[Verb any]() reflection.VerbResource

func NewUserVerbServer

func NewUserVerbServer(projectName string, 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.

func SinkClient

func SinkClient[Verb, Req any]() reflection.VerbResource

func SourceClient

func SourceClient[Verb, Resp any]() reflection.VerbResource

func VerbClient

func VerbClient[Verb, Req, Resp any]() reflection.VerbResource

Types

type Handler

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

Handler for a Verb.

func HandleCall

func HandleCall[Req, Resp any](verb any) Handler

func HandleEmpty

func HandleEmpty(verb any) Handler

func HandleSink

func HandleSink[Req any](verb any) Handler

func HandleSource

func HandleSource[Resp any](verb any) Handler

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 */
}