turn

Documentation

Index

• Variables
• func DefineQueuedTurnComponent(ctx context.Context, srv *datly.Service) error
• type QueuedTurnInput
  • func (i *QueuedTurnInput) EmbedFS() *embed.FS
• type QueuedTurnInputHas
• type QueuedTurnOutput
• type QueuedTurnView

Variables

var QueuedTurnFS embed.FS

var QueuedTurnPathURI = "/v1/api/agently/turn/nextQueued/nextQueued"

Functions

func DefineQueuedTurnComponent

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

Types

type QueuedTurnInput

type QueuedTurnInput struct {
	ConversationID string              `parameter:",kind=query,in=conversationId" predicate:"equal,group=0,t,conversation_id"`
	Has            *QueuedTurnInputHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

func (*QueuedTurnInput) EmbedFS

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

type QueuedTurnInputHas

type QueuedTurnInputHas struct {
	ConversationID bool
}

type QueuedTurnOutput

type QueuedTurnOutput struct {
	response.Status `parameter:",kind=output,in=status" json:",omitempty"`
	Data            []*QueuedTurnView `parameter:",kind=output,in=view" view:"queued_turn,batch=10000,relationalConcurrency=1" sql:"uri=queued_turn/queued_turn.sql"`
	Metrics         response.Metrics  `parameter:",kind=output,in=metrics"`
}

type QueuedTurnView

type QueuedTurnView struct {
	Id                    string    `sqlx:"id"`
	ConversationId        string    `sqlx:"conversation_id"`
	CreatedAt             time.Time `sqlx:"created_at"`
	QueueSeq              *int      `sqlx:"queue_seq"`
	Status                string    `sqlx:"status"`
	ErrorMessage          *string   `sqlx:"error_message"`
	StartedByMessageId    *string   `sqlx:"started_by_message_id"`
	RetryOf               *string   `sqlx:"retry_of"`
	AgentIdUsed           *string   `sqlx:"agent_id_used"`
	AgentConfigUsedId     *string   `sqlx:"agent_config_used_id"`
	ModelOverrideProvider *string   `sqlx:"model_override_provider"`
	ModelOverride         *string   `sqlx:"model_override"`
	ModelParamsOverride   *string   `sqlx:"model_params_override"`
	RunId                 *string   `sqlx:"run_id"`
}