internal

Documentation

Index

• Constants
• type Event
  • func ParseEvent(eventString string) (*Event, error)
  • func (e *Event) Marshal() (string, error)
• type EventList
• type FilesystemDatastore
  • func (d *FilesystemDatastore) Add(event *Event) error
  • func (d *FilesystemDatastore) Initialize() error
  • func (d *FilesystemDatastore) List() ([]*Event, error)
• type InMemoryDatastore
  • func (d *InMemoryDatastore) Add(event *Event) error
  • func (d *InMemoryDatastore) List() ([]*Event, error)
• type Server
  • func (s *Server) Start() error

Constants

const DefaultPort = 8081

const MessageKey = "msg"

const TimeKey = "time"

Types

type Event

type Event struct {
	Time    string            `json:"time"`
	Labels  map[string]string `json:"labels"`
	Message string            `json:"message"`
}

func ParseEvent

func ParseEvent(eventString string) (*Event, error)

func (*Event) Marshal

func (e *Event) Marshal() (string, error)

type EventList

type EventList interface {
	Add(*Event) error
	List() ([]*Event, error)
}

type FilesystemDatastore

type FilesystemDatastore struct {
	Path string
	// contains filtered or unexported fields
}

func (*FilesystemDatastore) Add

func (d *FilesystemDatastore) Add(event *Event) error

func (*FilesystemDatastore) Initialize

func (d *FilesystemDatastore) Initialize() error

func (*FilesystemDatastore) List

func (d *FilesystemDatastore) List() ([]*Event, error)

type InMemoryDatastore

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

func (*InMemoryDatastore) Add

func (d *InMemoryDatastore) Add(event *Event) error

func (*InMemoryDatastore) List

func (d *InMemoryDatastore) List() ([]*Event, error)

type Server

type Server struct {
	Events EventList
	Port   int
}

func (*Server) Start

func (s *Server) Start() error