podlog

Documentation

Index

• func LogStream(ctx context.Context, filter *WorkloadLogSubscriptionFilter) (<-chan *WorkloadLogLine, error)
• func NewLoaderContext(ctx context.Context, streamer Streamer) context.Context
• type Streamer
  • func NewLogStreamer(clientSets map[string]kubernetes.Interface, log logrus.FieldLogger) Streamer
• type WorkloadLogLine
• type WorkloadLogSubscriptionFilter
  • func (f *WorkloadLogSubscriptionFilter) Validate(ctx context.Context) error

Functions

func LogStream

func LogStream(ctx context.Context, filter *WorkloadLogSubscriptionFilter) (<-chan *WorkloadLogLine, error)

func NewLoaderContext

func NewLoaderContext(ctx context.Context, streamer Streamer) context.Context

Types

type Streamer

type Streamer interface {
	Logs(ctx context.Context, filter *WorkloadLogSubscriptionFilter) (<-chan *WorkloadLogLine, error)
}

func NewLogStreamer

func NewLogStreamer(clientSets map[string]kubernetes.Interface, log logrus.FieldLogger) Streamer

type WorkloadLogLine

type WorkloadLogLine struct {
	Time     time.Time `json:"time"`
	Message  string    `json:"message"`
	Instance string    `json:"instance"`
}

type WorkloadLogSubscriptionFilter

type WorkloadLogSubscriptionFilter struct {
	Team        slug.Slug `json:"team"`
	Environment string    `json:"environment"`
	Application *string   `json:"application"`
	Job         *string   `json:"job"`
	Instances   []string  `json:"instances"`
}

func (*WorkloadLogSubscriptionFilter) Validate

func (f *WorkloadLogSubscriptionFilter) Validate(ctx context.Context) error