server

Documentation

Index

• func Config[T ftl.ConfigType](module, name string) reflection.VerbResource
• func DatabaseHandle[T ftl.DatabaseConfig](dbtype string) reflection.VerbResource
• func EmptyClient[Verb any]() reflection.VerbResource
• func InitDatabase(ref reflection.Ref, dbtype string, protoDBtype deploymentcontext.DBType, ...) *reflection.ReflectedDatabaseHandle
• func InitMySQL(ref reflection.Ref) *reflection.ReflectedDatabaseHandle
• func InitPostgres(ref reflection.Ref) *reflection.ReflectedDatabaseHandle
• func InvokeVerb[Req, Resp any](ref reflection.Ref) func(ctx context.Context, req Req) (resp Resp, err error)
• func NewUserVerbServer(projectName string, moduleName string, handlers ...Handler) plugin.Constructor[ftlv1connect.VerbServiceHandler, UserVerbConfig]
• func Query[Req, Resp any](module string, verbName string, commandType reflection.CommandType, ...) reflection.Registree
• func QueryEmpty(module string, verbName string, commandType reflection.CommandType, ...) reflection.Registree
• func QuerySink[Req any](module string, verbName string, commandType reflection.CommandType, ...) reflection.Registree
• func QuerySource[Resp any](module string, verbName string, commandType reflection.CommandType, ...) reflection.Registree
• func Secret[T ftl.SecretType](module, name string) reflection.VerbResource
• func SinkClient[Verb, Req any]() reflection.VerbResource
• func SourceClient[Verb, Resp any]() reflection.VerbResource
• func TopicHandle[E any, M ftl.TopicPartitionMap[E]](module, name string) reflection.VerbResource
• func VerbClient[Verb, Req, Resp any]() reflection.VerbResource
• type Handler
  • func HandleCall[Req, Resp any](module string, verb string) Handler
  • func HandleEmpty(module string, verb string) Handler
  • func HandleSink[Req any](module string, verb string) Handler
  • func HandleSource[Resp any](module string, verb string) Handler
• type UserVerbConfig

Functions

func Config

func Config[T ftl.ConfigType](module, name string) reflection.VerbResource

func DatabaseHandle

func DatabaseHandle[T ftl.DatabaseConfig](dbtype string) reflection.VerbResource

func EmptyClient

func EmptyClient[Verb any]() reflection.VerbResource

func InitDatabase

func InitDatabase(ref reflection.Ref, dbtype string, protoDBtype deploymentcontext.DBType, driver string) *reflection.ReflectedDatabaseHandle

func InitMySQL

func InitMySQL(ref reflection.Ref) *reflection.ReflectedDatabaseHandle

func InitPostgres

func InitPostgres(ref reflection.Ref) *reflection.ReflectedDatabaseHandle

func InvokeVerb

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

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 Query

func Query[Req, Resp any](
	module string,
	verbName string,
	commandType reflection.CommandType,
	dbName string,
	rawSQL string,
	fields []string,
	colToFieldName []tuple.Pair[string, string],
) reflection.Registree

func QueryEmpty

func QueryEmpty(
	module string,
	verbName string,
	commandType reflection.CommandType,
	dbName string,
	rawSQL string,
	fields []string,
	colToFieldName []tuple.Pair[string, string],
) reflection.Registree

func QuerySink

func QuerySink[Req any](
	module string,
	verbName string,
	commandType reflection.CommandType,
	dbName string,
	rawSQL string,
	fields []string,
	colToFieldName []tuple.Pair[string, string],
) reflection.Registree

func QuerySource

func QuerySource[Resp any](
	module string,
	verbName string,
	commandType reflection.CommandType,
	dbName string,
	rawSQL string,
	fields []string,
	colToFieldName []tuple.Pair[string, string],
) reflection.Registree

func Secret

func Secret[T ftl.SecretType](module, name string) reflection.VerbResource

func SinkClient

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

func SourceClient

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

func TopicHandle

func TopicHandle[E any, M ftl.TopicPartitionMap[E]](module, name string) 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](module string, verb string) Handler

func HandleEmpty

func HandleEmpty(module string, verb string) Handler

func HandleSink

func HandleSink[Req any](module string, verb string) Handler

func HandleSource

func HandleSource[Resp any](module string, verb string) 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 */
}