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

write

package
v0.1.54 Latest Latest
Warning

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

Go to latest
Published: Sep 23, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var PathURI = "/v1/api/agently/turnqueue"

Functions

func DefineComponent

func DefineComponent(ctx context.Context, srv *datly.Service) (*repository.Component, error)

Types

type Handler

type Handler struct{}

func (*Handler) Exec

func (h *Handler) Exec(ctx context.Context, sess handler.Session) (interface{}, error)

type Input

type Input struct {
	Queues []*TurnQueue `parameter:",kind=body,in=data"`
}

func (*Input) EmbedFS

func (i *Input) EmbedFS() (fs *embed.FS)

func (*Input) Init

func (i *Input) Init(ctx context.Context, sess handler.Session, _ *Output) error

func (*Input) Validate

func (i *Input) Validate(ctx context.Context, sess handler.Session, output *Output) error

type MutableTurnQueueView

type MutableTurnQueueView = TurnQueue

type MutableTurnQueueViews

type MutableTurnQueueViews struct {
	TurnQueues []*MutableTurnQueueView
}

type Output

type Output struct {
	response.Status `parameter:",kind=output,in=status" anonymous:"true"`
	Data            []*TurnQueue           `parameter:",kind=body"`
	Violations      []*validator.Violation `parameter:",kind=transient"`
}

type TurnQueue

type TurnQueue struct {
	Id             string        `sqlx:"id,primaryKey" validate:"required"`
	ConversationId string        `sqlx:"conversation_id"`
	TurnId         string        `sqlx:"turn_id"`
	MessageId      string        `sqlx:"message_id"`
	QueueSeq       *int64        `sqlx:"queue_seq" json:",omitempty"`
	Status         string        `sqlx:"status"`
	CreatedAt      *time.Time    `sqlx:"created_at" json:",omitempty"`
	UpdatedAt      *time.Time    `sqlx:"updated_at" json:",omitempty"`
	Has            *TurnQueueHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

TurnQueue is a mutable Datly-compatible row for conversation turn queue.

func (*TurnQueue) SetConversationId

func (q *TurnQueue) SetConversationId(v string)

func (*TurnQueue) SetCreatedAt

func (q *TurnQueue) SetCreatedAt(v time.Time)

func (*TurnQueue) SetId

func (q *TurnQueue) SetId(v string)

func (*TurnQueue) SetMessageId

func (q *TurnQueue) SetMessageId(v string)

func (*TurnQueue) SetQueueSeq

func (q *TurnQueue) SetQueueSeq(v int64)

func (*TurnQueue) SetStatus

func (q *TurnQueue) SetStatus(v string)

func (*TurnQueue) SetTurnId

func (q *TurnQueue) SetTurnId(v string)

func (*TurnQueue) SetUpdatedAt

func (q *TurnQueue) SetUpdatedAt(v time.Time)

type TurnQueueHas

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

Jump to

Keyboard shortcuts

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