Help us shape the future of Go! Take the 2026 Go Developer Survey

read

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

Documentation

Index

Constants

View Source
const ReaderDatlyResourceNamespace = "datly_turnqueue_read_reader"

DatlyResourceNamespace identifies this package's generated resource filesystem.

Variables

View Source
var ReaderDatly = new(ReaderComponent)

The public value supports explicit component wiring.

View Source
var ReaderDatlyResources embed.FS

Functions

func ReaderDatlyType

func ReaderDatlyType() reflect.Type

ReaderDatlyType returns the public component type.

Types

type QueueRowView

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

QueueRowView is generated canonical view metadata for reader.

type QueueRowsInput

type QueueRowsInput struct {
	Id               string             `parameter:"Id,kind=query,in=id,dataType=string,required=false" predicate:"equal,q,id"`
	ConversationId   string             `parameter:"ConversationId,kind=query,in=conversationId,dataType=string,required=false" predicate:"equal,q,conversation_id"`
	ConversationIds  []string           `parameter:"ConversationIds,kind=query,in=conversationIds,dataType=[]string,required=false" predicate:"in,q,conversation_id"`
	TurnId           string             `parameter:"TurnId,kind=query,in=turnId,dataType=string,required=false" predicate:"equal,q,turn_id"`
	MessageId        string             `parameter:"MessageId,kind=query,in=messageId,dataType=string,required=false" predicate:"equal,q,message_id"`
	QueueStatus      string             `parameter:"QueueStatus,kind=query,in=status,dataType=string,required=false" predicate:"equal,q,status"`
	NativeQueuedOnly bool               `parameter:"NativeQueuedOnly,kind=query,in=nativeQueuedOnly,dataType=bool,required=false"`
	Has              *QueueRowsInputHas `setMarker:"true" typeName:"QueueRowsInputHas" json:"-" sqlx:"-"`
}

QueueRowsInput is the generated input scaffold for reader.

func (*QueueRowsInput) SetConversationId

func (input *QueueRowsInput) SetConversationId(value string)

func (*QueueRowsInput) SetConversationIds

func (input *QueueRowsInput) SetConversationIds(value []string)

func (*QueueRowsInput) SetId

func (input *QueueRowsInput) SetId(value string)

func (*QueueRowsInput) SetMessageId

func (input *QueueRowsInput) SetMessageId(value string)

func (*QueueRowsInput) SetNativeQueuedOnly

func (input *QueueRowsInput) SetNativeQueuedOnly(value bool)

func (*QueueRowsInput) SetQueueStatus

func (input *QueueRowsInput) SetQueueStatus(value string)

func (*QueueRowsInput) SetTurnId

func (input *QueueRowsInput) SetTurnId(value string)

type QueueRowsInputHas

type QueueRowsInputHas struct {
	Id               bool
	ConversationId   bool
	ConversationIds  bool
	TurnId           bool
	MessageId        bool
	QueueStatus      bool
	NativeQueuedOnly bool
}

type QueueRowsOutput

type QueueRowsOutput struct {
	Data []*QueueRowView `` /* 196-byte string literal not displayed */
}

QueueRowsOutput is the generated output scaffold for reader.

type ReaderComponent

type ReaderComponent struct {
	Contract xdatly.Component[QueueRowsInput, QueueRowsOutput] "" /* 150-byte string literal not displayed */
}

Component is the generated component scaffold for reader.

func (ReaderComponent) EmbedFS

func (ReaderComponent) EmbedFS() *embed.FS

func (ReaderComponent) EmbedNamespace

func (ReaderComponent) EmbedNamespace() string

Jump to

Keyboard shortcuts

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