write

type CurrentWriterView struct {
	Id             string     `validate:"required" sqlx:"id,primaryKey" json:"id,omitempty"`
	ConversationId string     `sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true" json:"conversationId,omitempty"`
	TurnId         string     `sqlx:"turn_id,refTable=turn,refColumn=id,required=true" json:"turnId,omitempty"`
	MessageId      string     `sqlx:"message_id,refTable=message,refColumn=id,required=true" json:"messageId,omitempty"`
	QueueSeq       *int64     `json:"queueSeq,omitempty" sqlx:"queue_seq,required=true"`
	Status         string     `sqlx:"status,required=true" json:"status,omitempty"`
	CreatedAt      *time.Time `json:"createdAt,omitempty" sqlx:"created_at,required=true"`
	UpdatedAt      *time.Time `json:"updatedAt,omitempty" sqlx:"updated_at"`
}

type Input struct {
	Queues        []*TurnQueue         `` /* 204-byte string literal not displayed */
	WriterKeys    []WriterKeysRow      `` /* 132-byte string literal not displayed */
	CurrentWriter []*CurrentWriterView `` /* 169-byte string literal not displayed */

	Has *InputHas `setMarker:"true" typeName:"InputHas" json:"-" sqlx:"-"`
	// contains filtered or unexported fields
}

type InputHas struct {
	Queues        bool
	WriterKeys    bool
	CurrentWriter bool
}

type Lifecycle struct{}

type Output struct {
	Data []*TurnQueue `parameter:"Data,kind=output,in=body,dataType=[]*TurnQueue" json:"data"`
}

type TurnQueue struct {
	ShouldDelete   bool          `json:"shouldDelete,omitempty" sqlx:"-" writer:"delete"`
	Id             string        `validate:"required" sqlx:"id,primaryKey" json:"id,omitempty"`
	ConversationId string        `sqlx:"conversation_id,refTable=conversation,refColumn=id,required=true" json:"conversationId,omitempty"`
	TurnId         string        `sqlx:"turn_id,refTable=turn,refColumn=id,required=true" json:"turnId,omitempty"`
	MessageId      string        `sqlx:"message_id,refTable=message,refColumn=id,required=true" json:"messageId,omitempty"`
	QueueSeq       *int64        `json:"queueSeq,omitempty" sqlx:"queue_seq,required=true"`
	Status         string        `sqlx:"status,required=true" json:"status,omitempty"`
	CreatedAt      *time.Time    `json:"createdAt,omitempty" sqlx:"created_at,required=true"`
	UpdatedAt      *time.Time    `json:"updatedAt,omitempty" sqlx:"updated_at"`
	Has            *TurnQueueHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-" typeName:"TurnQueueHas"`
}

type TurnQueueHas struct {
	ShouldDelete   bool
	Id             bool
	ConversationId bool
	TurnId         bool
	MessageId      bool
	QueueSeq       bool
	Status         bool
	CreatedAt      bool
	UpdatedAt      bool
}

type WriterComponent struct {
	Contract xdatly.Component[Input, Output] "" /* 166-byte string literal not displayed */
}

type WriterHandlerCurrentWriterGroupedByConversationId map[string][]*CurrentWriterView

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

type WriterHandlerCurrentWriterGroupedById map[string][]*CurrentWriterView

type WriterHandlerCurrentWriterGroupedByMessageId map[string][]*CurrentWriterView

type WriterHandlerCurrentWriterGroupedByQueueSeq map[int64][]*CurrentWriterView

type WriterHandlerCurrentWriterGroupedByStatus map[string][]*CurrentWriterView

type WriterHandlerCurrentWriterGroupedByTurnId map[string][]*CurrentWriterView

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

type WriterHandlerCurrentWriterIndexedByConversationId map[string]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByCreatedAt map[time.Time]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedById map[string]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByMessageId map[string]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByQueueSeq map[int64]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByStatus map[string]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByTurnId map[string]*CurrentWriterView

type WriterHandlerCurrentWriterIndexedByUpdatedAt map[time.Time]*CurrentWriterView

type WriterHandlerCurrentWriterSlice []*CurrentWriterView

type WriterHandlerReadIndexes struct {
	CurrentWriter     WriterHandlerCurrentWriterSlice
	CurrentWriterById WriterHandlerCurrentWriterIndexedById
}

type WriterKeysRow struct {
	Id string `sqlx:"id"`
}