timeline

Documentation

Index

• func Start(ctx context.Context, config Config) error
• type Config
  • func (c *Config) SetDefaults()
• type Metrics
  • func (m *Metrics) Dropped(ctx context.Context)
  • func (m *Metrics) Failed(ctx context.Context, count int)
  • func (m *Metrics) Inserted(ctx context.Context, count int)
• type TimelineFilter
  • func FilterCall(filters []*timelinepb.GetTimelineRequest_CallFilter) TimelineFilter
  • func FilterDeployments(filters []*timelinepb.GetTimelineRequest_DeploymentFilter) TimelineFilter
  • func FilterIDRange(filter *timelinepb.GetTimelineRequest_IDFilter) TimelineFilter
  • func FilterLogLevel(f *timelinepb.GetTimelineRequest_LogLevelFilter) TimelineFilter
  • func FilterModule(filters []*timelinepb.GetTimelineRequest_ModuleFilter) TimelineFilter
  • func FilterRequests(filters []*timelinepb.GetTimelineRequest_RequestFilter) TimelineFilter
  • func FilterTimeRange(filter *timelinepb.GetTimelineRequest_TimeFilter) TimelineFilter
  • func FilterTypes(filters ...*timelinepb.GetTimelineRequest_EventTypeFilter) TimelineFilter

Functions

func Start

func Start(ctx context.Context, config Config) error

Types

type Config

type Config struct {
	Bind              *url.URL       `help:"Socket to bind to." default:"http://127.0.0.1:8894" env:"FTL_BIND"`
	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 TimelineFilter

type TimelineFilter func(event *timelinepb.Event) bool

func FilterCall

func FilterCall(filters []*timelinepb.GetTimelineRequest_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 FilterDeployments

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

func FilterIDRange

func FilterIDRange(filter *timelinepb.GetTimelineRequest_IDFilter) TimelineFilter

FilterIDRange filters events between the given IDs, inclusive.

func FilterLogLevel

func FilterLogLevel(f *timelinepb.GetTimelineRequest_LogLevelFilter) TimelineFilter

func FilterModule

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

func FilterRequests

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

func FilterTimeRange

func FilterTimeRange(filter *timelinepb.GetTimelineRequest_TimeFilter) TimelineFilter

FilterTimeRange filters events between the given times, inclusive.

func FilterTypes

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