write

Documentation

Index

• Variables
• func DefineComponent(ctx context.Context, srv *datly.Service) (*repository.Component, error)
• type Handler
  • func (h *Handler) Exec(ctx context.Context, sess handler.Session) (interface{}, error)
• type Input
  • func (i *Input) EmbedFS() (fs *embed.FS)
  • func (i *Input) Init(ctx context.Context, sess handler.Session, _ *Output) error
  • func (i *Input) Validate(ctx context.Context, sess handler.Session, output *Output) error
• type MutableTurnQueueView
• type MutableTurnQueueViews
• type Output
• type TurnQueue
  • func (q *TurnQueue) SetConversationId(v string)
  • func (q *TurnQueue) SetCreatedAt(v time.Time)
  • func (q *TurnQueue) SetId(v string)
  • func (q *TurnQueue) SetMessageId(v string)
  • func (q *TurnQueue) SetQueueSeq(v int64)
  • func (q *TurnQueue) SetStatus(v string)
  • func (q *TurnQueue) SetTurnId(v string)
  • func (q *TurnQueue) SetUpdatedAt(v time.Time)
• type TurnQueueHas

Variables

var FS embed.FS

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
}