timeline

Documentation

Index

• type Call
• type Log
• type Service
  • func New(ctx context.Context, conn libdal.Connection, encryption *encryption.Service) *Service
  • func (s *Service) DeleteOldEvents(ctx context.Context, eventType dal.EventType, age time.Duration) (int64, error)
  • func (s *Service) InsertLogEvent(ctx context.Context, log *dal.LogEvent) error
  • func (s *Service) QueryTimeline(ctx context.Context, limit int, filters ...dal.TimelineFilter) ([]dal.TimelineEvent, error)
  • func (s *Service) RecordCall(ctx context.Context, call *Call)
  • func (s *Service) RecordLog(ctx context.Context, log *Log) error

Types

type Call

type Call struct {
	DeploymentKey    model.DeploymentKey
	RequestKey       model.RequestKey
	ParentRequestKey optional.Option[model.RequestKey]
	StartTime        time.Time
	DestVerb         *schema.Ref
	Callers          []*schema.Ref
	Request          *ftlv1.CallRequest
	Response         either.Either[*ftlv1.CallResponse, error]
}

type Log

type Log struct {
	DeploymentKey model.DeploymentKey
	RequestKey    optional.Option[model.RequestKey]
	Msg           *ftlv1.StreamDeploymentLogsRequest
}

type Service

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

func New

func New(ctx context.Context, conn libdal.Connection, encryption *encryption.Service) *Service

func (*Service) DeleteOldEvents

func (s *Service) DeleteOldEvents(ctx context.Context, eventType dal.EventType, age time.Duration) (int64, error)

func (*Service) InsertLogEvent

func (s *Service) InsertLogEvent(ctx context.Context, log *dal.LogEvent) error

func (*Service) QueryTimeline

func (s *Service) QueryTimeline(ctx context.Context, limit int, filters ...dal.TimelineFilter) ([]dal.TimelineEvent, error)

func (*Service) RecordCall

func (s *Service) RecordCall(ctx context.Context, call *Call)

func (*Service) RecordLog

func (s *Service) RecordLog(ctx context.Context, log *Log) error