timelineclient

type Call struct {
	DeploymentKey    key.Deployment
	RequestKey       key.Request
	ParentRequestKey optional.Option[key.Request]
	StartTime        time.Time
	DestVerb         *schema.Ref
	Callers          []*schema.Ref
	Request          *ftlv1.CallRequest
	Response         result.Result[*ftlv1.CallResponse]
}

type ChangesetCreated struct {
	Key       key.Changeset
	CreatedAt time.Time
	Modules   []string // Names of modules being added or modified
	ToRemove  []string // Names of modules being removed
}

type ChangesetStateChanged struct {
	Key   key.Changeset
	State schema.ChangesetState
	Error optional.Option[string] // Present if state is FAILED
}

type Client struct {
	timelinepbconnect.TimelineServiceClient
	// contains filtered or unexported fields
}

type Config struct {
	TimelineEndpoint *url.URL `help:"Timeline endpoint (discard:// to disable)." env:"FTL_TIMELINE_ENDPOINT" default:"http://127.0.0.1:8892"`
}

type CronScheduled struct {
	DeploymentKey key.Deployment
	Verb          schema.Ref
	Time          time.Time
	ScheduledAt   time.Time
	Schedule      string
	Error         optional.Option[string]
}

type DeploymentRuntime struct {
	Deployment key.Deployment
	Changeset  optional.Option[key.Changeset]
	Element    *schema.RuntimeElement
	UpdatedAt  time.Time
}

type Event interface {
	ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
	// contains filtered or unexported methods
}

type Ingress struct {
	DeploymentKey   key.Deployment
	RequestKey      key.Request
	StartTime       time.Time
	Verb            *schema.Ref
	RequestMethod   string
	RequestPath     string
	RequestHeaders  http.Header
	ResponseStatus  int
	ResponseHeaders http.Header
	RequestBody     []byte
	ResponseBody    []byte
	Error           optional.Option[string]
}

type Log struct {
	DeploymentKey key.Deployment
	ChangesetKey  optional.Option[key.Changeset]
	RequestKey    optional.Option[key.Request]
	Time          time.Time
	Level         int32
	Attributes    map[string]string
	Message       string
	Error         optional.Option[string]
}

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

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

type PubSubConsume struct {
	DeploymentKey key.Deployment
	RequestKey    optional.Option[string]
	Time          time.Time
	DestVerb      optional.Option[schema.RefKey]
	Topic         string
	Partition     int
	Offset        int
	Error         optional.Option[string]
}

type PubSubPublish struct {
	DeploymentKey key.Deployment
	RequestKey    optional.Option[string]
	Time          time.Time
	SourceVerb    schema.Ref
	Topic         string
	Partition     int
	Offset        int
	Request       []byte
	Error         optional.Option[string]
}