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

Documentation

Index

Constants

View Source
const MaxContentBytes = 16777215

MaxContentBytes preserves the legacy MEDIUMTEXT limit.

View Source
const WriterDatlyResourceNamespace = "datly_message_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 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) Init

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

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 *Input) SetDetachLinks(value bool)

func (*Input) SetDetachMessageIDs

func (input *Input) SetDetachMessageIDs(value []string)

func (*Input) SetMessages

func (input *Input) SetMessages(value []*Message)

func (*Input) SetOrphanColumn

func (input *Input) SetOrphanColumn(value string)

func (*Input) SetOrphanDetach

func (input *Input) SetOrphanDetach(value bool)

func (*Input) SetTerminalCleanup

func (input *Input) SetTerminalCleanup(value bool)

func (*Input) SetWriterKeys

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

type InputHas

type InputHas struct {
	OrphanDetach     bool
	OrphanColumn     bool
	DetachLinks      bool
	TerminalCleanup  bool
	DetachMessageIDs bool
	Messages         bool
	WriterKeys       bool
	CurrentWriter    bool
}

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 (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *Message, state xhandler.LifecycleContext[Message, xhandler.NoParent, Output]) error

func (*Lifecycle) AfterSequence

func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *Message, state xhandler.LifecycleContext[Message, 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 (*Lifecycle) Validate

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

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 (entity *Message) GetArchived() *int

func (*Message) GetAttachmentPayloadId

func (entity *Message) GetAttachmentPayloadId() *string

func (*Message) GetContent

func (entity *Message) GetContent() *string

func (*Message) GetContextSummary

func (entity *Message) GetContextSummary() *string

func (*Message) GetConversationId

func (entity *Message) GetConversationId() string

func (*Message) GetCreatedAt

func (entity *Message) GetCreatedAt() *time.Time

func (*Message) GetCreatedByUserId

func (entity *Message) GetCreatedByUserId() *string

func (*Message) GetElicitationId

func (entity *Message) GetElicitationId() *string

func (*Message) GetElicitationPayloadId

func (entity *Message) GetElicitationPayloadId() *string

func (*Message) GetEmbeddingIndex

func (entity *Message) GetEmbeddingIndex() *[]byte

func (*Message) GetId

func (entity *Message) GetId() string

func (*Message) GetInterim

func (entity *Message) GetInterim() *int

func (*Message) GetIteration

func (entity *Message) GetIteration() *int

func (*Message) GetLinkedConversationId

func (entity *Message) GetLinkedConversationId() *string

func (*Message) GetMode

func (entity *Message) GetMode() *string

func (*Message) GetNarration

func (entity *Message) GetNarration() *string

func (*Message) GetParentMessageId

func (entity *Message) GetParentMessageId() *string

func (*Message) GetPhase

func (entity *Message) GetPhase() *string

func (*Message) GetRawContent

func (entity *Message) GetRawContent() *string

func (*Message) GetRole

func (entity *Message) GetRole() string

func (*Message) GetSequence

func (entity *Message) GetSequence() *int

func (*Message) GetShouldDelete

func (entity *Message) GetShouldDelete() bool

func (*Message) GetStatus

func (entity *Message) GetStatus() *string

func (*Message) GetSummary

func (entity *Message) GetSummary() *string

func (*Message) GetSupersededBy

func (entity *Message) GetSupersededBy() *string

func (*Message) GetTags

func (entity *Message) GetTags() *string

func (*Message) GetToolName

func (entity *Message) GetToolName() *string

func (*Message) GetTurnId

func (entity *Message) GetTurnId() *string

func (*Message) GetType

func (entity *Message) GetType() string

func (*Message) GetUpdatedAt

func (entity *Message) GetUpdatedAt() *time.Time

func (*Message) SetArchived

func (entity *Message) SetArchived(value *int)

func (*Message) SetAttachmentPayloadId

func (entity *Message) SetAttachmentPayloadId(value *string)

func (*Message) SetContent

func (entity *Message) SetContent(value *string)

func (*Message) SetContextSummary

func (entity *Message) SetContextSummary(value *string)

func (*Message) SetConversationId

func (entity *Message) SetConversationId(value string)

func (*Message) SetCreatedAt

func (entity *Message) SetCreatedAt(value *time.Time)

func (*Message) SetCreatedByUserId

func (entity *Message) SetCreatedByUserId(value *string)

func (*Message) SetElicitationId

func (entity *Message) SetElicitationId(value *string)

func (*Message) SetElicitationPayloadId

func (entity *Message) SetElicitationPayloadId(value *string)

func (*Message) SetEmbeddingIndex

func (entity *Message) SetEmbeddingIndex(value *[]byte)

func (*Message) SetId

func (entity *Message) SetId(value string)

func (*Message) SetInterim

func (entity *Message) SetInterim(value *int)

func (*Message) SetIteration

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

func (*Message) SetLinkedConversationId

func (entity *Message) SetLinkedConversationId(value *string)

func (*Message) SetMode

func (entity *Message) SetMode(value *string)

func (*Message) SetNarration

func (entity *Message) SetNarration(value *string)

func (*Message) SetParentMessageId

func (entity *Message) SetParentMessageId(value *string)

func (*Message) SetPhase

func (entity *Message) SetPhase(value *string)

func (*Message) SetRawContent

func (entity *Message) SetRawContent(value *string)

func (*Message) SetRole

func (entity *Message) SetRole(value string)

func (*Message) SetSequence

func (entity *Message) SetSequence(value *int)

func (*Message) SetShouldDelete

func (entity *Message) SetShouldDelete(value bool)

func (*Message) SetStatus

func (entity *Message) SetStatus(value *string)

func (*Message) SetSummary

func (entity *Message) SetSummary(value *string)

func (*Message) SetSupersededBy

func (entity *Message) SetSupersededBy(value *string)

func (*Message) SetTags

func (entity *Message) SetTags(value *string)

func (*Message) SetToolName

func (entity *Message) SetToolName(value *string)

func (*Message) SetTurnId

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

func (*Message) SetType

func (entity *Message) SetType(value string)

func (*Message) SetUpdatedAt

func (entity *Message) SetUpdatedAt(value *time.Time)

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

type WriterHandlerCurrentWriterGroupedByAttachmentPayloadId

type WriterHandlerCurrentWriterGroupedByAttachmentPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByAttachmentPayloadId) Has

type WriterHandlerCurrentWriterGroupedByContent

type WriterHandlerCurrentWriterGroupedByContent map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByContent) Has

type WriterHandlerCurrentWriterGroupedByContextSummary

type WriterHandlerCurrentWriterGroupedByContextSummary map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByContextSummary) Has

type WriterHandlerCurrentWriterGroupedByConversationId

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByConversationId) Has

type WriterHandlerCurrentWriterGroupedByCreatedAt

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

func (WriterHandlerCurrentWriterGroupedByCreatedAt) Has

type WriterHandlerCurrentWriterGroupedByCreatedByUserId

type WriterHandlerCurrentWriterGroupedByCreatedByUserId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByCreatedByUserId) Has

type WriterHandlerCurrentWriterGroupedByElicitationId

type WriterHandlerCurrentWriterGroupedByElicitationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByElicitationId) Has

type WriterHandlerCurrentWriterGroupedByElicitationPayloadId

type WriterHandlerCurrentWriterGroupedByElicitationPayloadId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByElicitationPayloadId) Has

type WriterHandlerCurrentWriterGroupedById

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedById) Has

type WriterHandlerCurrentWriterGroupedByInterim

type WriterHandlerCurrentWriterGroupedByInterim map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByInterim) Has

type WriterHandlerCurrentWriterGroupedByIteration

type WriterHandlerCurrentWriterGroupedByIteration map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByIteration) Has

type WriterHandlerCurrentWriterGroupedByLinkedConversationId

type WriterHandlerCurrentWriterGroupedByLinkedConversationId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByLinkedConversationId) Has

type WriterHandlerCurrentWriterGroupedByMode

type WriterHandlerCurrentWriterGroupedByMode map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByMode) Has

type WriterHandlerCurrentWriterGroupedByNarration

type WriterHandlerCurrentWriterGroupedByNarration map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByNarration) Has

type WriterHandlerCurrentWriterGroupedByParentMessageId

type WriterHandlerCurrentWriterGroupedByParentMessageId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByParentMessageId) Has

type WriterHandlerCurrentWriterGroupedByPhase

type WriterHandlerCurrentWriterGroupedByPhase map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByPhase) Has

type WriterHandlerCurrentWriterGroupedByRawContent

type WriterHandlerCurrentWriterGroupedByRawContent map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRawContent) Has

type WriterHandlerCurrentWriterGroupedByRole

type WriterHandlerCurrentWriterGroupedByRole map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByRole) Has

type WriterHandlerCurrentWriterGroupedBySequence

type WriterHandlerCurrentWriterGroupedBySequence map[int][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySequence) Has

type WriterHandlerCurrentWriterGroupedByStatus

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByStatus) Has

type WriterHandlerCurrentWriterGroupedBySummary

type WriterHandlerCurrentWriterGroupedBySummary map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySummary) Has

type WriterHandlerCurrentWriterGroupedBySupersededBy

type WriterHandlerCurrentWriterGroupedBySupersededBy map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedBySupersededBy) Has

type WriterHandlerCurrentWriterGroupedByTags

type WriterHandlerCurrentWriterGroupedByTags map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTags) Has

type WriterHandlerCurrentWriterGroupedByToolName

type WriterHandlerCurrentWriterGroupedByToolName map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByToolName) Has

type WriterHandlerCurrentWriterGroupedByTurnId

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByTurnId) Has

type WriterHandlerCurrentWriterGroupedByType

type WriterHandlerCurrentWriterGroupedByType map[string][]*CurrentWriterView

func (WriterHandlerCurrentWriterGroupedByType) Has

type WriterHandlerCurrentWriterGroupedByUpdatedAt

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

func (WriterHandlerCurrentWriterGroupedByUpdatedAt) Has

type WriterHandlerCurrentWriterIndexedByArchived

type WriterHandlerCurrentWriterIndexedByArchived map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByArchived) Has

type WriterHandlerCurrentWriterIndexedByAttachmentPayloadId

type WriterHandlerCurrentWriterIndexedByAttachmentPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByAttachmentPayloadId) Has

type WriterHandlerCurrentWriterIndexedByContent

type WriterHandlerCurrentWriterIndexedByContent map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByContent) Has

type WriterHandlerCurrentWriterIndexedByContextSummary

type WriterHandlerCurrentWriterIndexedByContextSummary map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByContextSummary) Has

type WriterHandlerCurrentWriterIndexedByConversationId

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByConversationId) Has

type WriterHandlerCurrentWriterIndexedByCreatedAt

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedAt) Has

type WriterHandlerCurrentWriterIndexedByCreatedByUserId

type WriterHandlerCurrentWriterIndexedByCreatedByUserId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByCreatedByUserId) Has

type WriterHandlerCurrentWriterIndexedByElicitationId

type WriterHandlerCurrentWriterIndexedByElicitationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByElicitationId) Has

type WriterHandlerCurrentWriterIndexedByElicitationPayloadId

type WriterHandlerCurrentWriterIndexedByElicitationPayloadId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByElicitationPayloadId) Has

type WriterHandlerCurrentWriterIndexedById

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedById) Has

type WriterHandlerCurrentWriterIndexedByInterim

type WriterHandlerCurrentWriterIndexedByInterim map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByInterim) Has

type WriterHandlerCurrentWriterIndexedByIteration

type WriterHandlerCurrentWriterIndexedByIteration map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByIteration) Has

type WriterHandlerCurrentWriterIndexedByLinkedConversationId

type WriterHandlerCurrentWriterIndexedByLinkedConversationId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByLinkedConversationId) Has

type WriterHandlerCurrentWriterIndexedByMode

type WriterHandlerCurrentWriterIndexedByMode map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByMode) Has

type WriterHandlerCurrentWriterIndexedByNarration

type WriterHandlerCurrentWriterIndexedByNarration map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByNarration) Has

type WriterHandlerCurrentWriterIndexedByParentMessageId

type WriterHandlerCurrentWriterIndexedByParentMessageId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByParentMessageId) Has

type WriterHandlerCurrentWriterIndexedByPhase

type WriterHandlerCurrentWriterIndexedByPhase map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByPhase) Has

type WriterHandlerCurrentWriterIndexedByRawContent

type WriterHandlerCurrentWriterIndexedByRawContent map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRawContent) Has

type WriterHandlerCurrentWriterIndexedByRole

type WriterHandlerCurrentWriterIndexedByRole map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByRole) Has

type WriterHandlerCurrentWriterIndexedBySequence

type WriterHandlerCurrentWriterIndexedBySequence map[int]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySequence) Has

type WriterHandlerCurrentWriterIndexedByStatus

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByStatus) Has

type WriterHandlerCurrentWriterIndexedBySummary

type WriterHandlerCurrentWriterIndexedBySummary map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySummary) Has

type WriterHandlerCurrentWriterIndexedBySupersededBy

type WriterHandlerCurrentWriterIndexedBySupersededBy map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedBySupersededBy) Has

type WriterHandlerCurrentWriterIndexedByTags

type WriterHandlerCurrentWriterIndexedByTags map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTags) Has

type WriterHandlerCurrentWriterIndexedByToolName

type WriterHandlerCurrentWriterIndexedByToolName map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByToolName) Has

type WriterHandlerCurrentWriterIndexedByTurnId

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByTurnId) Has

type WriterHandlerCurrentWriterIndexedByType

type WriterHandlerCurrentWriterIndexedByType map[string]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByType) Has

type WriterHandlerCurrentWriterIndexedByUpdatedAt

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

func (WriterHandlerCurrentWriterIndexedByUpdatedAt) Has

type WriterHandlerCurrentWriterSlice

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

func (WriterHandlerCurrentWriterSlice) GroupByArchived

func (WriterHandlerCurrentWriterSlice) GroupByAttachmentPayloadId

func (WriterHandlerCurrentWriterSlice) GroupByContent

func (WriterHandlerCurrentWriterSlice) GroupByContextSummary

func (WriterHandlerCurrentWriterSlice) GroupByConversationId

func (WriterHandlerCurrentWriterSlice) GroupByCreatedAt

func (WriterHandlerCurrentWriterSlice) GroupByCreatedByUserId

func (WriterHandlerCurrentWriterSlice) GroupByElicitationId

func (WriterHandlerCurrentWriterSlice) GroupByElicitationPayloadId

func (WriterHandlerCurrentWriterSlice) GroupById

func (WriterHandlerCurrentWriterSlice) GroupByInterim

func (WriterHandlerCurrentWriterSlice) GroupByIteration

func (WriterHandlerCurrentWriterSlice) GroupByLinkedConversationId

func (WriterHandlerCurrentWriterSlice) GroupByMode

func (WriterHandlerCurrentWriterSlice) GroupByNarration

func (WriterHandlerCurrentWriterSlice) GroupByParentMessageId

func (WriterHandlerCurrentWriterSlice) GroupByPhase

func (WriterHandlerCurrentWriterSlice) GroupByRawContent

func (WriterHandlerCurrentWriterSlice) GroupByRole

func (WriterHandlerCurrentWriterSlice) GroupBySequence

func (WriterHandlerCurrentWriterSlice) GroupByStatus

func (WriterHandlerCurrentWriterSlice) GroupBySummary

func (WriterHandlerCurrentWriterSlice) GroupBySupersededBy

func (WriterHandlerCurrentWriterSlice) GroupByTags

func (WriterHandlerCurrentWriterSlice) GroupByToolName

func (WriterHandlerCurrentWriterSlice) GroupByTurnId

func (WriterHandlerCurrentWriterSlice) GroupByType

func (WriterHandlerCurrentWriterSlice) GroupByUpdatedAt

func (WriterHandlerCurrentWriterSlice) IndexByArchived

func (WriterHandlerCurrentWriterSlice) IndexByAttachmentPayloadId

func (WriterHandlerCurrentWriterSlice) IndexByContent

func (WriterHandlerCurrentWriterSlice) IndexByContextSummary

func (WriterHandlerCurrentWriterSlice) IndexByConversationId

func (WriterHandlerCurrentWriterSlice) IndexByCreatedAt

func (WriterHandlerCurrentWriterSlice) IndexByCreatedByUserId

func (WriterHandlerCurrentWriterSlice) IndexByElicitationId

func (WriterHandlerCurrentWriterSlice) IndexByElicitationPayloadId

func (WriterHandlerCurrentWriterSlice) IndexById

func (WriterHandlerCurrentWriterSlice) IndexByInterim

func (WriterHandlerCurrentWriterSlice) IndexByIteration

func (WriterHandlerCurrentWriterSlice) IndexByLinkedConversationId

func (WriterHandlerCurrentWriterSlice) IndexByMode

func (WriterHandlerCurrentWriterSlice) IndexByNarration

func (WriterHandlerCurrentWriterSlice) IndexByParentMessageId

func (WriterHandlerCurrentWriterSlice) IndexByPhase

func (WriterHandlerCurrentWriterSlice) IndexByRawContent

func (WriterHandlerCurrentWriterSlice) IndexByRole

func (WriterHandlerCurrentWriterSlice) IndexBySequence

func (WriterHandlerCurrentWriterSlice) IndexByStatus

func (WriterHandlerCurrentWriterSlice) IndexBySummary

func (WriterHandlerCurrentWriterSlice) IndexBySupersededBy

func (WriterHandlerCurrentWriterSlice) IndexByTags

func (WriterHandlerCurrentWriterSlice) IndexByToolName

func (WriterHandlerCurrentWriterSlice) IndexByTurnId

func (WriterHandlerCurrentWriterSlice) IndexByType

func (WriterHandlerCurrentWriterSlice) IndexByUpdatedAt

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"`
}

Jump to

Keyboard shortcuts

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