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 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
- type UserVerbConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Config ¶ added in v0.402.0
func Config[T ftl.ConfigType](module, name string) reflection.VerbResource
func DatabaseHandle ¶ added in v0.398.0
func DatabaseHandle[T ftl.DatabaseConfig](dbtype string) reflection.VerbResource
func EmptyClient ¶ added in v0.372.0
func EmptyClient[Verb any]() reflection.VerbResource
func InitDatabase ¶ added in v0.398.0
func InitDatabase(ref reflection.Ref, dbtype string, protoDBtype deploymentcontext.DBType, driver string) *reflection.ReflectedDatabaseHandle
func InitMySQL ¶ added in v0.398.0
func InitMySQL(ref reflection.Ref) *reflection.ReflectedDatabaseHandle
func InitPostgres ¶ added in v0.393.0
func InitPostgres(ref reflection.Ref) *reflection.ReflectedDatabaseHandle
func InvokeVerb ¶ added in v0.393.0
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 Secret ¶ added in v0.402.0
func Secret[T ftl.SecretType](module, name string) reflection.VerbResource
func SinkClient ¶ added in v0.372.0
func SinkClient[Verb, Req any]() reflection.VerbResource
func SourceClient ¶ added in v0.372.0
func SourceClient[Verb, Resp any]() reflection.VerbResource
func TopicHandle ¶ added in v0.401.0
func TopicHandle[E any, M ftl.TopicPartitionMap[E]](module, name string) reflection.VerbResource
func VerbClient ¶ added in v0.372.0
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 ¶ added in v0.149.2
func HandleEmpty ¶ added in v0.149.2
func HandleSink ¶ added in v0.149.2
func HandleSource ¶ added in v0.149.2
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 */ }
Click to show internal directories.
Click to hide internal directories.