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

read

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: 10 Imported by: 0

Documentation

Index

Constants

View Source
const ReaderDatlyResourceNamespace = "datly_message_read_reader"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source
var ReaderDatly = new(ReaderComponent)

The public value supports explicit component wiring.

View Source
var ReaderDatlyResources embed.FS

Functions

func ReaderDatlyType

func ReaderDatlyType() reflect.Type

ReaderDatlyType returns the public component type.

Types

type AttachmentView

type AttachmentView struct {
	InlineBody      *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Compression     string   `sqlx:"compression" json:"compression"`
	MimeType        string   `sqlx:"mime_type" json:"mimeType"`
	Uri             *string  `sqlx:"uri" json:"uri"`
	ParentMessageId *string  `sqlx:"parent_message_id" json:"parentMessageId"`
}

AttachmentView is generated canonical view metadata for reader.

type LinkedConversationView

type LinkedConversationView struct {
	Id        string     `sqlx:"id,primaryKey=true" json:"id"`
	CreatedAt time.Time  `sqlx:"created_at,required=true" json:"createdAt"`
	Status    *string    `sqlx:"status" json:"status"`
	UpdatedAt *time.Time `sqlx:"updated_at" json:"updatedAt"`
}

LinkedConversationView is generated canonical view metadata for reader.

type MessageRequest

type MessageRequest struct {
	ConversationId        string             `` /* 152-byte string literal not displayed */
	ConversationIds       []string           `` /* 154-byte string literal not displayed */
	TurnId                string             `parameter:"TurnId,kind=query,in=turnId,dataType=string,required=false" predicate:"equal,group=4,m,turn_id" json:"turnId"`
	Id                    string             `parameter:"Id,kind=query,in=id,dataType=string,required=false" predicate:"equal,group=4,m,id" json:"id"`
	Roles                 []string           `parameter:"Roles,kind=query,in=roles,dataType=[]string,required=false" predicate:"in,group=4,m,role" json:"roles"`
	Types                 []string           `parameter:"Types,kind=query,in=types,dataType=[]string,required=false" predicate:"in,group=4,m,type" json:"types"`
	Interim               int                `parameter:"Interim,kind=query,in=interim,dataType=int,required=false" predicate:"equal,group=4,m,interim" json:"interim"`
	Phase                 string             `parameter:"Phase,kind=query,in=phase,dataType=string,required=false" predicate:"equal,group=4,m,phase" json:"phase"`
	Iteration             int                `` /* 128-byte string literal not displayed */
	CreatedSince          time.Time          `` /* 155-byte string literal not displayed */
	CreatedBefore         time.Time          `` /* 155-byte string literal not displayed */
	CursorBefore          string             `` /* 260-byte string literal not displayed */
	CursorAfter           string             `` /* 257-byte string literal not displayed */
	TurnTask              bool               `` /* 187-byte string literal not displayed */
	AssistantFinal        bool               `` /* 211-byte string literal not displayed */
	AssistantStatus       bool               `` /* 215-byte string literal not displayed */
	IncludeModelCal       bool               `` /* 149-byte string literal not displayed */
	IncludeToolCall       bool               `` /* 148-byte string literal not displayed */
	ElicitationId         string             `` /* 148-byte string literal not displayed */
	LinkedConversationId  string             `` /* 177-byte string literal not displayed */
	LinkedConversationIds []string           `` /* 179-byte string literal not displayed */
	ParentMessageId       string             `` /* 157-byte string literal not displayed */
	Fields                []string           `` /* 146-byte string literal not displayed */
	Limit                 int                `` /* 137-byte string literal not displayed */
	Offset                int                `` /* 141-byte string literal not displayed */
	OrderBy               string             `` /* 148-byte string literal not displayed */
	ParentMessageIds      []string           `` /* 159-byte string literal not displayed */
	SupersededByIds       []string           `` /* 152-byte string literal not displayed */
	Has                   *MessageRequestHas `setMarker:"true" typeName:"MessageRequestHas" json:"-" sqlx:"-"`
}

MessageRequest is the public transport input projection of reader.

func (*MessageRequest) SetAssistantFinal

func (input *MessageRequest) SetAssistantFinal(value bool)

func (*MessageRequest) SetAssistantStatus

func (input *MessageRequest) SetAssistantStatus(value bool)

func (*MessageRequest) SetConversationId

func (input *MessageRequest) SetConversationId(value string)

func (*MessageRequest) SetConversationIds

func (input *MessageRequest) SetConversationIds(value []string)

func (*MessageRequest) SetCreatedBefore

func (input *MessageRequest) SetCreatedBefore(value time.Time)

func (*MessageRequest) SetCreatedSince

func (input *MessageRequest) SetCreatedSince(value time.Time)

func (*MessageRequest) SetCursorAfter

func (input *MessageRequest) SetCursorAfter(value string)

func (*MessageRequest) SetCursorBefore

func (input *MessageRequest) SetCursorBefore(value string)

func (*MessageRequest) SetElicitationId

func (input *MessageRequest) SetElicitationId(value string)

func (*MessageRequest) SetFields

func (input *MessageRequest) SetFields(value []string)

func (*MessageRequest) SetId

func (input *MessageRequest) SetId(value string)

func (*MessageRequest) SetIncludeModelCal

func (input *MessageRequest) SetIncludeModelCal(value bool)

func (*MessageRequest) SetIncludeToolCall

func (input *MessageRequest) SetIncludeToolCall(value bool)

func (*MessageRequest) SetInterim

func (input *MessageRequest) SetInterim(value int)

func (*MessageRequest) SetIteration

func (input *MessageRequest) SetIteration(value int)

func (*MessageRequest) SetLimit

func (input *MessageRequest) SetLimit(value int)

func (*MessageRequest) SetLinkedConversationId

func (input *MessageRequest) SetLinkedConversationId(value string)

func (*MessageRequest) SetLinkedConversationIds

func (input *MessageRequest) SetLinkedConversationIds(value []string)

func (*MessageRequest) SetOffset

func (input *MessageRequest) SetOffset(value int)

func (*MessageRequest) SetOrderBy

func (input *MessageRequest) SetOrderBy(value string)

func (*MessageRequest) SetParentMessageId

func (input *MessageRequest) SetParentMessageId(value string)

func (*MessageRequest) SetParentMessageIds

func (input *MessageRequest) SetParentMessageIds(value []string)

func (*MessageRequest) SetPhase

func (input *MessageRequest) SetPhase(value string)

func (*MessageRequest) SetRoles

func (input *MessageRequest) SetRoles(value []string)

func (*MessageRequest) SetSupersededByIds

func (input *MessageRequest) SetSupersededByIds(value []string)

func (*MessageRequest) SetTurnId

func (input *MessageRequest) SetTurnId(value string)

func (*MessageRequest) SetTurnTask

func (input *MessageRequest) SetTurnTask(value bool)

func (*MessageRequest) SetTypes

func (input *MessageRequest) SetTypes(value []string)

type MessageRequestHas

type MessageRequestHas struct {
	ConversationId        bool
	ConversationIds       bool
	TurnId                bool
	Id                    bool
	Roles                 bool
	Types                 bool
	Interim               bool
	Phase                 bool
	Iteration             bool
	CreatedSince          bool
	CreatedBefore         bool
	CursorBefore          bool
	CursorAfter           bool
	TurnTask              bool
	AssistantFinal        bool
	AssistantStatus       bool
	IncludeModelCal       bool
	IncludeToolCall       bool
	ElicitationId         bool
	LinkedConversationId  bool
	LinkedConversationIds bool
	ParentMessageId       bool
	Fields                bool
	Limit                 bool
	Offset                bool
	OrderBy               bool
	ParentMessageIds      bool
	SupersededByIds       bool
}

type MessageRequestPayloadView

type MessageRequestPayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

MessageRequestPayloadView is generated canonical view metadata for reader.

type MessageResponsePayloadView

type MessageResponsePayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

MessageResponsePayloadView is generated canonical view metadata for reader.

type MessageToolCallView

type MessageToolCallView struct {
	MessageId              string                      `sqlx:"message_id,refTable=message,refColumn=id,primaryKey=true" json:"messageId"`
	OpId                   string                      `sqlx:"op_id,required=true" json:"opId"`
	Attempt                int                         `sqlx:"attempt,required=true" json:"attempt"`
	ToolName               string                      `sqlx:"tool_name,required=true" json:"toolName"`
	ToolKind               string                      `sqlx:"tool_kind,required=true" json:"toolKind"`
	Status                 string                      `sqlx:"status,required=true" json:"status"`
	TurnId                 *string                     `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId"`
	RequestHash            *string                     `sqlx:"request_hash" json:"requestHash"`
	ErrorCode              *string                     `sqlx:"error_code" json:"errorCode"`
	ErrorMessage           *string                     `sqlx:"error_message" json:"errorMessage"`
	Retriable              *int                        `sqlx:"retriable" json:"retriable"`
	StartedAt              *time.Time                  `sqlx:"started_at" json:"startedAt"`
	CompletedAt            *time.Time                  `sqlx:"completed_at" json:"completedAt"`
	LatencyMs              *int                        `sqlx:"latency_ms" json:"latencyMs"`
	Cost                   *float64                    `sqlx:"cost" json:"cost"`
	TraceId                *string                     `sqlx:"trace_id" json:"traceId"`
	SpanId                 *string                     `sqlx:"span_id" json:"spanId"`
	RequestPayloadId       *string                     `sqlx:"request_payload_id,refTable=call_payload,refColumn=id" json:"requestPayloadId"`
	ResponsePayloadId      *string                     `sqlx:"response_payload_id,refTable=call_payload,refColumn=id" json:"responsePayloadId"`
	RunId                  *string                     `sqlx:"run_id" json:"runId"`
	Iteration              *int                        `sqlx:"iteration" json:"iteration"`
	MessageSequence        *int                        `sqlx:"message_sequence" json:"messageSequence"`
	MessageRequestPayload  *MessageRequestPayloadView  `` /* 260-byte string literal not displayed */
	MessageResponsePayload *MessageResponsePayloadView `` /* 267-byte string literal not displayed */
}

MessageToolCallView is generated canonical view metadata for reader.

type MessageView

type MessageView struct {
	CleanupStatus          string                   `internal:"true" json:"-" sqlx:"cleanup_status"`
	ReadMode               string                   `json:"-" sqlx:"read_mode"`
	ElicitationBody        []byte                   `json:"-" sqlx:"elicitation_body"`
	ElicitationCompression string                   `json:"-" sqlx:"elicitation_compression"`
	Elicitation            codec.JSON               `sqlx:"elicitation" json:"elicitation"`
	ConversationId         string                   `sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true" json:"conversationId"`
	CreatedAt              time.Time                `sqlx:"created_at,required=true" json:"createdAt"`
	Id                     string                   `sqlx:"id,primaryKey=true" json:"id"`
	Interim                int                      `sqlx:"interim,required=true" json:"interim"`
	Role                   string                   `sqlx:"role,required=true" json:"role"`
	Type                   string                   `sqlx:"type,required=true" json:"type"`
	Narration              *string                  `sqlx:"preamble" json:"narration"`
	TurnId                 *string                  `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId"`
	Archived               *int                     `sqlx:"archived" json:"archived"`
	Sequence               *int                     `sqlx:"sequence" json:"sequence"`
	UpdatedAt              *time.Time               `sqlx:"updated_at" json:"updatedAt"`
	CreatedByUserId        *string                  `sqlx:"created_by_user_id" json:"createdByUserId"`
	Status                 *string                  `sqlx:"status" json:"status"`
	Mode                   *string                  `sqlx:"mode" json:"mode"`
	Content                *string                  `sqlx:"content" json:"content"`
	RawContent             *string                  `sqlx:"raw_content" json:"rawContent"`
	Summary                *string                  `sqlx:"summary" json:"summary"`
	ContextSummary         *string                  `sqlx:"context_summary" json:"contextSummary"`
	Tags                   *string                  `sqlx:"tags" json:"tags"`
	ElicitationId          *string                  `sqlx:"elicitation_id" json:"elicitationId"`
	ParentMessageId        *string                  `sqlx:"parent_message_id" json:"parentMessageId"`
	SupersededBy           *string                  `sqlx:"superseded_by" json:"supersededBy"`
	LinkedConversationId   *string                  `sqlx:"linked_conversation_id" json:"linkedConversationId"`
	AttachmentPayloadId    *string                  `sqlx:"attachment_payload_id,refTable=call_payload,refColumn=id" json:"attachmentPayloadId"`
	ElicitationPayloadId   *string                  `sqlx:"elicitation_payload_id,refTable=call_payload,refColumn=id" json:"elicitationPayloadId"`
	ToolName               *string                  `sqlx:"tool_name" json:"toolName"`
	EmbeddingIndex         *string                  `sqlx:"embedding_index" json:"embeddingIndex"`
	Iteration              *int                     `sqlx:"iteration" json:"iteration"`
	Phase                  *string                  `sqlx:"phase" json:"phase"`
	MessageToolCall        *MessageToolCallView     `` /* 206-byte string literal not displayed */
	ToolMessage            []*ToolMessageView       `` /* 196-byte string literal not displayed */
	UserElicitationData    *UserElicitationDataView `` /* 224-byte string literal not displayed */
	LinkedConversation     *LinkedConversationView  `` /* 246-byte string literal not displayed */
	Attachment             []*AttachmentView        `` /* 190-byte string literal not displayed */
	ModelCall              *ModelCallView           `` /* 176-byte string literal not displayed */
}

MessageView is generated canonical view metadata for reader.

func (*MessageView) OnFetch

func (m *MessageView) OnFetch(ctx context.Context) error

type MessagesInput

type MessagesInput struct {
	ConversationId        string            `` /* 130-byte string literal not displayed */
	ConversationIds       []string          `` /* 131-byte string literal not displayed */
	TurnId                string            `parameter:"TurnId,kind=query,in=turnId,dataType=string,required=false" predicate:"equal,group=4,m,turn_id"`
	Id                    string            `parameter:"Id,kind=query,in=id,dataType=string,required=false" predicate:"equal,group=4,m,id"`
	Roles                 []string          `parameter:"Roles,kind=query,in=roles,dataType=[]string,required=false" predicate:"in,group=4,m,role"`
	Types                 []string          `parameter:"Types,kind=query,in=types,dataType=[]string,required=false" predicate:"in,group=4,m,type"`
	Interim               int               `parameter:"Interim,kind=query,in=interim,dataType=int,required=false" predicate:"equal,group=4,m,interim"`
	Phase                 string            `parameter:"Phase,kind=query,in=phase,dataType=string,required=false" predicate:"equal,group=4,m,phase"`
	Iteration             int               `parameter:"Iteration,kind=query,in=iteration,dataType=int,required=false" predicate:"equal,group=4,m,iteration"`
	CreatedSince          time.Time         `` /* 135-byte string literal not displayed */
	CreatedBefore         time.Time         `` /* 134-byte string literal not displayed */
	CursorBefore          string            `` /* 240-byte string literal not displayed */
	CursorAfter           string            `` /* 238-byte string literal not displayed */
	TurnTask              bool              `` /* 171-byte string literal not displayed */
	AssistantFinal        bool              `` /* 189-byte string literal not displayed */
	AssistantStatus       bool              `` /* 192-byte string literal not displayed */
	IncludeModelCal       bool              `` /* 126-byte string literal not displayed */
	IncludeToolCall       bool              `parameter:"IncludeToolCall,kind=query,in=includeToolCall,dataType=bool,value=false,required=false" predicate:"expr,group=3,?"`
	Internal              bool              `parameter:"Internal,kind=messageaccess,in=internal,dataType=bool,required=true"`
	ReadMode              string            `parameter:"ReadMode,kind=messageaccess,in=mode,dataType=string,required=true"`
	VisibilitySubject     *string           `parameter:"VisibilitySubject,kind=visibility,in=subject,dataType=*string,required=true"`
	ElicitationId         string            `` /* 127-byte string literal not displayed */
	LinkedConversationId  string            `` /* 149-byte string literal not displayed */
	LinkedConversationIds []string          `` /* 150-byte string literal not displayed */
	ParentMessageId       string            `` /* 134-byte string literal not displayed */
	Fields                []string          `` /* 132-byte string literal not displayed */
	Limit                 int               `parameter:"Limit,kind=query,in=limit,dataType=int,required=false,cacheable=false" querySelector:"view=reader,property=limit"`
	Offset                int               `` /* 127-byte string literal not displayed */
	OrderBy               string            `` /* 133-byte string literal not displayed */
	ParentMessageIds      []string          `` /* 135-byte string literal not displayed */
	SupersededByIds       []string          `` /* 129-byte string literal not displayed */
	Has                   *MessagesInputHas `setMarker:"true" typeName:"MessagesInputHas" json:"-" sqlx:"-"`
}

MessagesInput is the generated input scaffold for reader.

func (*MessagesInput) Init

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

func (*MessagesInput) SetAssistantFinal

func (input *MessagesInput) SetAssistantFinal(value bool)

func (*MessagesInput) SetAssistantStatus

func (input *MessagesInput) SetAssistantStatus(value bool)

func (*MessagesInput) SetConversationId

func (input *MessagesInput) SetConversationId(value string)

func (*MessagesInput) SetConversationIds

func (input *MessagesInput) SetConversationIds(value []string)

func (*MessagesInput) SetCreatedBefore

func (input *MessagesInput) SetCreatedBefore(value time.Time)

func (*MessagesInput) SetCreatedSince

func (input *MessagesInput) SetCreatedSince(value time.Time)

func (*MessagesInput) SetCursorAfter

func (input *MessagesInput) SetCursorAfter(value string)

func (*MessagesInput) SetCursorBefore

func (input *MessagesInput) SetCursorBefore(value string)

func (*MessagesInput) SetElicitationId

func (input *MessagesInput) SetElicitationId(value string)

func (*MessagesInput) SetFields

func (input *MessagesInput) SetFields(value []string)

func (*MessagesInput) SetId

func (input *MessagesInput) SetId(value string)

func (*MessagesInput) SetIncludeModelCal

func (input *MessagesInput) SetIncludeModelCal(value bool)

func (*MessagesInput) SetIncludeToolCall

func (input *MessagesInput) SetIncludeToolCall(value bool)

func (*MessagesInput) SetInterim

func (input *MessagesInput) SetInterim(value int)

func (*MessagesInput) SetInternal

func (input *MessagesInput) SetInternal(value bool)

func (*MessagesInput) SetIteration

func (input *MessagesInput) SetIteration(value int)

func (*MessagesInput) SetLimit

func (input *MessagesInput) SetLimit(value int)

func (*MessagesInput) SetLinkedConversationId

func (input *MessagesInput) SetLinkedConversationId(value string)

func (*MessagesInput) SetLinkedConversationIds

func (input *MessagesInput) SetLinkedConversationIds(value []string)

func (*MessagesInput) SetOffset

func (input *MessagesInput) SetOffset(value int)

func (*MessagesInput) SetOrderBy

func (input *MessagesInput) SetOrderBy(value string)

func (*MessagesInput) SetParentMessageId

func (input *MessagesInput) SetParentMessageId(value string)

func (*MessagesInput) SetParentMessageIds

func (input *MessagesInput) SetParentMessageIds(value []string)

func (*MessagesInput) SetPhase

func (input *MessagesInput) SetPhase(value string)

func (*MessagesInput) SetReadMode

func (input *MessagesInput) SetReadMode(value string)

func (*MessagesInput) SetRoles

func (input *MessagesInput) SetRoles(value []string)

func (*MessagesInput) SetSupersededByIds

func (input *MessagesInput) SetSupersededByIds(value []string)

func (*MessagesInput) SetTurnId

func (input *MessagesInput) SetTurnId(value string)

func (*MessagesInput) SetTurnTask

func (input *MessagesInput) SetTurnTask(value bool)

func (*MessagesInput) SetTypes

func (input *MessagesInput) SetTypes(value []string)

func (*MessagesInput) SetVisibilitySubject

func (input *MessagesInput) SetVisibilitySubject(value *string)

type MessagesInputHas

type MessagesInputHas struct {
	ConversationId        bool
	ConversationIds       bool
	TurnId                bool
	Id                    bool
	Roles                 bool
	Types                 bool
	Interim               bool
	Phase                 bool
	Iteration             bool
	CreatedSince          bool
	CreatedBefore         bool
	CursorBefore          bool
	CursorAfter           bool
	TurnTask              bool
	AssistantFinal        bool
	AssistantStatus       bool
	IncludeModelCal       bool
	IncludeToolCall       bool
	Internal              bool
	ReadMode              bool
	VisibilitySubject     bool
	ElicitationId         bool
	LinkedConversationId  bool
	LinkedConversationIds bool
	ParentMessageId       bool
	Fields                bool
	Limit                 bool
	Offset                bool
	OrderBy               bool
	ParentMessageIds      bool
	SupersededByIds       bool
}

type MessagesOutput

type MessagesOutput struct {
	Data []*MessageView `` /* 288-byte string literal not displayed */
}

MessagesOutput is the generated output scaffold for reader.

type ModelCallProviderRequestPayloadView

type ModelCallProviderRequestPayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ModelCallProviderRequestPayloadView is generated canonical view metadata for reader.

type ModelCallProviderResponsePayloadView

type ModelCallProviderResponsePayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ModelCallProviderResponsePayloadView is generated canonical view metadata for reader.

type ModelCallRequestPayloadView

type ModelCallRequestPayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ModelCallRequestPayloadView is generated canonical view metadata for reader.

type ModelCallResponsePayloadView

type ModelCallResponsePayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ModelCallResponsePayloadView is generated canonical view metadata for reader.

type ModelCallStreamPayloadView

type ModelCallStreamPayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ModelCallStreamPayloadView is generated canonical view metadata for reader.

type ModelCallView

type ModelCallView struct {
	MessageId                          string                                `sqlx:"message_id,refTable=message,refColumn=id,primaryKey=true" json:"messageId"`
	Model                              string                                `sqlx:"model,required=true" json:"model"`
	ModelKind                          string                                `sqlx:"model_kind,required=true" json:"modelKind"`
	Provider                           string                                `sqlx:"provider,required=true" json:"provider"`
	Status                             string                                `sqlx:"status,required=true" json:"status"`
	TurnId                             *string                               `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId"`
	ErrorCode                          *string                               `sqlx:"error_code" json:"errorCode"`
	ErrorMessage                       *string                               `sqlx:"error_message" json:"errorMessage"`
	FinishReason                       *string                               `sqlx:"finish_reason" json:"finishReason"`
	PromptTokens                       *int                                  `sqlx:"prompt_tokens" json:"promptTokens"`
	PromptCachedTokens                 *int                                  `sqlx:"prompt_cached_tokens" json:"promptCachedTokens"`
	CompletionTokens                   *int                                  `sqlx:"completion_tokens" json:"completionTokens"`
	TotalTokens                        *int                                  `sqlx:"total_tokens" json:"totalTokens"`
	PromptAudioTokens                  *int                                  `sqlx:"prompt_audio_tokens" json:"promptAudioTokens"`
	CompletionReasoningTokens          *int                                  `sqlx:"completion_reasoning_tokens" json:"completionReasoningTokens"`
	CompletionAudioTokens              *int                                  `sqlx:"completion_audio_tokens" json:"completionAudioTokens"`
	CompletionAcceptedPredictionTokens *int                                  `sqlx:"completion_accepted_prediction_tokens" json:"completionAcceptedPredictionTokens"`
	CompletionRejectedPredictionTokens *int                                  `sqlx:"completion_rejected_prediction_tokens" json:"completionRejectedPredictionTokens"`
	StartedAt                          *time.Time                            `sqlx:"started_at" json:"startedAt"`
	CompletedAt                        *time.Time                            `sqlx:"completed_at" json:"completedAt"`
	LatencyMs                          *int                                  `sqlx:"latency_ms" json:"latencyMs"`
	Cost                               *float64                              `sqlx:"cost" json:"cost"`
	TraceId                            *string                               `sqlx:"trace_id" json:"traceId"`
	SpanId                             *string                               `sqlx:"span_id" json:"spanId"`
	RequestPayloadId                   *string                               `sqlx:"request_payload_id,refTable=call_payload,refColumn=id" json:"requestPayloadId"`
	ResponsePayloadId                  *string                               `sqlx:"response_payload_id,refTable=call_payload,refColumn=id" json:"responsePayloadId"`
	ProviderRequestPayloadId           *string                               `sqlx:"provider_request_payload_id,refTable=call_payload,refColumn=id" json:"providerRequestPayloadId"`
	ProviderResponsePayloadId          *string                               `sqlx:"provider_response_payload_id,refTable=call_payload,refColumn=id" json:"providerResponsePayloadId"`
	StreamPayloadId                    *string                               `sqlx:"stream_payload_id,refTable=call_payload,refColumn=id" json:"streamPayloadId"`
	RunId                              *string                               `sqlx:"run_id" json:"runId"`
	Iteration                          *int                                  `sqlx:"iteration" json:"iteration"`
	ModelCallRequestPayload            *ModelCallRequestPayloadView          `` /* 265-byte string literal not displayed */
	ModelCallProviderRequestPayload    *ModelCallProviderRequestPayloadView  `` /* 323-byte string literal not displayed */
	ModelCallResponsePayload           *ModelCallResponsePayloadView         `` /* 272-byte string literal not displayed */
	ModelCallProviderResponsePayload   *ModelCallProviderResponsePayloadView `` /* 330-byte string literal not displayed */
	ToolCallLinks                      []*ToolCallLinksView                  `` /* 203-byte string literal not displayed */
	ModelCallStreamPayload             *ModelCallStreamPayloadView           `` /* 258-byte string literal not displayed */
}

ModelCallView is generated canonical view metadata for reader.

type ReaderComponent

type ReaderComponent struct {
	Contract xdatly.Component[MessagesInput, MessagesOutput] "" /* 148-byte string literal not displayed */
}

Component is the generated component scaffold for reader.

func (ReaderComponent) EmbedFS

func (ReaderComponent) EmbedFS() *embed.FS

func (ReaderComponent) EmbedNamespace

func (ReaderComponent) EmbedNamespace() string

type RequestPayloadView

type RequestPayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

RequestPayloadView is generated canonical view metadata for reader.

type ResponsePayloadView

type ResponsePayloadView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Id          string   `sqlx:"id,primaryKey=true" json:"id"`
	Compression string   `sqlx:"compression,required=true" json:"compression"`
}

ResponsePayloadView is generated canonical view metadata for reader.

type ToolCallLinksView

type ToolCallLinksView struct {
	MessageId string  `sqlx:"message_id,refTable=message,refColumn=id,primaryKey=true" json:"messageId"`
	OpId      string  `sqlx:"op_id,required=true" json:"opId"`
	TraceId   *string `sqlx:"trace_id" json:"traceId"`
}

ToolCallLinksView is generated canonical view metadata for reader.

type ToolCallView

type ToolCallView struct {
	MessageId         string               `sqlx:"message_id,refTable=message,refColumn=id,primaryKey=true" json:"messageId"`
	OpId              string               `sqlx:"op_id,required=true" json:"opId"`
	Attempt           int                  `sqlx:"attempt,required=true" json:"attempt"`
	ToolName          string               `sqlx:"tool_name,required=true" json:"toolName"`
	ToolKind          string               `sqlx:"tool_kind,required=true" json:"toolKind"`
	Status            string               `sqlx:"status,required=true" json:"status"`
	TurnId            *string              `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId"`
	RequestHash       *string              `sqlx:"request_hash" json:"requestHash"`
	ErrorCode         *string              `sqlx:"error_code" json:"errorCode"`
	ErrorMessage      *string              `sqlx:"error_message" json:"errorMessage"`
	Retriable         *int                 `sqlx:"retriable" json:"retriable"`
	StartedAt         *time.Time           `sqlx:"started_at" json:"startedAt"`
	CompletedAt       *time.Time           `sqlx:"completed_at" json:"completedAt"`
	LatencyMs         *int                 `sqlx:"latency_ms" json:"latencyMs"`
	Cost              *float64             `sqlx:"cost" json:"cost"`
	TraceId           *string              `sqlx:"trace_id" json:"traceId"`
	SpanId            *string              `sqlx:"span_id" json:"spanId"`
	RequestPayloadId  *string              `sqlx:"request_payload_id,refTable=call_payload,refColumn=id" json:"requestPayloadId"`
	ResponsePayloadId *string              `sqlx:"response_payload_id,refTable=call_payload,refColumn=id" json:"responsePayloadId"`
	RunId             *string              `sqlx:"run_id" json:"runId"`
	Iteration         *int                 `sqlx:"iteration" json:"iteration"`
	MessageSequence   *int                 `sqlx:"message_sequence" json:"messageSequence"`
	RequestPayload    *RequestPayloadView  `` /* 217-byte string literal not displayed */
	ResponsePayload   *ResponsePayloadView `` /* 224-byte string literal not displayed */
}

ToolCallView is generated canonical view metadata for reader.

type ToolMessageView

type ToolMessageView struct {
	Id                   string        `sqlx:"id,primaryKey=true" json:"id"`
	CreatedAt            time.Time     `sqlx:"created_at,required=true" json:"createdAt"`
	Type                 string        `sqlx:"type,required=true" json:"type"`
	LinkedConversationId *string       `sqlx:"linked_conversation_id" json:"linkedConversationId"`
	ParentMessageId      *string       `sqlx:"parent_message_id" json:"parentMessageId"`
	Sequence             *int          `sqlx:"sequence" json:"sequence"`
	Content              *string       `sqlx:"content" json:"content"`
	ToolName             *string       `sqlx:"tool_name" json:"toolName"`
	Iteration            *int          `sqlx:"iteration" json:"iteration"`
	ToolCall             *ToolCallView `` /* 172-byte string literal not displayed */
}

ToolMessageView is generated canonical view metadata for reader.

type UserElicitationDataView

type UserElicitationDataView struct {
	InlineBody  *[]uint8 `sqlx:"inline_body" json:"inlineBody"`
	Compression string   `sqlx:"compression" json:"compression"`
	MessageId   string   `sqlx:"id|message_id,primaryKey=true" json:"messageId"`
}

UserElicitationDataView is generated canonical view metadata for reader.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL