logs

type Chunk struct {
	// TODO: this is better set as a monotonic serial rather than a TFE ID.
	ID resource.TfeID `json:"chunk_id"` // Uniquely identifies the chunk.

	RunID  resource.TfeID     `json:"run_id"`  // ID of run that generated the chunk
	Phase  internal.PhaseType `json:"phase"`   // Phase that generated the chunk
	Offset int                `json:"_offset"` // Position within logs.
	Data   PostgresHex        `json:"chunk"`   // The log data
}

type Client struct {
	*otfapi.Client
}

type GetChunkOptions struct {
	RunID  resource.TfeID     `schema:"run_id,required"`
	Phase  internal.PhaseType `schema:"phase,required"`
	Limit  int                `schema:"limit"`  // size of the chunk to retrieve
	Offset int                `schema:"offset"` // position in overall data to seek from.
}

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

	Authorizer *authz.Authorizer
}

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

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

type PostgresHex []byte

type PutChunkOptions struct {
	RunID  resource.TfeID     `schema:"run_id,required"`
	Phase  internal.PhaseType `schema:"phase,required"`
	Offset int                `schema:"offset,required"`
	Data   []byte
}

type PutChunkService interface {
	PutChunk(ctx context.Context, opts PutChunkOptions) error
}

type Service struct {
	logr.Logger
	*authz.Authorizer
	// contains filtered or unexported fields
}

type TailOptions struct {
	RunID  resource.TfeID     `schema:"run_id,required"`
	Phase  internal.PhaseType `schema:"phase,required"`
	Offset int                `schema:"offset"` // position in overall data to seek from.
}