core

type Log interface {
	ID() int64
	Write(ctx context.Context, line *LogLine) error
	Save(ctx context.Context) error
	Remove(ctx context.Context) error
	Cat(ctx context.Context) ([]*LogLine, error)
	Tail(ctx context.Context) (<-chan *LogLine, error)
	Close(ctx context.Context) error
}

type LogLine struct {
	Number    int64     `json:"line"`
	Text      string    `json:"text"`
	Timestamp time.Time `json:"time"`
}

type LogManager interface {
	Create() (Log, error)
	Open(id int64) (Log, error)
	Close(id int64) error
}

type LogStore interface {
	Create(r io.Reader) (int64, error)
	Exists(id int64) bool
	Find(id int64) (io.ReadCloser, error)
	Update(id int64, r io.Reader) error
	Delete(id int64) error
}

type LogStream interface {
	Create(ctx context.Context, id int64) error
	Write(ctx context.Context, id int64, line *LogLine) error
	Delete(ctx context.Context, id int64) error
	Tail(ctx context.Context, id int64) (<-chan *LogLine, error)
}

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

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