tasklog

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

type Entry struct {
	TaskID  uuid.UUID
	TS      time.Time
	Event   string
	Kind    string
	TurnSeq uint32
	Data    string
	MsgSeq  string
	Labels  map[string]string
}

type Gateway struct {
	Loki       Provider
	ClickHouse Provider
}

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

type Provider interface {
	Name() string
	QueryLatestTurn(ctx context.Context, taskID uuid.UUID, taskCreatedAt, end time.Time) (*QueryLatestTurnResp, error)
	QueryTurns(ctx context.Context, taskID uuid.UUID, taskCreatedAt time.Time, cursor string, limit int) (*QueryTurnsResp, error)
}

type QueryLatestTurnResp struct {
	Entries    []Entry
	HasMore    bool
	NextCursor string
}

type QueryTurnsResp struct {
	Chunks     []*TurnChunk
	HasMore    bool
	NextCursor string
}

type TurnChunk struct {
	Data      []byte
	Event     string
	Kind      string
	Timestamp int64
	Labels    map[string]string
}