cron

Documentation

Index

• func Start(ctx context.Context, pullSchemaClient PullSchemaClient, verbClient CallClient) error
• type CallClient
• type PullSchemaClient

Functions

func Start

func Start(ctx context.Context, pullSchemaClient PullSchemaClient, 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 PullSchemaClient

type PullSchemaClient interface {
	PullSchema(ctx context.Context, req *connect.Request[ftlv1.PullSchemaRequest]) (*connect.ServerStreamForClient[ftlv1.PullSchemaResponse], error)
}