api

Documentation

Index

• Constants
• func NoFilter(e model.Event) bool
• type API
  • func New(s Store, b *Broadcaster, statsTTL time.Duration) (*API, error)
  • func (a *API) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Broadcaster
  • func NewBroadcaster(s Store, retryTimeout time.Duration) *Broadcaster
  • func (b *Broadcaster) Run() error
  • func (b *Broadcaster) Stop() error
  • func (b *Broadcaster) Subscribe(f Filter, prefill bool) (data <-chan []byte, unsubscribe func())
• type Filter
  • func SearchFilter(f string, since time.Time) Filter
• type Server
  • func NewServer(addr string, s Store, b *Broadcaster, statsTTL time.Duration) (*Server, error)
  • func (s *Server) Run() error
  • func (s *Server) Stop() error
• type Store

Constants

const BufferSize = 50

Functions

func NoFilter

func NoFilter(e model.Event) bool

Types

type API

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

func New

func New(s Store, b *Broadcaster, statsTTL time.Duration) (*API, error)

func (*API) ServeHTTP

func (a *API) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster(s Store, retryTimeout time.Duration) *Broadcaster

func (*Broadcaster) Run

func (b *Broadcaster) Run() error

func (*Broadcaster) Stop

func (b *Broadcaster) Stop() error

func (*Broadcaster) Subscribe

func (b *Broadcaster) Subscribe(f Filter, prefill bool) (data <-chan []byte, unsubscribe func())

type Filter

type Filter func(model.Event) bool

func SearchFilter

func SearchFilter(f string, since time.Time) Filter

type Server

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

func NewServer

func NewServer(addr string, s Store, b *Broadcaster, statsTTL time.Duration) (*Server, error)

func (*Server) Run

func (s *Server) Run() error

func (*Server) Stop

func (s *Server) Stop() error

type Store

type Store interface {
	Search(filter string) ([]model.Event, error)
	Stats() (model.Stats, error)
	Events() <-chan model.Event
}