read

package
v0.1.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 1, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var QueueRowsFS embed.FS
View Source
var QueueRowsPathURI = "/v1/api/agently/turnqueue/list"

Functions

func DefineQueueRowsComponent

func DefineQueueRowsComponent(ctx context.Context, srv *datly.Service) error

Types

type QueueRowView

type QueueRowView struct {
	Id             string     `sqlx:"id"`
	ConversationId string     `sqlx:"conversation_id"`
	TurnId         string     `sqlx:"turn_id"`
	MessageId      string     `sqlx:"message_id"`
	QueueSeq       int64      `sqlx:"queue_seq"`
	Status         string     `sqlx:"status"`
	CreatedAt      time.Time  `sqlx:"created_at"`
	UpdatedAt      *time.Time `sqlx:"updated_at"`
}

type QueueRowsInput

type QueueRowsInput struct {
	Id             string             `parameter:",kind=query,in=id" predicate:"equal,group=0,q,id"`
	ConversationId string             `parameter:",kind=query,in=conversationId" predicate:"equal,group=0,q,conversation_id"`
	TurnId         string             `parameter:",kind=query,in=turnId" predicate:"equal,group=0,q,turn_id"`
	MessageId      string             `parameter:",kind=query,in=messageId" predicate:"equal,group=0,q,message_id"`
	QueueStatus    string             `parameter:",kind=query,in=status" predicate:"equal,group=0,q,status"`
	Has            *QueueRowsInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

func (*QueueRowsInput) EmbedFS

func (i *QueueRowsInput) EmbedFS() *embed.FS

type QueueRowsInputHas

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

type QueueRowsOutput

type QueueRowsOutput struct {
	response.Status `parameter:",kind=output,in=apiStatus" json:",omitempty"`
	Data            []*QueueRowView  `parameter:",kind=output,in=view" view:"queue_rows,batch=1000,relationalConcurrency=1" sql:"uri=queue_rows/queue_rows.sql"`
	Metrics         response.Metrics `parameter:",kind=output,in=metrics"`
}

Jump to

Keyboard shortcuts

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