datasource

Documentation

Index

• Constants
• func NewFakeID() string
• type Datasource
• type LogEvent
  • func (e LogEvent) MarshalJSON() ([]byte, error)
  • func (e *LogEvent) UnmarshalJSON(b []byte) error

Constants

const (
	S3    = "s3"
	Local = "local"
	Fake  = "fake"
)

Functions

func NewFakeID

func NewFakeID() string

Types

type Datasource

type Datasource interface {
	Fetch(context.Context) <-chan *LogEvent
	Err() error
}

type LogEvent

type LogEvent struct {
	ID        string
	Timestamp time.Time
	Message   string
	Raw       string
}

func (LogEvent) MarshalJSON

func (e LogEvent) MarshalJSON() ([]byte, error)

func (*LogEvent) UnmarshalJSON

func (e *LogEvent) UnmarshalJSON(b []byte) error