eventlogger

Documentation

Index

• func CountJobsByTransitions(transitionsByJobId map[string][]string) map[string]int
• type EventsLogger
  • func New(c chan *api.EventMessage, interval time.Duration) *EventsLogger
  • func (srv *EventsLogger) Log()
  • func (srv *EventsLogger) Run(ctx context.Context) error

Functions

func CountJobsByTransitions

func CountJobsByTransitions(transitionsByJobId map[string][]string) map[string]int

CountJobsByTransitions returns a map from sequences of transitions, e.g., "submitted -> queued" to the number of jobs going through exactly those transitions.

Types

type EventsLogger

type EventsLogger struct {
	Out io.Writer
	// contains filtered or unexported fields
}

func New

func New(c chan *api.EventMessage, interval time.Duration) *EventsLogger

func (*EventsLogger) Log

func (srv *EventsLogger) Log()

func (*EventsLogger) Run

func (srv *EventsLogger) Run(ctx context.Context) error