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 WriterHandlerCurrentWriterIndexByConversationIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByCreatedAtKey(value *CurrentWriterView) (time.Time, bool) + func WriterHandlerCurrentWriterIndexByIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByMessageIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByQueueSeqKey(value *CurrentWriterView) (int64, bool) + func WriterHandlerCurrentWriterIndexByStatusKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByTurnIdKey(value *CurrentWriterView) (string, bool) + func WriterHandlerCurrentWriterIndexByUpdatedAtKey(value *CurrentWriterView) (time.Time, bool) + type CurrentWriterView struct + ConversationId string + CreatedAt *time.Time + Id string + MessageId string + QueueSeq *int64 + Status string + TurnId string + UpdatedAt *time.Time + type Input struct + CurrentWriter []*CurrentWriterView + Has *InputHas + Queues []*TurnQueue + 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) SetQueues(value []*TurnQueue) + func (input *Input) SetWriterKeys(value []WriterKeysRow) + type InputHas struct + CurrentWriter bool + Queues bool + WriterKeys bool + type Lifecycle struct + func (hooks *Lifecycle) AfterQueue(ctx context.Context, entity *TurnQueue, ...) error + func (hooks *Lifecycle) AfterSequence(ctx context.Context, entity *TurnQueue, ...) error + func (hooks *Lifecycle) Finalize(ctx context.Context, input *Input, output *Output, outcome xhandler.Outcome) error + func (hooks *Lifecycle) Init(ctx context.Context, entity *TurnQueue, ...) error + func (hooks *Lifecycle) Validate(ctx context.Context, entity *TurnQueue, ...) error + type Output struct + Data []*TurnQueue + type TurnQueue struct + ConversationId string + CreatedAt *time.Time + Has *TurnQueueHas + Id string + MessageId string + QueueSeq *int64 + ShouldDelete bool + Status string + TurnId string + UpdatedAt *time.Time + func (entity *TurnQueue) GetConversationId() string + func (entity *TurnQueue) GetCreatedAt() *time.Time + func (entity *TurnQueue) GetId() string + func (entity *TurnQueue) GetMessageId() string + func (entity *TurnQueue) GetQueueSeq() *int64 + func (entity *TurnQueue) GetShouldDelete() bool + func (entity *TurnQueue) GetStatus() string + func (entity *TurnQueue) GetTurnId() string + func (entity *TurnQueue) GetUpdatedAt() *time.Time + func (entity *TurnQueue) SetConversationId(value string) + func (entity *TurnQueue) SetCreatedAt(value *time.Time) + func (entity *TurnQueue) SetId(value string) + func (entity *TurnQueue) SetMessageId(value string) + func (entity *TurnQueue) SetQueueSeq(value *int64) + func (entity *TurnQueue) SetShouldDelete(value bool) + func (entity *TurnQueue) SetStatus(value string) + func (entity *TurnQueue) SetTurnId(value string) + func (entity *TurnQueue) SetUpdatedAt(value *time.Time) + type TurnQueueHas struct + ConversationId bool + CreatedAt bool + Id bool + MessageId bool + QueueSeq bool + ShouldDelete bool + Status bool + TurnId bool + UpdatedAt bool + type WriterComponent struct + Contract xdatly.Component[Input, Output] + func (WriterComponent) EmbedFS() *embed.FS + func (WriterComponent) EmbedNamespace() string + 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 WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedById) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByMessageId) Has(key string) bool + type WriterHandlerCurrentWriterGroupedByQueueSeq map[int64][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByQueueSeq) Has(key int64) bool + type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView + func (index WriterHandlerCurrentWriterGroupedByStatus) 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 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 WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedById) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByMessageId) Has(key string) bool + type WriterHandlerCurrentWriterIndexedByQueueSeq map[int64]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByQueueSeq) Has(key int64) bool + type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView + func (index WriterHandlerCurrentWriterIndexedByStatus) 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 WriterHandlerCurrentWriterSlice []*CurrentWriterView + func (rows WriterHandlerCurrentWriterSlice) GroupByConversationId() WriterHandlerCurrentWriterGroupedByConversationId + func (rows WriterHandlerCurrentWriterSlice) GroupByCreatedAt() WriterHandlerCurrentWriterGroupedByCreatedAt + func (rows WriterHandlerCurrentWriterSlice) GroupById() WriterHandlerCurrentWriterGroupedById + func (rows WriterHandlerCurrentWriterSlice) GroupByMessageId() WriterHandlerCurrentWriterGroupedByMessageId + func (rows WriterHandlerCurrentWriterSlice) GroupByQueueSeq() WriterHandlerCurrentWriterGroupedByQueueSeq + func (rows WriterHandlerCurrentWriterSlice) GroupByStatus() WriterHandlerCurrentWriterGroupedByStatus + func (rows WriterHandlerCurrentWriterSlice) GroupByTurnId() WriterHandlerCurrentWriterGroupedByTurnId + func (rows WriterHandlerCurrentWriterSlice) GroupByUpdatedAt() WriterHandlerCurrentWriterGroupedByUpdatedAt + func (rows WriterHandlerCurrentWriterSlice) IndexByConversationId() (WriterHandlerCurrentWriterIndexedByConversationId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByCreatedAt() (WriterHandlerCurrentWriterIndexedByCreatedAt, error) + func (rows WriterHandlerCurrentWriterSlice) IndexById() (WriterHandlerCurrentWriterIndexedById, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByMessageId() (WriterHandlerCurrentWriterIndexedByMessageId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByQueueSeq() (WriterHandlerCurrentWriterIndexedByQueueSeq, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByStatus() (WriterHandlerCurrentWriterIndexedByStatus, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByTurnId() (WriterHandlerCurrentWriterIndexedByTurnId, error) + func (rows WriterHandlerCurrentWriterSlice) IndexByUpdatedAt() (WriterHandlerCurrentWriterIndexedByUpdatedAt, 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