Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Call ¶
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]
}
func (Call) ToEntry ¶
func (c Call) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type ChangesetCreated ¶ added in v0.460.0
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
}
ChangesetCreated represents a timeline event for when a changeset is created
func (ChangesetCreated) ToEntry ¶ added in v0.460.0
func (c ChangesetCreated) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type ChangesetStateChanged ¶ added in v0.460.0
type ChangesetStateChanged struct {
Key key.Changeset
State schema.ChangesetState
Error optional.Option[string] // Present if state is FAILED
}
ChangesetStateChanged represents a timeline event for when a changeset changes state
func (ChangesetStateChanged) ToEntry ¶ added in v0.460.0
func (c ChangesetStateChanged) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type Client ¶
type Client struct {
timelinepbconnect.TimelineServiceClient
// contains filtered or unexported fields
}
type CronScheduled ¶
type CronScheduled struct {
DeploymentKey key.Deployment
Verb schema.Ref
Time time.Time
ScheduledAt time.Time
Schedule string
Error optional.Option[string]
}
func (CronScheduled) ToEntry ¶
func (e CronScheduled) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type DeploymentRuntime ¶ added in v0.460.0
type DeploymentRuntime struct {
Deployment key.Deployment
Changeset optional.Option[key.Changeset]
Element *schema.RuntimeElement
UpdatedAt time.Time
}
DeploymentRuntime represents a timeline event for deployment runtime changes
func (DeploymentRuntime) ToEntry ¶ added in v0.460.0
func (d DeploymentRuntime) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type Event ¶
type Event interface {
ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
// contains filtered or unexported methods
}
type Ingress ¶
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]
}
func (Ingress) ToEntry ¶
func (i Ingress) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type Log ¶
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]
}
func (Log) ToEntry ¶
func (l Log) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type LogSink ¶ added in v0.461.0
type LogSink struct {
// contains filtered or unexported fields
}
LogSink is a log sink that sends logs to the timeline client.
It needs to be run in a separate goroutine after creation by calling RunLogLoop.
func (*LogSink) RunLogLoop ¶ added in v0.461.0
RunLogLoop runs the log loop.
It will run until the context is cancelled.
type PubSubConsume ¶
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]
}
func (PubSubConsume) ToEntry ¶
func (p PubSubConsume) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
type PubSubPublish ¶
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]
}
func (PubSubPublish) ToEntry ¶
func (p PubSubPublish) ToEntry() (*timelinepb.CreateEventsRequest_EventEntry, error)
Click to show internal directories.
Click to hide internal directories.