logstorage

type LogGetOpts struct {
	Path  string
	Count uint
}

type LogStorageBackend interface {
	// GetID retrieves an ID for the log storage backend
	GetID() string

	// StreamLogs streams logs to the WriteCloser, blocking until the context is cancelled
	StreamLogs(ctx context.Context, opts *LogGetOpts, w io.WriteCloser) error

	// ReadLogs is like StreamLogs, except it returns when all current logs have been read
	ReadLogs(ctx context.Context, opts *LogGetOpts, w io.WriteCloser) error

	// ClearLogs deletes all logs corresponding to the path
	ClearLogs(ctx context.Context, path string) error

	// PushLogLine adds a single log line to the log collection defined by the path
	PushLogLine(ctx context.Context, path string, log []byte) error
}