logs

type Client struct {
	internal.JSONAPIClient
}

type LogsService = Service

type Options struct {
	logr.Logger
	internal.Cache
	*sql.DB
	*pubsub.Broker
	internal.Verifier

	RunAuthorizer internal.Authorizer
}

type PhaseWriter struct {
	internal.PutChunkService // for uploading logs to server
	// contains filtered or unexported fields
}

type PhaseWriterOptions struct {
	RunID  string
	Phase  internal.PhaseType
	Writer internal.PutChunkService
}

type Service interface {
	GetChunk(ctx context.Context, opts internal.GetChunkOptions) (internal.Chunk, error)
	Tail(ctx context.Context, opts internal.GetChunkOptions) (<-chan internal.Chunk, error)
	internal.PutChunkService
	Start(context.Context) error
}