timeline

package
v0.489.3 Latest Latest
Warning

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

 Go to latest Published: May 10, 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.