server

type DataService interface {
	Find(req core.Request) ([]core.LogEntry, error)
	LastPublished() (entry core.LogEntry, err error)
}

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

type FileWriter interface {
	Write(rec core.LogEntry) error
}

type Forwarder struct {
	Publisher  Publisher
	Syslog     SyslogBackgroundReader
	FileWriter FileWriter
}

type Mongo struct {
	*mdrv.Client
	MongoParams
	// contains filtered or unexported fields
}

type MongoParams struct {
	MaxDocs            int
	MaxCollectionSize  int
	Delay              time.Duration
	DBName, Collection string
}

type Publisher interface {
	Publish(records []core.LogEntry) (err error)
	LastPublished() (entry core.LogEntry, err error)
}

type RestServer struct {
	Port           int
	DataService    DataService
	Limit          int // request limit, i.e. max number of records any single Find can return
	Version        string
	StreamDuration time.Duration
}

type Syslog struct {
	Port int
	// contains filtered or unexported fields
}

type SyslogBackgroundReader interface {
	Go(ctx context.Context) (<-chan string, error)
}

type WritersFactory func(host, container string) io.Writer