Versions in this module Expand all Collapse all v0 v0.1.58 Oct 26, 2026 v0.1.57 Oct 26, 2026 Changes in this version + const WriterDatlyResourceNamespace + var LifecycleDatly = LifecycleDatlyType() + var LifecycleHooks = new(Lifecycle) + var WriterDatly = new(WriterComponent) + var WriterDatlyResources embed.FS + func LifecycleDatlyType() reflect.Type + func WriterDatlyType() reflect.Type + func WriterHandlerCurrentWriterIndexByApprovedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByApprovedByUserIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByCompletedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByDecisionKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByErrorMessageKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByExecutedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByExpiresAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByMessageIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByTimedOutAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByTitleKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByToolNameKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByUserIdKey(value *CurrentWriterView) (string, bool) + type CurrentWriterView struct + ApprovedAt *time.Time + ApprovedByUserId *string + Arguments []byte + CompletedAt *time.Time + ConversationId *string + CreatedAt *time.Time + Decision *string + ErrorMessage *string + ExecutedAt *time.Time + ExpiresAt *time.Time + Id string + MessageId *string + Metadata *[]byte + Status string + TimedOutAt *time.Time + Title *string + ToolName string + TurnId *string + UpdatedAt *time.Time + UserId string + type Input struct + CurrentWriter []*CurrentWriterView + Has *InputHas + OrphanColumn string + OrphanDetach bool + Queues []*ToolApprovalQueue + WriterKeys []WriterKeysRow + 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) SetOrphanColumn(value string) + func (input *Input) SetOrphanDetach(value bool) + func (input *Input) SetQueues(value []*ToolApprovalQueue) + func (input *Input) SetWriterKeys(value []WriterKeysRow) + type InputHas struct + CurrentWriter bool + OrphanColumn bool + OrphanDetach bool + Queues bool + WriterKeys bool + type Lifecycle struct + Input *Input + func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *ToolApprovalQueue, ...) error + func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *ToolApprovalQueue, ...) error + func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error + func (hooks *Lifecycle) Init(ctx context.Context, entity *ToolApprovalQueue, ...) error + func (hooks *Lifecycle) Validate(ctx context.Context, entity *ToolApprovalQueue, ...) error + type Output struct + Data []*ToolApprovalQueue + type ToolApprovalQueue struct + ApprovedAt *time.Time + ApprovedByUserId *string + Arguments []byte + CompletedAt *time.Time + ConversationId *string + CreatedAt *time.Time + Decision *string + ErrorMessage *string + ExecutedAt *time.Time + ExpiresAt *time.Time + Has *ToolApprovalQueueHas + Id string + MessageId *string + Metadata *[]byte + ShouldDelete bool + Status string + TimedOutAt *time.Time + Title *string + ToolName string + TurnId *string + UpdatedAt *time.Time + UserId string + func (entity *ToolApprovalQueue) GetApprovedAt() *time.Time + func (entity *ToolApprovalQueue) GetApprovedByUserId() *string + func (entity *ToolApprovalQueue) GetArguments() []byte + func (entity *ToolApprovalQueue) GetCompletedAt() *time.Time + func (entity *ToolApprovalQueue) GetConversationId() *string + func (entity *ToolApprovalQueue) GetCreatedAt() *time.Time + func (entity *ToolApprovalQueue) GetDecision() *string + func (entity *ToolApprovalQueue) GetErrorMessage() *string + func (entity *ToolApprovalQueue) GetExecutedAt() *time.Time + func (entity *ToolApprovalQueue) GetExpiresAt() *time.Time + func (entity *ToolApprovalQueue) GetId() string + func (entity *ToolApprovalQueue) GetMessageId() *string + func (entity *ToolApprovalQueue) GetMetadata() *[]byte + func (entity *ToolApprovalQueue) GetShouldDelete() bool + func (entity *ToolApprovalQueue) GetStatus() string + func (entity *ToolApprovalQueue) GetTimedOutAt() *time.Time + func (entity *ToolApprovalQueue) GetTitle() *string + func (entity *ToolApprovalQueue) GetToolName() string + func (entity *ToolApprovalQueue) GetTurnId() *string + func (entity *ToolApprovalQueue) GetUpdatedAt() *time.Time + func (entity *ToolApprovalQueue) GetUserId() string + func (entity *ToolApprovalQueue) SetApprovedAt(value *time.Time) + func (entity *ToolApprovalQueue) SetApprovedByUserId(value *string) + func (entity *ToolApprovalQueue) SetArguments(value []byte) + func (entity *ToolApprovalQueue) SetCompletedAt(value *time.Time) + func (entity *ToolApprovalQueue) SetConversationId(value *string) + func (entity *ToolApprovalQueue) SetCreatedAt(value *time.Time) + func (entity *ToolApprovalQueue) SetDecision(value *string) + func (entity *ToolApprovalQueue) SetErrorMessage(value *string) + func (entity *ToolApprovalQueue) SetExecutedAt(value *time.Time) + func (entity *ToolApprovalQueue) SetExpiresAt(value *time.Time) + func (entity *ToolApprovalQueue) SetId(value string) + func (entity *ToolApprovalQueue) SetMessageId(value *string) + func (entity *ToolApprovalQueue) SetMetadata(value *[]byte) + func (entity *ToolApprovalQueue) SetShouldDelete(value bool) + func (entity *ToolApprovalQueue) SetStatus(value string) + func (entity *ToolApprovalQueue) SetTimedOutAt(value *time.Time) + func (entity *ToolApprovalQueue) SetTitle(value *string) + func (entity *ToolApprovalQueue) SetToolName(value string) + func (entity *ToolApprovalQueue) SetTurnId(value *string) + func (entity *ToolApprovalQueue) SetUpdatedAt(value *time.Time) + func (entity *ToolApprovalQueue) SetUserId(value string) + type ToolApprovalQueueHas struct + ApprovedAt bool + ApprovedByUserId bool + Arguments bool + CompletedAt bool + ConversationId bool + CreatedAt bool + Decision bool + ErrorMessage bool + ExecutedAt bool + ExpiresAt bool + Id bool + MessageId bool + Metadata bool + ShouldDelete bool + Status bool + TimedOutAt bool + Title bool + ToolName bool + TurnId bool + UpdatedAt bool + UserId bool + type WriterComponent struct + Contract xdatly.Component[Input, Output] + func (WriterComponent) EmbedFS() *embed.FS + func (WriterComponent) EmbedNamespace() string + type WriterHandlerCurrentWriterGroupedByApprovedAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByApprovedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByApprovedByUserId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByApprovedByUserId) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByCompletedAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByCompletedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByConversationId) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByCreatedAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByCreatedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByDecision map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByDecision) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByErrorMessage map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByErrorMessage) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByExecutedAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByExecutedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByExpiresAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByExpiresAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByMessageId) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByStatus) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByTimedOutAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByTimedOutAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByTitle map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByTitle) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByToolName map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByToolName) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByTurnId) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByUpdatedAt map[time.Time][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByUpdatedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterGroupedByUserId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByUserId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByApprovedAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByApprovedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByApprovedByUserId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByApprovedByUserId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByCompletedAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByCompletedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByConversationId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByCreatedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByDecision map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByDecision) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByErrorMessage map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByErrorMessage) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByExecutedAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByExecutedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByExpiresAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByExpiresAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByMessageId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByStatus) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByTimedOutAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByTimedOutAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByTitle map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByTitle) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByToolName map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByToolName) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByTurnId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByUpdatedAt) Has(key time.Time) bool + type WriterHandlerCurrentWriterIndexedByUserId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByUserId) Has(key string) bool + type WriterHandlerCurrentWriterSlice []*CurrentWriterView + func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedAt() WriterHandlerCurrentWriterGroupedByApprovedAt + func (rows WriterHandlerCurrentWriterSlice) GroupByApprovedByUserId() WriterHandlerCurrentWriterGroupedByApprovedByUserId + func (rows WriterHandlerCurrentWriterSlice) GroupByCompletedAt() WriterHandlerCurrentWriterGroupedByCompletedAt + func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId + func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt + func (rows WriterHandlerCurrentWriterSlice) GroupByDecision() WriterHandlerCurrentWriterGroupedByDecision + func (rows WriterHandlerCurrentWriterSlice) GroupByErrorMessage() WriterHandlerCurrentWriterGroupedByErrorMessage + func (rows WriterHandlerCurrentWriterSlice) GroupByExecutedAt() WriterHandlerCurrentWriterGroupedByExecutedAt + func (rows WriterHandlerCurrentWriterSlice) GroupByExpiresAt() WriterHandlerCurrentWriterGroupedByExpiresAt + func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById + func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId + func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus + func (rows WriterHandlerCurrentWriterSlice) GroupByTimedOutAt() WriterHandlerCurrentWriterGroupedByTimedOutAt + func (rows WriterHandlerCurrentWriterSlice) GroupByTitle() WriterHandlerCurrentWriterGroupedByTitle + func (rows WriterHandlerCurrentWriterSlice) GroupByToolName() WriterHandlerCurrentWriterGroupedByToolName + func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId + func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt + func (rows WriterHandlerCurrentWriterSlice) GroupByUserId() WriterHandlerCurrentWriterGroupedByUserId + func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedAt() (WriterHandlerCurrentWriterIndexedByApprovedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByApprovedByUserId() (WriterHandlerCurrentWriterIndexedByApprovedByUserId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByCompletedAt() (WriterHandlerCurrentWriterIndexedByCompletedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByDecision() (WriterHandlerCurrentWriterIndexedByDecision, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByErrorMessage() (WriterHandlerCurrentWriterIndexedByErrorMessage, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByExecutedAt() (WriterHandlerCurrentWriterIndexedByExecutedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByExpiresAt() (WriterHandlerCurrentWriterIndexedByExpiresAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByMessageId() (WriterHandlerCurrentWriterIndexedByMessageId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByTimedOutAt() (WriterHandlerCurrentWriterIndexedByTimedOutAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByTitle() (WriterHandlerCurrentWriterIndexedByTitle, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByToolName() (WriterHandlerCurrentWriterIndexedByToolName, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByUserId() (WriterHandlerCurrentWriterIndexedByUserId, error) + type WriterHandlerReadIndexes struct + CurrentWriter WriterHandlerCurrentWriterSlice + CurrentWriterById WriterHandlerCurrentWriterIndexedById + func BuildWriterHandlerReadIndexes(ctx context.Context, input *Input) (*WriterHandlerReadIndexes, error) + type WriterKeysRow struct + Id string
Go to main page