logstorage

Documentation

Index

• type Log
• type Receiver
• type Store
  • func New() Store
  • func (s *Store) Append(stream string, ts time.Time, prefix, message string)
  • func (s *Store) Subscribe(ctx context.Context, ch Receiver, stream string, start time.Time, follow bool)

Types

type Log

type Log struct {
	Prefix    string
	Message   string
	Timestamp time.Time
}

type Receiver

type Receiver chan Log

type Store

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

func New

func New() Store

func (*Store) Append

func (s *Store) Append(stream string, ts time.Time, prefix, message string)

func (*Store) Subscribe

func (s *Store) Subscribe(ctx context.Context, ch Receiver, stream string, start time.Time, follow bool)