Help us shape the future of Go! Take the 2026 Go Developer Survey

write

package
v0.1.58 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const WriterDatlyResourceNamespace = "datly_modelcall_write_writer"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source 
var (
	LifecycleHooks = new(Lifecycle)
	LifecycleDatly = LifecycleDatlyType()
)
View Source 
var WriterDatly = new(WriterComponent)

The public value supports explicit component wiring.

View Source 
var WriterDatlyResources embed.FS

Functions

func LifecycleDatlyType 

func LifecycleDatlyType() reflect.Type

func WriterDatlyType 

func WriterDatlyType() reflect.Type

WriterDatlyType returns the public component type.

func WriterHandlerCurrentWriterIndexByCompletedAtKey 

func WriterHandlerCurrentWriterIndexByCompletedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByCompletionAcceptedPredictionTokensKey 

func WriterHandlerCurrentWriterIndexByCompletionAcceptedPredictionTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCompletionAudioTokensKey 

func WriterHandlerCurrentWriterIndexByCompletionAudioTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCompletionReasoningTokensKey 

func WriterHandlerCurrentWriterIndexByCompletionReasoningTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCompletionRejectedPredictionTokensKey 

func WriterHandlerCurrentWriterIndexByCompletionRejectedPredictionTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCompletionTokensKey 

func WriterHandlerCurrentWriterIndexByCompletionTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByCostKey 

func WriterHandlerCurrentWriterIndexByCostKey(value *CurrentWriterView) (float64, bool)

func WriterHandlerCurrentWriterIndexByErrorCodeKey 

func WriterHandlerCurrentWriterIndexByErrorCodeKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByErrorMessageKey 

func WriterHandlerCurrentWriterIndexByErrorMessageKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByFinishReasonKey 

func WriterHandlerCurrentWriterIndexByFinishReasonKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByIterationKey 

func WriterHandlerCurrentWriterIndexByIterationKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByLatencyMsKey 

func WriterHandlerCurrentWriterIndexByLatencyMsKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByMessageIdKey 

func WriterHandlerCurrentWriterIndexByMessageIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByModelKey 

func WriterHandlerCurrentWriterIndexByModelKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByModelKindKey 

func WriterHandlerCurrentWriterIndexByModelKindKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByPromptAudioTokensKey 

func WriterHandlerCurrentWriterIndexByPromptAudioTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByPromptCachedTokensKey 

func WriterHandlerCurrentWriterIndexByPromptCachedTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByPromptTokensKey 

func WriterHandlerCurrentWriterIndexByPromptTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByProviderKey 

func WriterHandlerCurrentWriterIndexByProviderKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProviderRequestPayloadIdKey 

func WriterHandlerCurrentWriterIndexByProviderRequestPayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByProviderResponsePayloadIdKey 

func WriterHandlerCurrentWriterIndexByProviderResponsePayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRequestPayloadIdKey 

func WriterHandlerCurrentWriterIndexByRequestPayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByResponsePayloadIdKey 

func WriterHandlerCurrentWriterIndexByResponsePayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByRunIdKey 

func WriterHandlerCurrentWriterIndexByRunIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexBySpanIdKey 

func WriterHandlerCurrentWriterIndexBySpanIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByStartedAtKey 

func WriterHandlerCurrentWriterIndexByStartedAtKey(value *CurrentWriterView) (time.Time, bool)

func WriterHandlerCurrentWriterIndexByStatusKey 

func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByStreamPayloadIdKey 

func WriterHandlerCurrentWriterIndexByStreamPayloadIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByTotalTokensKey 

func WriterHandlerCurrentWriterIndexByTotalTokensKey(value *CurrentWriterView) (int, bool)

func WriterHandlerCurrentWriterIndexByTraceIdKey 

func WriterHandlerCurrentWriterIndexByTraceIdKey(value *CurrentWriterView) (string, bool)

func WriterHandlerCurrentWriterIndexByTurnIdKey 

func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool)

Types

type CurrentWriterView 

type CurrentWriterView struct {
	MessageId                          string     `validate:"required" sqlx:"message_id,primaryKey,refTable=message,refColumn=id" json:"messageId"`
	Provider                           string     `validate:"required" json:"provider" sqlx:"provider,required=true"`
	Model                              string     `validate:"required" json:"model" sqlx:"model,required=true"`
	ModelKind                          string     `validate:"required" json:"modelKind" sqlx:"model_kind,required=true"`
	Status                             string     `validate:"required" json:"status" sqlx:"status,required=true"`
	Cost                               *float64   `sqlx:"cost" json:"cost,omitempty"`
	TurnId                             *string    `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	ErrorCode                          *string    `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage                       *string    `sqlx:"error_message" json:"errorMessage,omitempty"`
	FinishReason                       *string    `sqlx:"finish_reason" json:"finishReason,omitempty"`
	PromptTokens                       *int       `sqlx:"prompt_tokens" json:"promptTokens,omitempty"`
	PromptCachedTokens                 *int       `sqlx:"prompt_cached_tokens" json:"promptCachedTokens,omitempty"`
	CompletionTokens                   *int       `sqlx:"completion_tokens" json:"completionTokens,omitempty"`
	TotalTokens                        *int       `sqlx:"total_tokens" json:"totalTokens,omitempty"`
	PromptAudioTokens                  *int       `sqlx:"prompt_audio_tokens" json:"promptAudioTokens,omitempty"`
	CompletionReasoningTokens          *int       `sqlx:"completion_reasoning_tokens" json:"completionReasoningTokens,omitempty"`
	CompletionAudioTokens              *int       `sqlx:"completion_audio_tokens" json:"completionAudioTokens,omitempty"`
	CompletionAcceptedPredictionTokens *int       `sqlx:"completion_accepted_prediction_tokens" json:"completionAcceptedPredictionTokens,omitempty"`
	CompletionRejectedPredictionTokens *int       `sqlx:"completion_rejected_prediction_tokens" json:"completionRejectedPredictionTokens,omitempty"`
	StartedAt                          *time.Time `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt                        *time.Time `sqlx:"completed_at" json:"completedAt,omitempty"`
	LatencyMs                          *int       `sqlx:"latency_ms" json:"latencyMs,omitempty"`
	TraceId                            *string    `sqlx:"trace_id" json:"traceId,omitempty"`
	SpanId                             *string    `sqlx:"span_id" json:"spanId,omitempty"`
	RequestPayloadId                   *string    `sqlx:"request_payload_id,refTable=call_payload,refColumn=id" json:"requestPayloadId,omitempty"`
	ResponsePayloadId                  *string    `sqlx:"response_payload_id,refTable=call_payload,refColumn=id" json:"responsePayloadId,omitempty"`
	ProviderRequestPayloadId           *string    `sqlx:"provider_request_payload_id,refTable=call_payload,refColumn=id" json:"providerRequestPayloadId,omitempty"`
	ProviderResponsePayloadId          *string    `sqlx:"provider_response_payload_id,refTable=call_payload,refColumn=id" json:"providerResponsePayloadId,omitempty"`
	StreamPayloadId                    *string    `sqlx:"stream_payload_id,refTable=call_payload,refColumn=id" json:"streamPayloadId,omitempty"`
	RunId                              *string    `sqlx:"run_id" json:"runId,omitempty"`
	Iteration                          *int       `sqlx:"iteration" json:"iteration,omitempty"`
}

CurrentWriterView is generated canonical view metadata for writer.

type Input 

type Input struct {
	OrphanDetach  bool                 `parameter:"OrphanDetach,kind=orphandetach,in=enabledDetach,dataType=bool,required=false"`
	OrphanColumn  string               `parameter:"OrphanColumn,kind=orphandetach,in=column,dataType=string,required=false"`
	ModelCalls    []*ModelCall         `` /* 208-byte string literal not displayed */
	WriterKeys    []WriterKeysRow      `` /* 136-byte string literal not displayed */
	CurrentWriter []*CurrentWriterView `` /* 169-byte string literal not displayed */

	Has *InputHas `setMarker:"true" typeName:"InputHas" json:"-" sqlx:"-"`
	// contains filtered or unexported fields
}

Input is the generated input scaffold for writer.

func (*Input) Init 

func (input *Input) Init(context.Context) error

Legacy deletion acknowledges blank message identities without touching data.

func (*Input) PrepareReadIndexes 

func (input *Input) PrepareReadIndexes(ctx context.Context) error

func (*Input) ReadIndexes 

func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)

func (*Input) SetCurrentWriter 

func (input *Input) SetCurrentWriter(value []*CurrentWriterView)

func (*Input) SetModelCalls 

func (input *Input) SetModelCalls(value []*ModelCall)

func (*Input) SetOrphanColumn 

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach 

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetWriterKeys 

func (input *Input) SetWriterKeys(value []WriterKeysRow)

type InputHas 

type InputHas struct {
	OrphanDetach  bool
	OrphanColumn  bool
	ModelCalls    bool
	WriterKeys    bool
	CurrentWriter bool
}

type Lifecycle 

type Lifecycle struct {
	Input *Input `bind:"kind=input"`
}

Lifecycle customizes role Input.ModelCalls.

func (*Lifecycle) AfterQueue 

func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *ModelCall, state xhandler.LifecycleContext[ModelCall, xhandler.NoParent, Output]) error

func (*Lifecycle) AfterSequence 

func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *ModelCall, state xhandler.LifecycleContext[ModelCall, xhandler.NoParent, Output]) error

func (*Lifecycle) Finalize 

func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error

func (*Lifecycle) Init 

func (hooks *Lifecycle) Init(ctx context.Context, entity *ModelCall, state xhandler.LifecycleContext[ModelCall, xhandler.NoParent, Output]) error

func (*Lifecycle) Validate 

func (hooks *Lifecycle) Validate(ctx context.Context, entity *ModelCall, state xhandler.LifecycleContext[ModelCall, xhandler.NoParent, Output]) error

type ModelCall 

type ModelCall struct {
	ShouldDelete                       bool          `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
	MessageId                          string        `validate:"required" sqlx:"message_id,primaryKey,refTable=message,refColumn=id" json:"messageId"`
	Provider                           string        `validate:"required" json:"provider" sqlx:"provider,required=true"`
	Model                              string        `validate:"required" json:"model" sqlx:"model,required=true"`
	ModelKind                          string        `validate:"required" json:"modelKind" sqlx:"model_kind,required=true"`
	Status                             string        `validate:"required" json:"status" sqlx:"status,required=true"`
	Cost                               *float64      `sqlx:"cost" json:"cost,omitempty"`
	TurnId                             *string       `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
	ErrorCode                          *string       `sqlx:"error_code" json:"errorCode,omitempty"`
	ErrorMessage                       *string       `sqlx:"error_message" json:"errorMessage,omitempty"`
	FinishReason                       *string       `sqlx:"finish_reason" json:"finishReason,omitempty"`
	PromptTokens                       *int          `sqlx:"prompt_tokens" json:"promptTokens,omitempty"`
	PromptCachedTokens                 *int          `sqlx:"prompt_cached_tokens" json:"promptCachedTokens,omitempty"`
	CompletionTokens                   *int          `sqlx:"completion_tokens" json:"completionTokens,omitempty"`
	TotalTokens                        *int          `sqlx:"total_tokens" json:"totalTokens,omitempty"`
	PromptAudioTokens                  *int          `sqlx:"prompt_audio_tokens" json:"promptAudioTokens,omitempty"`
	CompletionReasoningTokens          *int          `sqlx:"completion_reasoning_tokens" json:"completionReasoningTokens,omitempty"`
	CompletionAudioTokens              *int          `sqlx:"completion_audio_tokens" json:"completionAudioTokens,omitempty"`
	CompletionAcceptedPredictionTokens *int          `sqlx:"completion_accepted_prediction_tokens" json:"completionAcceptedPredictionTokens,omitempty"`
	CompletionRejectedPredictionTokens *int          `sqlx:"completion_rejected_prediction_tokens" json:"completionRejectedPredictionTokens,omitempty"`
	StartedAt                          *time.Time    `sqlx:"started_at" json:"startedAt,omitempty"`
	CompletedAt                        *time.Time    `sqlx:"completed_at" json:"completedAt,omitempty"`
	LatencyMs                          *int          `sqlx:"latency_ms" json:"latencyMs,omitempty"`
	TraceId                            *string       `sqlx:"trace_id" json:"traceId,omitempty"`
	SpanId                             *string       `sqlx:"span_id" json:"spanId,omitempty"`
	RequestPayloadId                   *string       `sqlx:"request_payload_id,refTable=call_payload,refColumn=id" json:"requestPayloadId,omitempty"`
	ResponsePayloadId                  *string       `sqlx:"response_payload_id,refTable=call_payload,refColumn=id" json:"responsePayloadId,omitempty"`
	ProviderRequestPayloadId           *string       `sqlx:"provider_request_payload_id,refTable=call_payload,refColumn=id" json:"providerRequestPayloadId,omitempty"`
	ProviderResponsePayloadId          *string       `sqlx:"provider_response_payload_id,refTable=call_payload,refColumn=id" json:"providerResponsePayloadId,omitempty"`
	StreamPayloadId                    *string       `sqlx:"stream_payload_id,refTable=call_payload,refColumn=id" json:"streamPayloadId,omitempty"`
	RunId                              *string       `sqlx:"run_id" json:"runId,omitempty"`
	Iteration                          *int          `sqlx:"iteration" json:"iteration,omitempty"`
	Has                                *ModelCallHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"ModelCallHas"`
}

ModelCall is generated canonical view metadata for writer.

func (*ModelCall) GetCompletedAt 

func (entity *ModelCall) GetCompletedAt() *time.Time

func (*ModelCall) GetCompletionAcceptedPredictionTokens 

func (entity *ModelCall) GetCompletionAcceptedPredictionTokens() *int

func (*ModelCall) GetCompletionAudioTokens 

func (entity *ModelCall) GetCompletionAudioTokens() *int

func (*ModelCall) GetCompletionReasoningTokens 

func (entity *ModelCall) GetCompletionReasoningTokens() *int

func (*ModelCall) GetCompletionRejectedPredictionTokens 

func (entity *ModelCall) GetCompletionRejectedPredictionTokens() *int

func (*ModelCall) GetCompletionTokens 

func (entity *ModelCall) GetCompletionTokens() *int

func (*ModelCall) GetCost 

func (entity *ModelCall) GetCost() *float64

func (*ModelCall) GetErrorCode 

func (entity *ModelCall) GetErrorCode() *string

func (*ModelCall) GetErrorMessage 

func (entity *ModelCall) GetErrorMessage() *string

func (*ModelCall) GetFinishReason 

func (entity *ModelCall) GetFinishReason() *string

func (*ModelCall) GetIteration 

func (entity *ModelCall) GetIteration() *int

func (*ModelCall) GetLatencyMs 

func (entity *ModelCall) GetLatencyMs() *int

func (*ModelCall) GetMessageId 

func (entity *ModelCall) GetMessageId() string

func (*ModelCall) GetModel 

func (entity *ModelCall) GetModel() string

func (*ModelCall) GetModelKind 

func (entity *ModelCall) GetModelKind() string

func (*ModelCall) GetPromptAudioTokens 

func (entity *ModelCall) GetPromptAudioTokens() *int

func (*ModelCall) GetPromptCachedTokens 

func (entity *ModelCall) GetPromptCachedTokens() *int

func (*ModelCall) GetPromptTokens 

func (entity *ModelCall) GetPromptTokens() *int

func (*ModelCall) GetProvider 

func (entity *ModelCall) GetProvider() string

func (*ModelCall) GetProviderRequestPayloadId 

func (entity *ModelCall) GetProviderRequestPayloadId() *string

func (*ModelCall) GetProviderResponsePayloadId 

func (entity *ModelCall) GetProviderResponsePayloadId() *string

func (*ModelCall) GetRequestPayloadId 

func (entity *ModelCall) GetRequestPayloadId() *string

func (*ModelCall) GetResponsePayloadId 

func (entity *ModelCall) GetResponsePayloadId() *string

func (*ModelCall) GetRunId 

func (entity *ModelCall) GetRunId() *string

func (*ModelCall) GetShouldDelete 

func (entity *ModelCall) GetShouldDelete() bool

func (*ModelCall) GetSpanId 

func (entity *ModelCall) GetSpanId() *string

func (*ModelCall) GetStartedAt 

func (entity *ModelCall) GetStartedAt() *time.Time

func (*ModelCall) GetStatus 

func (entity *ModelCall) GetStatus() string

func (*ModelCall) GetStreamPayloadId 

func (entity *ModelCall) GetStreamPayloadId() *string

func (*ModelCall) GetTotalTokens 

func (entity *ModelCall) GetTotalTokens() *int

func (*ModelCall) GetTraceId 

func (entity *ModelCall) GetTraceId() *string

func (*ModelCall) GetTurnId 

func (entity *ModelCall) GetTurnId() *string

func (*ModelCall) SetCompletedAt 

func (entity *ModelCall) SetCompletedAt(value *time.Time)

func (*ModelCall) SetCompletionAcceptedPredictionTokens 

func (entity *ModelCall) SetCompletionAcceptedPredictionTokens(value *int)

func (*ModelCall) SetCompletionAudioTokens 

func (entity *ModelCall) SetCompletionAudioTokens(value *int)

func (*ModelCall) SetCompletionReasoningTokens 

func (entity *ModelCall) SetCompletionReasoningTokens(value *int)

func (*ModelCall) SetCompletionRejectedPredictionTokens 

func (entity *ModelCall) SetCompletionRejectedPredictionTokens(value *int)

func (*ModelCall) SetCompletionTokens 

func (entity *ModelCall) SetCompletionTokens(value *int)

func (*ModelCall) SetCost 

func (entity *ModelCall) SetCost(value *float64)

func (*ModelCall) SetErrorCode 

func (entity *ModelCall) SetErrorCode(value *string)

func (*ModelCall) SetErrorMessage 

func (entity *ModelCall) SetErrorMessage(value *string)

func (*ModelCall) SetFinishReason 

func (entity *ModelCall) SetFinishReason(value *string)

func (*ModelCall) SetIteration 

func (entity *ModelCall) SetIteration(value *int)

func (*ModelCall) SetLatencyMs 

func (entity *ModelCall) SetLatencyMs(value *int)

func (*ModelCall) SetMessageId 

func (entity *ModelCall) SetMessageId(value string)

func (*ModelCall) SetModel 

func (entity *ModelCall) SetModel(value string)

func (*ModelCall) SetModelKind 

func (entity *ModelCall) SetModelKind(value string)

func (*ModelCall) SetPromptAudioTokens 

func (entity *ModelCall) SetPromptAudioTokens(value *int)

func (*ModelCall) SetPromptCachedTokens 

func (entity *ModelCall) SetPromptCachedTokens(value *int)

func (*ModelCall) SetPromptTokens 

func (entity *ModelCall) SetPromptTokens(value *int)

func (*ModelCall) SetProvider 

func (entity *ModelCall) SetProvider(value string)

func (*ModelCall) SetProviderRequestPayloadId 

func (entity *ModelCall) SetProviderRequestPayloadId(value *string)

func (*ModelCall) SetProviderResponsePayloadId 

func (entity *ModelCall) SetProviderResponsePayloadId(value *string)

func (*ModelCall) SetRequestPayloadId 

func (entity *ModelCall) SetRequestPayloadId(value *string)

func (*ModelCall) SetResponsePayloadId 

func (entity *ModelCall) SetResponsePayloadId(value *string)

func (*ModelCall) SetRunId 

func (entity *ModelCall) SetRunId(value *string)

func (*ModelCall) SetShouldDelete 

func (entity *ModelCall) SetShouldDelete(value bool)

func (*ModelCall) SetSpanId 

func (entity *ModelCall) SetSpanId(value *string)

func (*ModelCall) SetStartedAt 

func (entity *ModelCall) SetStartedAt(value *time.Time)

func (*ModelCall) SetStatus 

func (entity *ModelCall) SetStatus(value string)

func (*ModelCall) SetStreamPayloadId 

func (entity *ModelCall) SetStreamPayloadId(value *string)

func (*ModelCall) SetTotalTokens 

func (entity *ModelCall) SetTotalTokens(value *int)

func (*ModelCall) SetTraceId 

func (entity *ModelCall) SetTraceId(value *string)

func (*ModelCall) SetTurnId 

func (entity *ModelCall) SetTurnId(value *string)

type ModelCallHas 

type ModelCallHas struct {
	ShouldDelete                       bool
	MessageId                          bool
	Provider                           bool
	Model                              bool
	ModelKind                          bool
	Status                             bool
	Cost                               bool
	TurnId                             bool
	ErrorCode                          bool
	ErrorMessage                       bool
	FinishReason                       bool
	PromptTokens                       bool
	PromptCachedTokens                 bool
	CompletionTokens                   bool
	TotalTokens                        bool
	PromptAudioTokens                  bool
	CompletionReasoningTokens          bool
	CompletionAudioTokens              bool
	CompletionAcceptedPredictionTokens bool
	CompletionRejectedPredictionTokens bool
	StartedAt                          bool
	CompletedAt                        bool
	LatencyMs                          bool
	TraceId                            bool
	SpanId                             bool
	RequestPayloadId                   bool
	ResponsePayloadId                  bool
	ProviderRequestPayloadId           bool
	ProviderResponsePayloadId          bool
	StreamPayloadId                    bool
	RunId                              bool
	Iteration                          bool
}

type Output 

type Output struct {
	Data []*ModelCall `parameter:"Data,kind=output,in=body,dataType=[]*ModelCall" json:"data,omitempty"`
}

Output is the generated output scaffold for writer.

type WriterComponent 

type WriterComponent struct {
	Contract xdatly.Component[Input, Output] "" /* 166-byte string literal not displayed */
}

Component is the generated component scaffold for writer.

func (WriterComponent) EmbedFS 

func (WriterComponent) EmbedFS() *embed.FS

func (WriterComponent) EmbedNamespace 

func (WriterComponent) EmbedNamespace() string

type WriterHandlerCurrentWriterGroupedByCompletedAt 

type WriterHandlerCurrentWriterGroupedByCompletedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByCompletionAcceptedPredictionTokens 

type WriterHandlerCurrentWriterGroupedByCompletionAcceptedPredictionTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletionAcceptedPredictionTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletionAcceptedPredictionTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCompletionAudioTokens 

type WriterHandlerCurrentWriterGroupedByCompletionAudioTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletionAudioTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletionAudioTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCompletionReasoningTokens 

type WriterHandlerCurrentWriterGroupedByCompletionReasoningTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletionReasoningTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletionReasoningTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCompletionRejectedPredictionTokens 

type WriterHandlerCurrentWriterGroupedByCompletionRejectedPredictionTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletionRejectedPredictionTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletionRejectedPredictionTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCompletionTokens 

type WriterHandlerCurrentWriterGroupedByCompletionTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCompletionTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByCompletionTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByCost 

type WriterHandlerCurrentWriterGroupedByCost map[float64][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCost) Has 

func (index WriterHandlerCurrentWriterGroupedByCost) Has(key float64) bool

type WriterHandlerCurrentWriterGroupedByErrorCode 

type WriterHandlerCurrentWriterGroupedByErrorCode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorCode) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByErrorMessage 

type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByFinishReason 

type WriterHandlerCurrentWriterGroupedByFinishReason map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByFinishReason) Has 

func (index WriterHandlerCurrentWriterGroupedByFinishReason) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByIteration 

type WriterHandlerCurrentWriterGroupedByIteration map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByIteration) Has 

func (index WriterHandlerCurrentWriterGroupedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByLatencyMs 

type WriterHandlerCurrentWriterGroupedByLatencyMs map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLatencyMs) Has 

func (index WriterHandlerCurrentWriterGroupedByLatencyMs) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByMessageId 

type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMessageId) Has 

func (index WriterHandlerCurrentWriterGroupedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModel 

type WriterHandlerCurrentWriterGroupedByModel map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModel) Has 

func (index WriterHandlerCurrentWriterGroupedByModel) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByModelKind 

type WriterHandlerCurrentWriterGroupedByModelKind map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByModelKind) Has 

func (index WriterHandlerCurrentWriterGroupedByModelKind) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByPromptAudioTokens 

type WriterHandlerCurrentWriterGroupedByPromptAudioTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPromptAudioTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByPromptAudioTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByPromptCachedTokens 

type WriterHandlerCurrentWriterGroupedByPromptCachedTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPromptCachedTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByPromptCachedTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByPromptTokens 

type WriterHandlerCurrentWriterGroupedByPromptTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPromptTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByPromptTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByProvider 

type WriterHandlerCurrentWriterGroupedByProvider map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProvider) Has 

func (index WriterHandlerCurrentWriterGroupedByProvider) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProviderRequestPayloadId 

type WriterHandlerCurrentWriterGroupedByProviderRequestPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProviderRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByProviderRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByProviderResponsePayloadId 

type WriterHandlerCurrentWriterGroupedByProviderResponsePayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByProviderResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByProviderResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRequestPayloadId 

type WriterHandlerCurrentWriterGroupedByRequestPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByResponsePayloadId 

type WriterHandlerCurrentWriterGroupedByResponsePayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByRunId 

type WriterHandlerCurrentWriterGroupedByRunId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRunId) Has 

func (index WriterHandlerCurrentWriterGroupedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedBySpanId 

type WriterHandlerCurrentWriterGroupedBySpanId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySpanId) Has 

func (index WriterHandlerCurrentWriterGroupedBySpanId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStartedAt 

type WriterHandlerCurrentWriterGroupedByStartedAt map[time.Time][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStartedAt) Has 

func (index WriterHandlerCurrentWriterGroupedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterGroupedByStatus 

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has 

func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByStreamPayloadId 

type WriterHandlerCurrentWriterGroupedByStreamPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStreamPayloadId) Has 

func (index WriterHandlerCurrentWriterGroupedByStreamPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTotalTokens 

type WriterHandlerCurrentWriterGroupedByTotalTokens map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTotalTokens) Has 

func (index WriterHandlerCurrentWriterGroupedByTotalTokens) Has(key int) bool

type WriterHandlerCurrentWriterGroupedByTraceId 

type WriterHandlerCurrentWriterGroupedByTraceId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTraceId) Has 

func (index WriterHandlerCurrentWriterGroupedByTraceId) Has(key string) bool

type WriterHandlerCurrentWriterGroupedByTurnId 

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTurnId) Has 

func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByCompletedAt 

type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByCompletionAcceptedPredictionTokens 

type WriterHandlerCurrentWriterIndexedByCompletionAcceptedPredictionTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletionAcceptedPredictionTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletionAcceptedPredictionTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCompletionAudioTokens 

type WriterHandlerCurrentWriterIndexedByCompletionAudioTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletionAudioTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletionAudioTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCompletionReasoningTokens 

type WriterHandlerCurrentWriterIndexedByCompletionReasoningTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletionReasoningTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletionReasoningTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCompletionRejectedPredictionTokens 

type WriterHandlerCurrentWriterIndexedByCompletionRejectedPredictionTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletionRejectedPredictionTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletionRejectedPredictionTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCompletionTokens 

type WriterHandlerCurrentWriterIndexedByCompletionTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCompletionTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByCompletionTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByCost 

type WriterHandlerCurrentWriterIndexedByCost map[float64]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCost) Has 

func (index WriterHandlerCurrentWriterIndexedByCost) Has(key float64) bool

type WriterHandlerCurrentWriterIndexedByErrorCode 

type WriterHandlerCurrentWriterIndexedByErrorCode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorCode) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorCode) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByErrorMessage 

type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByErrorMessage) Has 

func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByFinishReason 

type WriterHandlerCurrentWriterIndexedByFinishReason map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByFinishReason) Has 

func (index WriterHandlerCurrentWriterIndexedByFinishReason) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByIteration 

type WriterHandlerCurrentWriterIndexedByIteration map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByIteration) Has 

func (index WriterHandlerCurrentWriterIndexedByIteration) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByLatencyMs 

type WriterHandlerCurrentWriterIndexedByLatencyMs map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLatencyMs) Has 

func (index WriterHandlerCurrentWriterIndexedByLatencyMs) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByMessageId 

type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMessageId) Has 

func (index WriterHandlerCurrentWriterIndexedByMessageId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModel 

type WriterHandlerCurrentWriterIndexedByModel map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModel) Has 

func (index WriterHandlerCurrentWriterIndexedByModel) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByModelKind 

type WriterHandlerCurrentWriterIndexedByModelKind map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByModelKind) Has 

func (index WriterHandlerCurrentWriterIndexedByModelKind) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByPromptAudioTokens 

type WriterHandlerCurrentWriterIndexedByPromptAudioTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPromptAudioTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByPromptAudioTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByPromptCachedTokens 

type WriterHandlerCurrentWriterIndexedByPromptCachedTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPromptCachedTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByPromptCachedTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByPromptTokens 

type WriterHandlerCurrentWriterIndexedByPromptTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPromptTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByPromptTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByProvider 

type WriterHandlerCurrentWriterIndexedByProvider map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProvider) Has 

func (index WriterHandlerCurrentWriterIndexedByProvider) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProviderRequestPayloadId 

type WriterHandlerCurrentWriterIndexedByProviderRequestPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProviderRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByProviderRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByProviderResponsePayloadId 

type WriterHandlerCurrentWriterIndexedByProviderResponsePayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByProviderResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByProviderResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRequestPayloadId 

type WriterHandlerCurrentWriterIndexedByRequestPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRequestPayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByRequestPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByResponsePayloadId 

type WriterHandlerCurrentWriterIndexedByResponsePayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByResponsePayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByResponsePayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByRunId 

type WriterHandlerCurrentWriterIndexedByRunId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRunId) Has 

func (index WriterHandlerCurrentWriterIndexedByRunId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedBySpanId 

type WriterHandlerCurrentWriterIndexedBySpanId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySpanId) Has 

func (index WriterHandlerCurrentWriterIndexedBySpanId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStartedAt 

type WriterHandlerCurrentWriterIndexedByStartedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStartedAt) Has 

func (index WriterHandlerCurrentWriterIndexedByStartedAt) Has(key time.Time) bool

type WriterHandlerCurrentWriterIndexedByStatus 

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has 

func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByStreamPayloadId 

type WriterHandlerCurrentWriterIndexedByStreamPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStreamPayloadId) Has 

func (index WriterHandlerCurrentWriterIndexedByStreamPayloadId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTotalTokens 

type WriterHandlerCurrentWriterIndexedByTotalTokens map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTotalTokens) Has 

func (index WriterHandlerCurrentWriterIndexedByTotalTokens) Has(key int) bool

type WriterHandlerCurrentWriterIndexedByTraceId 

type WriterHandlerCurrentWriterIndexedByTraceId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTraceId) Has 

func (index WriterHandlerCurrentWriterIndexedByTraceId) Has(key string) bool

type WriterHandlerCurrentWriterIndexedByTurnId 

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTurnId) Has 

func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool

type WriterHandlerCurrentWriterSlice 

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt

func (WriterHandlerCurrentWriterSlice) GroupByCompletionAcceptedPredictionTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletionAcceptedPredictionTokens() WriterHandlerCurrentWriterGroupedByCompletionAcceptedPredictionTokens

func (WriterHandlerCurrentWriterSlice) GroupByCompletionAudioTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletionAudioTokens() WriterHandlerCurrentWriterGroupedByCompletionAudioTokens

func (WriterHandlerCurrentWriterSlice) GroupByCompletionReasoningTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletionReasoningTokens() WriterHandlerCurrentWriterGroupedByCompletionReasoningTokens

func (WriterHandlerCurrentWriterSlice) GroupByCompletionRejectedPredictionTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletionRejectedPredictionTokens() WriterHandlerCurrentWriterGroupedByCompletionRejectedPredictionTokens

func (WriterHandlerCurrentWriterSlice) GroupByCompletionTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByCompletionTokens() WriterHandlerCurrentWriterGroupedByCompletionTokens

func (WriterHandlerCurrentWriterSlice) GroupByCost 

func (rows WriterHandlerCurrentWriterSlice) GroupByCost() WriterHandlerCurrentWriterGroupedByCost

func (WriterHandlerCurrentWriterSlice) GroupByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorCode() WriterHandlerCurrentWriterGroupedByErrorCode

func (WriterHandlerCurrentWriterSlice) GroupByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage

func (WriterHandlerCurrentWriterSlice) GroupByFinishReason 

func (rows WriterHandlerCurrentWriterSlice) GroupByFinishReason() WriterHandlerCurrentWriterGroupedByFinishReason

func (WriterHandlerCurrentWriterSlice) GroupByIteration 

func (rows WriterHandlerCurrentWriterSlice) GroupByIteration() WriterHandlerCurrentWriterGroupedByIteration

func (WriterHandlerCurrentWriterSlice) GroupByLatencyMs 

func (rows WriterHandlerCurrentWriterSlice) GroupByLatencyMs() WriterHandlerCurrentWriterGroupedByLatencyMs

func (WriterHandlerCurrentWriterSlice) GroupByMessageId 

func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId

func (WriterHandlerCurrentWriterSlice) GroupByModel 

func (rows WriterHandlerCurrentWriterSlice) GroupByModel() WriterHandlerCurrentWriterGroupedByModel

func (WriterHandlerCurrentWriterSlice) GroupByModelKind 

func (rows WriterHandlerCurrentWriterSlice) GroupByModelKind() WriterHandlerCurrentWriterGroupedByModelKind

func (WriterHandlerCurrentWriterSlice) GroupByPromptAudioTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByPromptAudioTokens() WriterHandlerCurrentWriterGroupedByPromptAudioTokens

func (WriterHandlerCurrentWriterSlice) GroupByPromptCachedTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByPromptCachedTokens() WriterHandlerCurrentWriterGroupedByPromptCachedTokens

func (WriterHandlerCurrentWriterSlice) GroupByPromptTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByPromptTokens() WriterHandlerCurrentWriterGroupedByPromptTokens

func (WriterHandlerCurrentWriterSlice) GroupByProvider 

func (rows WriterHandlerCurrentWriterSlice) GroupByProvider() WriterHandlerCurrentWriterGroupedByProvider

func (WriterHandlerCurrentWriterSlice) GroupByProviderRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProviderRequestPayloadId() WriterHandlerCurrentWriterGroupedByProviderRequestPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByProviderResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByProviderResponsePayloadId() WriterHandlerCurrentWriterGroupedByProviderResponsePayloadId

func (WriterHandlerCurrentWriterSlice) GroupByRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRequestPayloadId() WriterHandlerCurrentWriterGroupedByRequestPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByResponsePayloadId() WriterHandlerCurrentWriterGroupedByResponsePayloadId

func (WriterHandlerCurrentWriterSlice) GroupByRunId 

func (rows WriterHandlerCurrentWriterSlice) GroupByRunId() WriterHandlerCurrentWriterGroupedByRunId

func (WriterHandlerCurrentWriterSlice) GroupBySpanId 

func (rows WriterHandlerCurrentWriterSlice) GroupBySpanId() WriterHandlerCurrentWriterGroupedBySpanId

func (WriterHandlerCurrentWriterSlice) GroupByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) GroupByStartedAt() WriterHandlerCurrentWriterGroupedByStartedAt

func (WriterHandlerCurrentWriterSlice) GroupByStatus 

func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus

func (WriterHandlerCurrentWriterSlice) GroupByStreamPayloadId 

func (rows WriterHandlerCurrentWriterSlice) GroupByStreamPayloadId() WriterHandlerCurrentWriterGroupedByStreamPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByTotalTokens 

func (rows WriterHandlerCurrentWriterSlice) GroupByTotalTokens() WriterHandlerCurrentWriterGroupedByTotalTokens

func (WriterHandlerCurrentWriterSlice) GroupByTraceId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTraceId() WriterHandlerCurrentWriterGroupedByTraceId

func (WriterHandlerCurrentWriterSlice) GroupByTurnId 

func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId

func (WriterHandlerCurrentWriterSlice) IndexByCompletedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletedAt() (WriterHandlerCurrentWriterIndexedByCompletedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletionAcceptedPredictionTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletionAcceptedPredictionTokens() (WriterHandlerCurrentWriterIndexedByCompletionAcceptedPredictionTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletionAudioTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletionAudioTokens() (WriterHandlerCurrentWriterIndexedByCompletionAudioTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletionReasoningTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletionReasoningTokens() (WriterHandlerCurrentWriterIndexedByCompletionReasoningTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletionRejectedPredictionTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletionRejectedPredictionTokens() (WriterHandlerCurrentWriterIndexedByCompletionRejectedPredictionTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByCompletionTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByCompletionTokens() (WriterHandlerCurrentWriterIndexedByCompletionTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByCost 

func (rows WriterHandlerCurrentWriterSlice) IndexByCost() (WriterHandlerCurrentWriterIndexedByCost, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorCode 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorCode() (WriterHandlerCurrentWriterIndexedByErrorCode, error)

func (WriterHandlerCurrentWriterSlice) IndexByErrorMessage 

func (rows WriterHandlerCurrentWriterSlice) IndexByErrorMessage() (WriterHandlerCurrentWriterIndexedByErrorMessage, error)

func (WriterHandlerCurrentWriterSlice) IndexByFinishReason 

func (rows WriterHandlerCurrentWriterSlice) IndexByFinishReason() (WriterHandlerCurrentWriterIndexedByFinishReason, error)

func (WriterHandlerCurrentWriterSlice) IndexByIteration 

func (rows WriterHandlerCurrentWriterSlice) IndexByIteration() (WriterHandlerCurrentWriterIndexedByIteration, error)

func (WriterHandlerCurrentWriterSlice) IndexByLatencyMs 

func (rows WriterHandlerCurrentWriterSlice) IndexByLatencyMs() (WriterHandlerCurrentWriterIndexedByLatencyMs, error)

func (WriterHandlerCurrentWriterSlice) IndexByMessageId 

func (rows WriterHandlerCurrentWriterSlice) IndexByMessageId() (WriterHandlerCurrentWriterIndexedByMessageId, error)

func (WriterHandlerCurrentWriterSlice) IndexByModel 

func (rows WriterHandlerCurrentWriterSlice) IndexByModel() (WriterHandlerCurrentWriterIndexedByModel, error)

func (WriterHandlerCurrentWriterSlice) IndexByModelKind 

func (rows WriterHandlerCurrentWriterSlice) IndexByModelKind() (WriterHandlerCurrentWriterIndexedByModelKind, error)

func (WriterHandlerCurrentWriterSlice) IndexByPromptAudioTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByPromptAudioTokens() (WriterHandlerCurrentWriterIndexedByPromptAudioTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByPromptCachedTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByPromptCachedTokens() (WriterHandlerCurrentWriterIndexedByPromptCachedTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByPromptTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByPromptTokens() (WriterHandlerCurrentWriterIndexedByPromptTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByProvider 

func (rows WriterHandlerCurrentWriterSlice) IndexByProvider() (WriterHandlerCurrentWriterIndexedByProvider, error)

func (WriterHandlerCurrentWriterSlice) IndexByProviderRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProviderRequestPayloadId() (WriterHandlerCurrentWriterIndexedByProviderRequestPayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByProviderResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByProviderResponsePayloadId() (WriterHandlerCurrentWriterIndexedByProviderResponsePayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRequestPayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByRequestPayloadId() (WriterHandlerCurrentWriterIndexedByRequestPayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByResponsePayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByResponsePayloadId() (WriterHandlerCurrentWriterIndexedByResponsePayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByRunId 

func (rows WriterHandlerCurrentWriterSlice) IndexByRunId() (WriterHandlerCurrentWriterIndexedByRunId, error)

func (WriterHandlerCurrentWriterSlice) IndexBySpanId 

func (rows WriterHandlerCurrentWriterSlice) IndexBySpanId() (WriterHandlerCurrentWriterIndexedBySpanId, error)

func (WriterHandlerCurrentWriterSlice) IndexByStartedAt 

func (rows WriterHandlerCurrentWriterSlice) IndexByStartedAt() (WriterHandlerCurrentWriterIndexedByStartedAt, error)

func (WriterHandlerCurrentWriterSlice) IndexByStatus 

func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)

func (WriterHandlerCurrentWriterSlice) IndexByStreamPayloadId 

func (rows WriterHandlerCurrentWriterSlice) IndexByStreamPayloadId() (WriterHandlerCurrentWriterIndexedByStreamPayloadId, error)

func (WriterHandlerCurrentWriterSlice) IndexByTotalTokens 

func (rows WriterHandlerCurrentWriterSlice) IndexByTotalTokens() (WriterHandlerCurrentWriterIndexedByTotalTokens, error)

func (WriterHandlerCurrentWriterSlice) IndexByTraceId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTraceId() (WriterHandlerCurrentWriterIndexedByTraceId, error)

func (WriterHandlerCurrentWriterSlice) IndexByTurnId 

func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error)

type WriterHandlerReadIndexes 

type WriterHandlerReadIndexes struct {
	CurrentWriter            WriterHandlerCurrentWriterSlice
	CurrentWriterByMessageId WriterHandlerCurrentWriterIndexedByMessageId
}

func BuildWriterHandlerReadIndexes 

func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)

type WriterKeysRow 

type WriterKeysRow struct {
	MessageId string `sqlx:"message_id"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.