Help us shape the future of Go! Take the 2026 Go Developer Survey

timeline

package
v0.510.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 4, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config 

type Config struct {
	EventLogRetention *time.Duration `help:"Delete call logs after this time period. 0 to disable" env:"FTL_EVENT_LOG_RETENTION" default:"24h"`
}

func (*Config) SetDefaults 

func (c *Config) SetDefaults()

type Metrics 

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

func (*Metrics) Dropped 

func (m *Metrics) Dropped(ctx context.Context)

func (*Metrics) Failed 

func (m *Metrics) Failed(ctx context.Context, count int)

func (*Metrics) Inserted 

func (m *Metrics) Inserted(ctx context.Context, count int)

type Service added in v0.477.0 

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

func New added in v0.477.0 

func New(ctx context.Context, config Config) (*Service, error)

func (*Service) CreateEvents added in v0.477.0 

func (s *Service) CreateEvents(ctx context.Context, req *connect.Request[timelinepb.CreateEventsRequest]) (*connect.Response[timelinepb.CreateEventsResponse], error)

func (*Service) DeleteOldEvents added in v0.477.0 

func (s *Service) DeleteOldEvents(ctx context.Context, req *connect.Request[timelinepb.DeleteOldEventsRequest]) (*connect.Response[timelinepb.DeleteOldEventsResponse], error)

func (*Service) GetTimeline added in v0.477.0 

func (s *Service) GetTimeline(ctx context.Context, req *connect.Request[timelinepb.GetTimelineRequest]) (*connect.Response[timelinepb.GetTimelineResponse], error)

func (*Service) Ping added in v0.477.0 

func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) StartServices added in v0.477.0 

func (s *Service) StartServices(ctx context.Context) ([]rpc.Option, error)

func (*Service) StreamTimeline added in v0.477.0 

func (s *Service) StreamTimeline(ctx context.Context, req *connect.Request[timelinepb.StreamTimelineRequest], stream *connect.ServerStream[timelinepb.StreamTimelineResponse]) error

type TimelineFilter 

type TimelineFilter func(event *timelinepb.Event) bool

func FilterCall 

func FilterCall(filters []*timelinepb.TimelineQuery_CallFilter) TimelineFilter

FilterCall filters call events between the given modules.

Takes a list of filters, with each call event needing to match at least one filter.

func FilterChangesets added in v0.464.0 

func FilterChangesets(filters []*timelinepb.TimelineQuery_ChangesetFilter) TimelineFilter

func FilterDeployments 

func FilterDeployments(filters []*timelinepb.TimelineQuery_DeploymentFilter) TimelineFilter

func FilterIDRange 

func FilterIDRange(filter *timelinepb.TimelineQuery_IDFilter) TimelineFilter

FilterIDRange filters events between the given IDs.

func FilterLogLevel 

func FilterLogLevel(f *timelinepb.TimelineQuery_LogLevelFilter) TimelineFilter

func FilterModule 

func FilterModule(filters []*timelinepb.TimelineQuery_ModuleFilter) TimelineFilter

func FilterRequests 

func FilterRequests(filters []*timelinepb.TimelineQuery_RequestFilter) TimelineFilter

func FilterTimeRange 

func FilterTimeRange(filter *timelinepb.TimelineQuery_TimeFilter) TimelineFilter

FilterTimeRange filters events between the given times, inclusive.

func FilterTypes 

func FilterTypes(filters ...*timelinepb.TimelineQuery_EventTypeFilter) TimelineFilter

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.