cron

Documentation

Index

• func Start(ctx context.Context, eventSource schemaeventsource.EventSource, ...) error
• type CallClient
• type Config

Functions

func Start

func Start(ctx context.Context, eventSource schemaeventsource.EventSource, verbClient CallClient) error

Start the cron service. Blocks until the context is cancelled.

Types

type CallClient

type CallClient interface {
	Call(ctx context.Context, req *connect.Request[ftlv1.CallRequest]) (*connect.Response[ftlv1.CallResponse], error)
}

type Config

type Config struct {
	ControllerEndpoint *url.URL `name:"ftl-endpoint" help:"Controller endpoint." env:"FTL_ENDPOINT" default:"http://127.0.0.1:8892"`
}