history

Documentation

Index

• Constants
• func NewMock() interface{ ... }
• type DB
  • func InstrumentedDB(db DB) DB
• type EventReadWriter
• type EventReader
• type EventWriter

Constants

const (
	LabelMethod  = "method"
	LabelSuccess = "success"
)

Functions

func NewMock

func NewMock() interface {
	EventReader
	EventWriter
}

Types

type DB

type DB interface {
	LogEvent(flux.InstanceID, flux.Event) error
	AllEvents(flux.InstanceID, time.Time, int64) ([]flux.Event, error)
	EventsForService(flux.InstanceID, flux.ServiceID, time.Time, int64) ([]flux.Event, error)
	GetEvent(flux.EventID) (flux.Event, error)
	io.Closer
}

func InstrumentedDB

func InstrumentedDB(db DB) DB

type EventReadWriter

type EventReadWriter interface {
	EventReader
	EventWriter
}

type EventReader

type EventReader interface {
	// AllEvents returns a history for every service. Events must be
	// returned in descending timestamp order.
	AllEvents(time.Time, int64) ([]flux.Event, error)

	// EventsForService returns the history for a particular
	// service. Events must be returned in descending timestamp order.
	EventsForService(flux.ServiceID, time.Time, int64) ([]flux.Event, error)

	// GetEvent finds a single event, by ID.
	GetEvent(flux.EventID) (flux.Event, error)
}

type EventWriter

type EventWriter interface {
	// LogEvent records a message in the history of a service.
	LogEvent(flux.Event) error
}