logflusher

Documentation

Index

• type FlushInput
• type FlushLogsInput
• type LogFlusher
  • func NewLogFlusher(opts *LogFlusherOpts) *LogFlusher
  • func (lf *LogFlusher) Flush(ctx context.Context, input FlushInput) (string, error)
  • func (lf *LogFlusher) FlushLogs(ctx workflow.Context, input FlushLogsInput) (string, error)
• type LogFlusherOpts

Types

type FlushInput

type FlushInput struct {
	TeamID      string
	ModuleID    string
	ModuleRunID string
}

type FlushLogsInput

type FlushLogsInput struct {
}

type LogFlusher

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

func NewLogFlusher

func NewLogFlusher(opts *LogFlusherOpts) *LogFlusher

func (*LogFlusher) Flush

func (lf *LogFlusher) Flush(ctx context.Context, input FlushInput) (string, error)

func (*LogFlusher) FlushLogs

func (lf *LogFlusher) FlushLogs(ctx workflow.Context, input FlushLogsInput) (string, error)

type LogFlusherOpts

type LogFlusherOpts struct {
	LogStore   logstorage.LogStorageBackend
	FileStore  filestorage.FileStorageManager
	Repository repository.Repository
}