Documentation
¶
Index ¶
- Constants
- Variables
- func LifecycleDatlyType() reflect.Type
- func WriterDatlyType() reflect.Type
- func WriterHandlerCurrentWriterIndexByArchivedKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByAttachmentPayloadIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByContentKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByContextSummaryKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
- func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByElicitationIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByElicitationPayloadIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByInterimKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByIterationKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByLinkedConversationIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByModeKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByNarrationKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByParentMessageIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByPhaseKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByRawContentKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByRoleKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexBySequenceKey(value *CurrentWriterView) (int, bool)
- func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexBySummaryKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexBySupersededByKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTagsKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByToolNameKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByTypeKey(value *CurrentWriterView) (string, bool)
- func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
- type CoreWriterComponent
- type CurrentWriterView
- type Input
- func (input *Input) Init(context.Context) error
- func (input *Input) PrepareReadIndexes(ctx context.Context) error
- func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
- func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
- func (input *Input) SetDetachLinks(value bool)
- func (input *Input) SetDetachMessageIDs(value []string)
- func (input *Input) SetMessages(value []*Message)
- func (input *Input) SetOrphanColumn(value string)
- func (input *Input) SetOrphanDetach(value bool)
- func (input *Input) SetTerminalCleanup(value bool)
- func (input *Input) SetWriterKeys(value []WriterKeysRow)
- type InputHas
- type Lifecycle
- func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *Message, ...) error
- func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *Message, ...) error
- func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error
- func (hooks *Lifecycle) Init(ctx context.Context, entity *Message, ...) error
- func (hooks *Lifecycle) Validate(ctx context.Context, entity *Message, ...) error
- type Message
- func (entity *Message) GetArchived() *int
- func (entity *Message) GetAttachmentPayloadId() *string
- func (entity *Message) GetContent() *string
- func (entity *Message) GetContextSummary() *string
- func (entity *Message) GetConversationId() string
- func (entity *Message) GetCreatedAt() *time.Time
- func (entity *Message) GetCreatedByUserId() *string
- func (entity *Message) GetElicitationId() *string
- func (entity *Message) GetElicitationPayloadId() *string
- func (entity *Message) GetEmbeddingIndex() *[]byte
- func (entity *Message) GetId() string
- func (entity *Message) GetInterim() *int
- func (entity *Message) GetIteration() *int
- func (entity *Message) GetLinkedConversationId() *string
- func (entity *Message) GetMode() *string
- func (entity *Message) GetNarration() *string
- func (entity *Message) GetParentMessageId() *string
- func (entity *Message) GetPhase() *string
- func (entity *Message) GetRawContent() *string
- func (entity *Message) GetRole() string
- func (entity *Message) GetSequence() *int
- func (entity *Message) GetShouldDelete() bool
- func (entity *Message) GetStatus() *string
- func (entity *Message) GetSummary() *string
- func (entity *Message) GetSupersededBy() *string
- func (entity *Message) GetTags() *string
- func (entity *Message) GetToolName() *string
- func (entity *Message) GetTurnId() *string
- func (entity *Message) GetType() string
- func (entity *Message) GetUpdatedAt() *time.Time
- func (entity *Message) SetArchived(value *int)
- func (entity *Message) SetAttachmentPayloadId(value *string)
- func (entity *Message) SetContent(value *string)
- func (entity *Message) SetContextSummary(value *string)
- func (entity *Message) SetConversationId(value string)
- func (entity *Message) SetCreatedAt(value *time.Time)
- func (entity *Message) SetCreatedByUserId(value *string)
- func (entity *Message) SetElicitationId(value *string)
- func (entity *Message) SetElicitationPayloadId(value *string)
- func (entity *Message) SetEmbeddingIndex(value *[]byte)
- func (entity *Message) SetId(value string)
- func (entity *Message) SetInterim(value *int)
- func (entity *Message) SetIteration(value *int)
- func (entity *Message) SetLinkedConversationId(value *string)
- func (entity *Message) SetMode(value *string)
- func (entity *Message) SetNarration(value *string)
- func (entity *Message) SetParentMessageId(value *string)
- func (entity *Message) SetPhase(value *string)
- func (entity *Message) SetRawContent(value *string)
- func (entity *Message) SetRole(value string)
- func (entity *Message) SetSequence(value *int)
- func (entity *Message) SetShouldDelete(value bool)
- func (entity *Message) SetStatus(value *string)
- func (entity *Message) SetSummary(value *string)
- func (entity *Message) SetSupersededBy(value *string)
- func (entity *Message) SetTags(value *string)
- func (entity *Message) SetToolName(value *string)
- func (entity *Message) SetTurnId(value *string)
- func (entity *Message) SetType(value string)
- func (entity *Message) SetUpdatedAt(value *time.Time)
- type MessageHas
- type Output
- type WriterComponent
- type WriterHandlerCurrentWriterGroupedByArchived
- type WriterHandlerCurrentWriterGroupedByAttachmentPayloadId
- type WriterHandlerCurrentWriterGroupedByContent
- type WriterHandlerCurrentWriterGroupedByContextSummary
- type WriterHandlerCurrentWriterGroupedByConversationId
- type WriterHandlerCurrentWriterGroupedByCreatedAt
- type WriterHandlerCurrentWriterGroupedByCreatedByUserId
- type WriterHandlerCurrentWriterGroupedByElicitationId
- type WriterHandlerCurrentWriterGroupedByElicitationPayloadId
- type WriterHandlerCurrentWriterGroupedById
- type WriterHandlerCurrentWriterGroupedByInterim
- type WriterHandlerCurrentWriterGroupedByIteration
- type WriterHandlerCurrentWriterGroupedByLinkedConversationId
- type WriterHandlerCurrentWriterGroupedByMode
- type WriterHandlerCurrentWriterGroupedByNarration
- type WriterHandlerCurrentWriterGroupedByParentMessageId
- type WriterHandlerCurrentWriterGroupedByPhase
- type WriterHandlerCurrentWriterGroupedByRawContent
- type WriterHandlerCurrentWriterGroupedByRole
- type WriterHandlerCurrentWriterGroupedBySequence
- type WriterHandlerCurrentWriterGroupedByStatus
- type WriterHandlerCurrentWriterGroupedBySummary
- type WriterHandlerCurrentWriterGroupedBySupersededBy
- type WriterHandlerCurrentWriterGroupedByTags
- type WriterHandlerCurrentWriterGroupedByToolName
- type WriterHandlerCurrentWriterGroupedByTurnId
- type WriterHandlerCurrentWriterGroupedByType
- type WriterHandlerCurrentWriterGroupedByUpdatedAt
- type WriterHandlerCurrentWriterIndexedByArchived
- type WriterHandlerCurrentWriterIndexedByAttachmentPayloadId
- type WriterHandlerCurrentWriterIndexedByContent
- type WriterHandlerCurrentWriterIndexedByContextSummary
- type WriterHandlerCurrentWriterIndexedByConversationId
- type WriterHandlerCurrentWriterIndexedByCreatedAt
- type WriterHandlerCurrentWriterIndexedByCreatedByUserId
- type WriterHandlerCurrentWriterIndexedByElicitationId
- type WriterHandlerCurrentWriterIndexedByElicitationPayloadId
- type WriterHandlerCurrentWriterIndexedById
- type WriterHandlerCurrentWriterIndexedByInterim
- type WriterHandlerCurrentWriterIndexedByIteration
- type WriterHandlerCurrentWriterIndexedByLinkedConversationId
- type WriterHandlerCurrentWriterIndexedByMode
- type WriterHandlerCurrentWriterIndexedByNarration
- type WriterHandlerCurrentWriterIndexedByParentMessageId
- type WriterHandlerCurrentWriterIndexedByPhase
- type WriterHandlerCurrentWriterIndexedByRawContent
- type WriterHandlerCurrentWriterIndexedByRole
- type WriterHandlerCurrentWriterIndexedBySequence
- type WriterHandlerCurrentWriterIndexedByStatus
- type WriterHandlerCurrentWriterIndexedBySummary
- type WriterHandlerCurrentWriterIndexedBySupersededBy
- type WriterHandlerCurrentWriterIndexedByTags
- type WriterHandlerCurrentWriterIndexedByToolName
- type WriterHandlerCurrentWriterIndexedByTurnId
- type WriterHandlerCurrentWriterIndexedByType
- type WriterHandlerCurrentWriterIndexedByUpdatedAt
- type WriterHandlerCurrentWriterSlice
- func (rows WriterHandlerCurrentWriterSlice) GroupByArchived() WriterHandlerCurrentWriterGroupedByArchived
- func (rows WriterHandlerCurrentWriterSlice) GroupByAttachmentPayloadId() WriterHandlerCurrentWriterGroupedByAttachmentPayloadId
- func (rows WriterHandlerCurrentWriterSlice) GroupByContent() WriterHandlerCurrentWriterGroupedByContent
- func (rows WriterHandlerCurrentWriterSlice) GroupByContextSummary() WriterHandlerCurrentWriterGroupedByContextSummary
- func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId
- func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
- func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId() WriterHandlerCurrentWriterGroupedByCreatedByUserId
- func (rows WriterHandlerCurrentWriterSlice) GroupByElicitationId() WriterHandlerCurrentWriterGroupedByElicitationId
- func (rows WriterHandlerCurrentWriterSlice) GroupByElicitationPayloadId() WriterHandlerCurrentWriterGroupedByElicitationPayloadId
- func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
- func (rows WriterHandlerCurrentWriterSlice) GroupByInterim() WriterHandlerCurrentWriterGroupedByInterim
- func (rows WriterHandlerCurrentWriterSlice) GroupByIteration() WriterHandlerCurrentWriterGroupedByIteration
- func (rows WriterHandlerCurrentWriterSlice) GroupByLinkedConversationId() WriterHandlerCurrentWriterGroupedByLinkedConversationId
- func (rows WriterHandlerCurrentWriterSlice) GroupByMode() WriterHandlerCurrentWriterGroupedByMode
- func (rows WriterHandlerCurrentWriterSlice) GroupByNarration() WriterHandlerCurrentWriterGroupedByNarration
- func (rows WriterHandlerCurrentWriterSlice) GroupByParentMessageId() WriterHandlerCurrentWriterGroupedByParentMessageId
- func (rows WriterHandlerCurrentWriterSlice) GroupByPhase() WriterHandlerCurrentWriterGroupedByPhase
- func (rows WriterHandlerCurrentWriterSlice) GroupByRawContent() WriterHandlerCurrentWriterGroupedByRawContent
- func (rows WriterHandlerCurrentWriterSlice) GroupByRole() WriterHandlerCurrentWriterGroupedByRole
- func (rows WriterHandlerCurrentWriterSlice) GroupBySequence() WriterHandlerCurrentWriterGroupedBySequence
- func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus
- func (rows WriterHandlerCurrentWriterSlice) GroupBySummary() WriterHandlerCurrentWriterGroupedBySummary
- func (rows WriterHandlerCurrentWriterSlice) GroupBySupersededBy() WriterHandlerCurrentWriterGroupedBySupersededBy
- func (rows WriterHandlerCurrentWriterSlice) GroupByTags() WriterHandlerCurrentWriterGroupedByTags
- func (rows WriterHandlerCurrentWriterSlice) GroupByToolName() WriterHandlerCurrentWriterGroupedByToolName
- func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId
- func (rows WriterHandlerCurrentWriterSlice) GroupByType() WriterHandlerCurrentWriterGroupedByType
- func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
- func (rows WriterHandlerCurrentWriterSlice) IndexByArchived() (WriterHandlerCurrentWriterIndexedByArchived, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByAttachmentPayloadId() (WriterHandlerCurrentWriterIndexedByAttachmentPayloadId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByContent() (WriterHandlerCurrentWriterIndexedByContent, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByContextSummary() (WriterHandlerCurrentWriterIndexedByContextSummary, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId() (WriterHandlerCurrentWriterIndexedByCreatedByUserId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByElicitationId() (WriterHandlerCurrentWriterIndexedByElicitationId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByElicitationPayloadId() (WriterHandlerCurrentWriterIndexedByElicitationPayloadId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByInterim() (WriterHandlerCurrentWriterIndexedByInterim, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByIteration() (WriterHandlerCurrentWriterIndexedByIteration, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByLinkedConversationId() (WriterHandlerCurrentWriterIndexedByLinkedConversationId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByMode() (WriterHandlerCurrentWriterIndexedByMode, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByNarration() (WriterHandlerCurrentWriterIndexedByNarration, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByParentMessageId() (WriterHandlerCurrentWriterIndexedByParentMessageId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByPhase() (WriterHandlerCurrentWriterIndexedByPhase, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByRawContent() (WriterHandlerCurrentWriterIndexedByRawContent, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByRole() (WriterHandlerCurrentWriterIndexedByRole, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexBySequence() (WriterHandlerCurrentWriterIndexedBySequence, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexBySummary() (WriterHandlerCurrentWriterIndexedBySummary, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexBySupersededBy() (WriterHandlerCurrentWriterIndexedBySupersededBy, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTags() (WriterHandlerCurrentWriterIndexedByTags, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByToolName() (WriterHandlerCurrentWriterIndexedByToolName, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByType() (WriterHandlerCurrentWriterIndexedByType, error)
- func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
- type WriterHandlerReadIndexes
- type WriterKeysRow
Constants ¶
const MaxContentBytes = 16777215
MaxContentBytes preserves the legacy MEDIUMTEXT limit.
const WriterDatlyResourceNamespace = "datly_message_write_writer"
DatlyResourceNamespace identifies this package's generated resource filesystem.
Variables ¶
var ( LifecycleHooks = new(Lifecycle) LifecycleDatly = LifecycleDatlyType() )
var WriterDatly = new(WriterComponent)
The public value supports explicit component wiring.
var WriterDatlyResources embed.FS
Functions ¶
func LifecycleDatlyType ¶
func WriterDatlyType ¶
WriterDatlyType returns the public component type.
func WriterHandlerCurrentWriterIndexByArchivedKey ¶
func WriterHandlerCurrentWriterIndexByArchivedKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByAttachmentPayloadIdKey ¶
func WriterHandlerCurrentWriterIndexByAttachmentPayloadIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByContentKey ¶
func WriterHandlerCurrentWriterIndexByContentKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByContextSummaryKey ¶
func WriterHandlerCurrentWriterIndexByContextSummaryKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByConversationIdKey ¶
func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByCreatedAtKey ¶
func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool)
func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey ¶
func WriterHandlerCurrentWriterIndexByCreatedByUserIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByElicitationIdKey ¶
func WriterHandlerCurrentWriterIndexByElicitationIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByElicitationPayloadIdKey ¶
func WriterHandlerCurrentWriterIndexByElicitationPayloadIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByIdKey ¶
func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByInterimKey ¶
func WriterHandlerCurrentWriterIndexByInterimKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByIterationKey ¶
func WriterHandlerCurrentWriterIndexByIterationKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByLinkedConversationIdKey ¶
func WriterHandlerCurrentWriterIndexByLinkedConversationIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByModeKey ¶
func WriterHandlerCurrentWriterIndexByModeKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByNarrationKey ¶
func WriterHandlerCurrentWriterIndexByNarrationKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByParentMessageIdKey ¶
func WriterHandlerCurrentWriterIndexByParentMessageIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByPhaseKey ¶
func WriterHandlerCurrentWriterIndexByPhaseKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByRawContentKey ¶
func WriterHandlerCurrentWriterIndexByRawContentKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByRoleKey ¶
func WriterHandlerCurrentWriterIndexByRoleKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexBySequenceKey ¶
func WriterHandlerCurrentWriterIndexBySequenceKey(value *CurrentWriterView) (int, bool)
func WriterHandlerCurrentWriterIndexByStatusKey ¶
func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexBySummaryKey ¶
func WriterHandlerCurrentWriterIndexBySummaryKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexBySupersededByKey ¶
func WriterHandlerCurrentWriterIndexBySupersededByKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByTagsKey ¶
func WriterHandlerCurrentWriterIndexByTagsKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByToolNameKey ¶
func WriterHandlerCurrentWriterIndexByToolNameKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByTurnIdKey ¶
func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByTypeKey ¶
func WriterHandlerCurrentWriterIndexByTypeKey(value *CurrentWriterView) (string, bool)
func WriterHandlerCurrentWriterIndexByUpdatedAtKey ¶
func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool)
Types ¶
type CoreWriterComponent ¶
type CoreWriterComponent struct {
Contract xdatly.Component[Input, Output] `` /* 185-byte string literal not displayed */
}
CoreWriterComponent keeps the original per-turn business allocation around the canonical native writer. Rollback recovery rereads the collided sequence through the scoped invoker. Imperative composition preserves the same parent-owned transaction.
func (CoreWriterComponent) DatlyHandler ¶
func (CoreWriterComponent) DatlyHandler(name string) func() (rh.TypedHandler, error)
func (CoreWriterComponent) EmbedFS ¶
func (CoreWriterComponent) EmbedFS() *embed.FS
func (CoreWriterComponent) EmbedNamespace ¶
func (CoreWriterComponent) EmbedNamespace() string
type CurrentWriterView ¶
type CurrentWriterView struct {
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
ConversationId string `validate:"required" json:"conversationId" sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true"`
Role string `validate:"required" json:"role" sqlx:"role,required=true"`
Type string `validate:"required" json:"type" sqlx:"type,required=true"`
EmbeddingIndex *[]byte `sqlx:"embedding_index" json:"embeddingIndex,omitempty"`
Status *string `json:"status" sqlx:"status"`
Content *string `json:"content" sqlx:"content"`
Narration *string `sqlx:"preamble" json:"narration,omitempty"`
TurnId *string `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
Archived *int `sqlx:"archived" json:"archived,omitempty"`
Sequence *int `sqlx:"sequence" json:"sequence,omitempty"`
CreatedAt *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `sqlx:"updated_at" json:"updatedAt,omitempty"`
CreatedByUserId *string `sqlx:"created_by_user_id" json:"createdByUserId,omitempty"`
Mode *string `sqlx:"mode" json:"mode,omitempty"`
RawContent *string `sqlx:"raw_content" json:"rawContent,omitempty"`
Summary *string `sqlx:"summary" json:"summary,omitempty"`
ContextSummary *string `sqlx:"context_summary" json:"contextSummary,omitempty"`
Tags *string `sqlx:"tags" json:"tags,omitempty"`
Interim *int `sqlx:"interim,required=true" json:"interim,omitempty"`
ElicitationId *string `sqlx:"elicitation_id" json:"elicitationId,omitempty"`
ParentMessageId *string `sqlx:"parent_message_id" json:"parentMessageId,omitempty"`
SupersededBy *string `sqlx:"superseded_by" json:"supersededBy,omitempty"`
LinkedConversationId *string `sqlx:"linked_conversation_id" json:"linkedConversationId,omitempty"`
AttachmentPayloadId *string `sqlx:"attachment_payload_id,refTable=call_payload,refColumn=id" json:"attachmentPayloadId,omitempty"`
ElicitationPayloadId *string `sqlx:"elicitation_payload_id,refTable=call_payload,refColumn=id" json:"elicitationPayloadId,omitempty"`
ToolName *string `sqlx:"tool_name" json:"toolName,omitempty"`
Iteration *int `sqlx:"iteration" json:"iteration,omitempty"`
Phase *string `sqlx:"phase" json:"phase,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"`
DetachLinks bool `parameter:"DetachLinks,kind=messageaccess,in=detachLinks,dataType=bool,required=false"`
TerminalCleanup bool `parameter:"TerminalCleanup,kind=messageaccess,in=terminalCleanup,dataType=bool,required=false"`
DetachMessageIDs []string `parameter:"DetachMessageIDs,kind=messageaccess,in=messageIds,dataType=[]string,required=false"`
Messages []*Message `` /* 197-byte string literal not displayed */
WriterKeys []WriterKeysRow `` /* 132-byte string literal not displayed */
CurrentWriter []*CurrentWriterView `` /* 164-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) PrepareReadIndexes ¶
func (*Input) ReadIndexes ¶
func (input *Input) ReadIndexes(ctx context.Context) (*WriterHandlerReadIndexes, error)
func (*Input) SetCurrentWriter ¶
func (input *Input) SetCurrentWriter(value []*CurrentWriterView)
func (*Input) SetDetachLinks ¶
func (*Input) SetDetachMessageIDs ¶
func (*Input) SetMessages ¶
func (*Input) SetOrphanColumn ¶
func (*Input) SetOrphanDetach ¶
func (*Input) SetTerminalCleanup ¶
func (*Input) SetWriterKeys ¶
func (input *Input) SetWriterKeys(value []WriterKeysRow)
type Lifecycle ¶
type Lifecycle struct {
Invoker dexec.ComponentInvoker `bind:"kind=component_invoker"`
Input *Input `bind:"kind=input"`
// contains filtered or unexported fields
}
Lifecycle customizes role Input.Messages.
func (*Lifecycle) AfterQueue ¶
func (*Lifecycle) AfterSequence ¶
type Message ¶
type Message struct {
ShouldDelete bool `sqlx:"-" writer:"delete" json:"shouldDelete,omitempty"`
Id string `validate:"required" sqlx:"id,primaryKey" json:"id"`
ConversationId string `validate:"required" json:"conversationId" sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true"`
Role string `validate:"required" json:"role" sqlx:"role,required=true"`
Type string `validate:"required" json:"type" sqlx:"type,required=true"`
EmbeddingIndex *[]byte `sqlx:"embedding_index" json:"embeddingIndex,omitempty"`
Status *string `json:"status" sqlx:"status"`
Content *string `json:"content" sqlx:"content"`
Narration *string `sqlx:"preamble" json:"narration,omitempty"`
TurnId *string `sqlx:"turn_id,refTable=turn,refColumn=id" json:"turnId,omitempty"`
Archived *int `sqlx:"archived" json:"archived,omitempty"`
Sequence *int `sqlx:"sequence" json:"sequence,omitempty"`
CreatedAt *time.Time `sqlx:"created_at,required=true" json:"createdAt,omitempty"`
UpdatedAt *time.Time `sqlx:"updated_at" json:"updatedAt,omitempty"`
CreatedByUserId *string `sqlx:"created_by_user_id" json:"createdByUserId,omitempty"`
Mode *string `sqlx:"mode" json:"mode,omitempty"`
RawContent *string `sqlx:"raw_content" json:"rawContent,omitempty"`
Summary *string `sqlx:"summary" json:"summary,omitempty"`
ContextSummary *string `sqlx:"context_summary" json:"contextSummary,omitempty"`
Tags *string `sqlx:"tags" json:"tags,omitempty"`
Interim *int `sqlx:"interim,required=true" json:"interim,omitempty"`
ElicitationId *string `sqlx:"elicitation_id" json:"elicitationId,omitempty"`
ParentMessageId *string `sqlx:"parent_message_id" json:"parentMessageId,omitempty"`
SupersededBy *string `sqlx:"superseded_by" json:"supersededBy,omitempty"`
LinkedConversationId *string `sqlx:"linked_conversation_id" json:"linkedConversationId,omitempty"`
AttachmentPayloadId *string `sqlx:"attachment_payload_id,refTable=call_payload,refColumn=id" json:"attachmentPayloadId,omitempty"`
ElicitationPayloadId *string `sqlx:"elicitation_payload_id,refTable=call_payload,refColumn=id" json:"elicitationPayloadId,omitempty"`
ToolName *string `sqlx:"tool_name" json:"toolName,omitempty"`
Iteration *int `sqlx:"iteration" json:"iteration,omitempty"`
Phase *string `sqlx:"phase" json:"phase,omitempty"`
Has *MessageHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"MessageHas"`
}
Message is generated canonical view metadata for writer.
func (*Message) GetArchived ¶
func (*Message) GetAttachmentPayloadId ¶
func (*Message) GetContent ¶
func (*Message) GetContextSummary ¶
func (*Message) GetConversationId ¶
func (*Message) GetCreatedAt ¶
func (*Message) GetCreatedByUserId ¶
func (*Message) GetElicitationId ¶
func (*Message) GetElicitationPayloadId ¶
func (*Message) GetEmbeddingIndex ¶
func (*Message) GetInterim ¶
func (*Message) GetIteration ¶
func (*Message) GetLinkedConversationId ¶
func (*Message) GetNarration ¶
func (*Message) GetParentMessageId ¶
func (*Message) GetRawContent ¶
func (*Message) GetSequence ¶
func (*Message) GetShouldDelete ¶
func (*Message) GetSummary ¶
func (*Message) GetSupersededBy ¶
func (*Message) GetToolName ¶
func (*Message) GetUpdatedAt ¶
func (*Message) SetArchived ¶
func (*Message) SetAttachmentPayloadId ¶
func (*Message) SetContent ¶
func (*Message) SetContextSummary ¶
func (*Message) SetConversationId ¶
func (*Message) SetCreatedAt ¶
func (*Message) SetCreatedByUserId ¶
func (*Message) SetElicitationId ¶
func (*Message) SetElicitationPayloadId ¶
func (*Message) SetEmbeddingIndex ¶
func (*Message) SetInterim ¶
func (*Message) SetIteration ¶
func (*Message) SetLinkedConversationId ¶
func (*Message) SetNarration ¶
func (*Message) SetParentMessageId ¶
func (*Message) SetRawContent ¶
func (*Message) SetSequence ¶
func (*Message) SetShouldDelete ¶
func (*Message) SetSummary ¶
func (*Message) SetSupersededBy ¶
func (*Message) SetToolName ¶
func (*Message) SetUpdatedAt ¶
type MessageHas ¶
type MessageHas struct {
ShouldDelete bool
Id bool
ConversationId bool
Role bool
Type bool
EmbeddingIndex bool
Status bool
Content bool
Narration bool
TurnId bool
Archived bool
Sequence bool
CreatedAt bool
UpdatedAt bool
CreatedByUserId bool
Mode bool
RawContent bool
Summary bool
ContextSummary bool
Tags bool
Interim bool
ElicitationId bool
ParentMessageId bool
SupersededBy bool
LinkedConversationId bool
AttachmentPayloadId bool
ElicitationPayloadId bool
ToolName bool
Iteration bool
Phase bool
}
type Output ¶
type Output struct {
Data []*Message `parameter:"Data,kind=output,in=body,dataType=[]*Message" json:"data,omitempty"`
}
Output is the generated output scaffold for writer.
type WriterComponent ¶
type WriterComponent struct {
Contract xdatly.Component[Input, Output] "" /* 164-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 WriterHandlerCurrentWriterGroupedByArchived ¶
type WriterHandlerCurrentWriterGroupedByArchived map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByArchived) Has ¶
func (index WriterHandlerCurrentWriterGroupedByArchived) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByAttachmentPayloadId ¶
type WriterHandlerCurrentWriterGroupedByAttachmentPayloadId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByAttachmentPayloadId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByAttachmentPayloadId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByContent ¶
type WriterHandlerCurrentWriterGroupedByContent map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByContent) Has ¶
func (index WriterHandlerCurrentWriterGroupedByContent) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByContextSummary ¶
type WriterHandlerCurrentWriterGroupedByContextSummary map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByContextSummary) Has ¶
func (index WriterHandlerCurrentWriterGroupedByContextSummary) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByConversationId ¶
type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByConversationId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByCreatedAt ¶
type WriterHandlerCurrentWriterGroupedByCreatedAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterGroupedByCreatedByUserId ¶
type WriterHandlerCurrentWriterGroupedByCreatedByUserId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByElicitationId ¶
type WriterHandlerCurrentWriterGroupedByElicitationId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByElicitationId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByElicitationId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByElicitationPayloadId ¶
type WriterHandlerCurrentWriterGroupedByElicitationPayloadId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByElicitationPayloadId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByElicitationPayloadId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedById ¶
type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedById) Has ¶
func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByInterim ¶
type WriterHandlerCurrentWriterGroupedByInterim map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByInterim) Has ¶
func (index WriterHandlerCurrentWriterGroupedByInterim) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByIteration ¶
type WriterHandlerCurrentWriterGroupedByIteration map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByIteration) Has ¶
func (index WriterHandlerCurrentWriterGroupedByIteration) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByLinkedConversationId ¶
type WriterHandlerCurrentWriterGroupedByLinkedConversationId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByLinkedConversationId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByLinkedConversationId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByMode ¶
type WriterHandlerCurrentWriterGroupedByMode map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByMode) Has ¶
func (index WriterHandlerCurrentWriterGroupedByMode) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByNarration ¶
type WriterHandlerCurrentWriterGroupedByNarration map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByNarration) Has ¶
func (index WriterHandlerCurrentWriterGroupedByNarration) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByParentMessageId ¶
type WriterHandlerCurrentWriterGroupedByParentMessageId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByParentMessageId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByParentMessageId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByPhase ¶
type WriterHandlerCurrentWriterGroupedByPhase map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByPhase) Has ¶
func (index WriterHandlerCurrentWriterGroupedByPhase) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByRawContent ¶
type WriterHandlerCurrentWriterGroupedByRawContent map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByRawContent) Has ¶
func (index WriterHandlerCurrentWriterGroupedByRawContent) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByRole ¶
type WriterHandlerCurrentWriterGroupedByRole map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByRole) Has ¶
func (index WriterHandlerCurrentWriterGroupedByRole) Has(key string) bool
type WriterHandlerCurrentWriterGroupedBySequence ¶
type WriterHandlerCurrentWriterGroupedBySequence map[int][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedBySequence) Has ¶
func (index WriterHandlerCurrentWriterGroupedBySequence) Has(key int) bool
type WriterHandlerCurrentWriterGroupedByStatus ¶
type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByStatus) Has ¶
func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool
type WriterHandlerCurrentWriterGroupedBySummary ¶
type WriterHandlerCurrentWriterGroupedBySummary map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedBySummary) Has ¶
func (index WriterHandlerCurrentWriterGroupedBySummary) Has(key string) bool
type WriterHandlerCurrentWriterGroupedBySupersededBy ¶
type WriterHandlerCurrentWriterGroupedBySupersededBy map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedBySupersededBy) Has ¶
func (index WriterHandlerCurrentWriterGroupedBySupersededBy) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByTags ¶
type WriterHandlerCurrentWriterGroupedByTags map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTags) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTags) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByToolName ¶
type WriterHandlerCurrentWriterGroupedByToolName map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByToolName) Has ¶
func (index WriterHandlerCurrentWriterGroupedByToolName) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByTurnId ¶
type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByTurnId) Has ¶
func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByType ¶
type WriterHandlerCurrentWriterGroupedByType map[string][]*CurrentWriterView
func (WriterHandlerCurrentWriterGroupedByType) Has ¶
func (index WriterHandlerCurrentWriterGroupedByType) Has(key string) bool
type WriterHandlerCurrentWriterGroupedByUpdatedAt ¶
type WriterHandlerCurrentWriterGroupedByUpdatedAt map[time.Time][]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByArchived ¶
type WriterHandlerCurrentWriterIndexedByArchived map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByArchived) Has ¶
func (index WriterHandlerCurrentWriterIndexedByArchived) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByAttachmentPayloadId ¶
type WriterHandlerCurrentWriterIndexedByAttachmentPayloadId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByAttachmentPayloadId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByAttachmentPayloadId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByContent ¶
type WriterHandlerCurrentWriterIndexedByContent map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByContent) Has ¶
func (index WriterHandlerCurrentWriterIndexedByContent) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByContextSummary ¶
type WriterHandlerCurrentWriterIndexedByContextSummary map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByContextSummary) Has ¶
func (index WriterHandlerCurrentWriterIndexedByContextSummary) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByConversationId ¶
type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByConversationId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByCreatedAt ¶
type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterIndexedByCreatedByUserId ¶
type WriterHandlerCurrentWriterIndexedByCreatedByUserId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByElicitationId ¶
type WriterHandlerCurrentWriterIndexedByElicitationId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByElicitationId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByElicitationId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByElicitationPayloadId ¶
type WriterHandlerCurrentWriterIndexedByElicitationPayloadId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByElicitationPayloadId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByElicitationPayloadId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedById ¶
type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedById) Has ¶
func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByInterim ¶
type WriterHandlerCurrentWriterIndexedByInterim map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByInterim) Has ¶
func (index WriterHandlerCurrentWriterIndexedByInterim) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByIteration ¶
type WriterHandlerCurrentWriterIndexedByIteration map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByIteration) Has ¶
func (index WriterHandlerCurrentWriterIndexedByIteration) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByLinkedConversationId ¶
type WriterHandlerCurrentWriterIndexedByLinkedConversationId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByLinkedConversationId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByLinkedConversationId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByMode ¶
type WriterHandlerCurrentWriterIndexedByMode map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByMode) Has ¶
func (index WriterHandlerCurrentWriterIndexedByMode) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByNarration ¶
type WriterHandlerCurrentWriterIndexedByNarration map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByNarration) Has ¶
func (index WriterHandlerCurrentWriterIndexedByNarration) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByParentMessageId ¶
type WriterHandlerCurrentWriterIndexedByParentMessageId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByParentMessageId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByParentMessageId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByPhase ¶
type WriterHandlerCurrentWriterIndexedByPhase map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByPhase) Has ¶
func (index WriterHandlerCurrentWriterIndexedByPhase) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByRawContent ¶
type WriterHandlerCurrentWriterIndexedByRawContent map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByRawContent) Has ¶
func (index WriterHandlerCurrentWriterIndexedByRawContent) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByRole ¶
type WriterHandlerCurrentWriterIndexedByRole map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByRole) Has ¶
func (index WriterHandlerCurrentWriterIndexedByRole) Has(key string) bool
type WriterHandlerCurrentWriterIndexedBySequence ¶
type WriterHandlerCurrentWriterIndexedBySequence map[int]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedBySequence) Has ¶
func (index WriterHandlerCurrentWriterIndexedBySequence) Has(key int) bool
type WriterHandlerCurrentWriterIndexedByStatus ¶
type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByStatus) Has ¶
func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool
type WriterHandlerCurrentWriterIndexedBySummary ¶
type WriterHandlerCurrentWriterIndexedBySummary map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedBySummary) Has ¶
func (index WriterHandlerCurrentWriterIndexedBySummary) Has(key string) bool
type WriterHandlerCurrentWriterIndexedBySupersededBy ¶
type WriterHandlerCurrentWriterIndexedBySupersededBy map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedBySupersededBy) Has ¶
func (index WriterHandlerCurrentWriterIndexedBySupersededBy) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByTags ¶
type WriterHandlerCurrentWriterIndexedByTags map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTags) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTags) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByToolName ¶
type WriterHandlerCurrentWriterIndexedByToolName map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByToolName) Has ¶
func (index WriterHandlerCurrentWriterIndexedByToolName) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByTurnId ¶
type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByTurnId) Has ¶
func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByType ¶
type WriterHandlerCurrentWriterIndexedByType map[string]*CurrentWriterView
func (WriterHandlerCurrentWriterIndexedByType) Has ¶
func (index WriterHandlerCurrentWriterIndexedByType) Has(key string) bool
type WriterHandlerCurrentWriterIndexedByUpdatedAt ¶
type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView
type WriterHandlerCurrentWriterSlice ¶
type WriterHandlerCurrentWriterSlice []*CurrentWriterView
func (WriterHandlerCurrentWriterSlice) GroupByArchived ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByArchived() WriterHandlerCurrentWriterGroupedByArchived
func (WriterHandlerCurrentWriterSlice) GroupByAttachmentPayloadId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByAttachmentPayloadId() WriterHandlerCurrentWriterGroupedByAttachmentPayloadId
func (WriterHandlerCurrentWriterSlice) GroupByContent ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByContent() WriterHandlerCurrentWriterGroupedByContent
func (WriterHandlerCurrentWriterSlice) GroupByContextSummary ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByContextSummary() WriterHandlerCurrentWriterGroupedByContextSummary
func (WriterHandlerCurrentWriterSlice) GroupByConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId
func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt
func (WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId() WriterHandlerCurrentWriterGroupedByCreatedByUserId
func (WriterHandlerCurrentWriterSlice) GroupByElicitationId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByElicitationId() WriterHandlerCurrentWriterGroupedByElicitationId
func (WriterHandlerCurrentWriterSlice) GroupByElicitationPayloadId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByElicitationPayloadId() WriterHandlerCurrentWriterGroupedByElicitationPayloadId
func (WriterHandlerCurrentWriterSlice) GroupById ¶
func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById
func (WriterHandlerCurrentWriterSlice) GroupByInterim ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByInterim() WriterHandlerCurrentWriterGroupedByInterim
func (WriterHandlerCurrentWriterSlice) GroupByIteration ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByIteration() WriterHandlerCurrentWriterGroupedByIteration
func (WriterHandlerCurrentWriterSlice) GroupByLinkedConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByLinkedConversationId() WriterHandlerCurrentWriterGroupedByLinkedConversationId
func (WriterHandlerCurrentWriterSlice) GroupByMode ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByMode() WriterHandlerCurrentWriterGroupedByMode
func (WriterHandlerCurrentWriterSlice) GroupByNarration ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByNarration() WriterHandlerCurrentWriterGroupedByNarration
func (WriterHandlerCurrentWriterSlice) GroupByParentMessageId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByParentMessageId() WriterHandlerCurrentWriterGroupedByParentMessageId
func (WriterHandlerCurrentWriterSlice) GroupByPhase ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByPhase() WriterHandlerCurrentWriterGroupedByPhase
func (WriterHandlerCurrentWriterSlice) GroupByRawContent ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByRawContent() WriterHandlerCurrentWriterGroupedByRawContent
func (WriterHandlerCurrentWriterSlice) GroupByRole ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByRole() WriterHandlerCurrentWriterGroupedByRole
func (WriterHandlerCurrentWriterSlice) GroupBySequence ¶
func (rows WriterHandlerCurrentWriterSlice) GroupBySequence() WriterHandlerCurrentWriterGroupedBySequence
func (WriterHandlerCurrentWriterSlice) GroupByStatus ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus
func (WriterHandlerCurrentWriterSlice) GroupBySummary ¶
func (rows WriterHandlerCurrentWriterSlice) GroupBySummary() WriterHandlerCurrentWriterGroupedBySummary
func (WriterHandlerCurrentWriterSlice) GroupBySupersededBy ¶
func (rows WriterHandlerCurrentWriterSlice) GroupBySupersededBy() WriterHandlerCurrentWriterGroupedBySupersededBy
func (WriterHandlerCurrentWriterSlice) GroupByTags ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTags() WriterHandlerCurrentWriterGroupedByTags
func (WriterHandlerCurrentWriterSlice) GroupByToolName ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByToolName() WriterHandlerCurrentWriterGroupedByToolName
func (WriterHandlerCurrentWriterSlice) GroupByTurnId ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId
func (WriterHandlerCurrentWriterSlice) GroupByType ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByType() WriterHandlerCurrentWriterGroupedByType
func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt
func (WriterHandlerCurrentWriterSlice) IndexByArchived ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByArchived() (WriterHandlerCurrentWriterIndexedByArchived, error)
func (WriterHandlerCurrentWriterSlice) IndexByAttachmentPayloadId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByAttachmentPayloadId() (WriterHandlerCurrentWriterIndexedByAttachmentPayloadId, error)
func (WriterHandlerCurrentWriterSlice) IndexByContent ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByContent() (WriterHandlerCurrentWriterIndexedByContent, error)
func (WriterHandlerCurrentWriterSlice) IndexByContextSummary ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByContextSummary() (WriterHandlerCurrentWriterIndexedByContextSummary, error)
func (WriterHandlerCurrentWriterSlice) IndexByConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error)
func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error)
func (WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId() (WriterHandlerCurrentWriterIndexedByCreatedByUserId, error)
func (WriterHandlerCurrentWriterSlice) IndexByElicitationId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByElicitationId() (WriterHandlerCurrentWriterIndexedByElicitationId, error)
func (WriterHandlerCurrentWriterSlice) IndexByElicitationPayloadId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByElicitationPayloadId() (WriterHandlerCurrentWriterIndexedByElicitationPayloadId, error)
func (WriterHandlerCurrentWriterSlice) IndexById ¶
func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error)
func (WriterHandlerCurrentWriterSlice) IndexByInterim ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByInterim() (WriterHandlerCurrentWriterIndexedByInterim, error)
func (WriterHandlerCurrentWriterSlice) IndexByIteration ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByIteration() (WriterHandlerCurrentWriterIndexedByIteration, error)
func (WriterHandlerCurrentWriterSlice) IndexByLinkedConversationId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByLinkedConversationId() (WriterHandlerCurrentWriterIndexedByLinkedConversationId, error)
func (WriterHandlerCurrentWriterSlice) IndexByMode ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByMode() (WriterHandlerCurrentWriterIndexedByMode, error)
func (WriterHandlerCurrentWriterSlice) IndexByNarration ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByNarration() (WriterHandlerCurrentWriterIndexedByNarration, error)
func (WriterHandlerCurrentWriterSlice) IndexByParentMessageId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByParentMessageId() (WriterHandlerCurrentWriterIndexedByParentMessageId, error)
func (WriterHandlerCurrentWriterSlice) IndexByPhase ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByPhase() (WriterHandlerCurrentWriterIndexedByPhase, error)
func (WriterHandlerCurrentWriterSlice) IndexByRawContent ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByRawContent() (WriterHandlerCurrentWriterIndexedByRawContent, error)
func (WriterHandlerCurrentWriterSlice) IndexByRole ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByRole() (WriterHandlerCurrentWriterIndexedByRole, error)
func (WriterHandlerCurrentWriterSlice) IndexBySequence ¶
func (rows WriterHandlerCurrentWriterSlice) IndexBySequence() (WriterHandlerCurrentWriterIndexedBySequence, error)
func (WriterHandlerCurrentWriterSlice) IndexByStatus ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error)
func (WriterHandlerCurrentWriterSlice) IndexBySummary ¶
func (rows WriterHandlerCurrentWriterSlice) IndexBySummary() (WriterHandlerCurrentWriterIndexedBySummary, error)
func (WriterHandlerCurrentWriterSlice) IndexBySupersededBy ¶
func (rows WriterHandlerCurrentWriterSlice) IndexBySupersededBy() (WriterHandlerCurrentWriterIndexedBySupersededBy, error)
func (WriterHandlerCurrentWriterSlice) IndexByTags ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTags() (WriterHandlerCurrentWriterIndexedByTags, error)
func (WriterHandlerCurrentWriterSlice) IndexByToolName ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByToolName() (WriterHandlerCurrentWriterIndexedByToolName, error)
func (WriterHandlerCurrentWriterSlice) IndexByTurnId ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error)
func (WriterHandlerCurrentWriterSlice) IndexByType ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByType() (WriterHandlerCurrentWriterIndexedByType, error)
func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt ¶
func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error)
type WriterHandlerReadIndexes ¶
type WriterHandlerReadIndexes struct {
CurrentWriter WriterHandlerCurrentWriterSlice
CurrentWriterById WriterHandlerCurrentWriterIndexedById
}
func BuildWriterHandlerReadIndexes ¶
func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error)
type WriterKeysRow ¶
type WriterKeysRow struct {
Id string `sqlx:"id"`
}