logs

type Client struct {
	*otfapi.Client
}

type LogsService = Service

type Options struct {
	logr.Logger
	internal.Cache
	*sql.DB
	*sql.Listener
	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)
	WatchLogs(ctx context.Context) (<-chan pubsub.Event[internal.Chunk], func())
	internal.PutChunkService
	Start(context.Context) error
}