write

package
v0.1.13 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VisibilityPrivate = "private"
	VisibilityPublic  = "public"
)

Variables

View Source 
var ConversationPostFS embed.FS
View Source 
var PathURI = "/v1/api/agently/conversation"

Functions

func DefineComponent 

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

func DefineDeleteComponent 

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

Types

type Conversation 

type Conversation = MutableConversationView

Compatibility aliases.

type ConversationHas 

type ConversationHas struct {
	Id                       bool
	Summary                  bool
	LastActivity             bool
	UsageInputTokens         bool
	UsageOutputTokens        bool
	UsageEmbeddingTokens     bool
	CreatedAt                bool
	UpdatedAt                bool
	CreatedByUserID          bool
	AgentId                  bool
	DefaultModelProvider     bool
	DefaultModel             bool
	DefaultModelParams       bool
	Title                    bool
	ConversationParentId     bool
	ConversationParentTurnId bool
	Metadata                 bool
	Visibility               bool
	Shareable                bool
	Status                   bool
	Scheduled                bool
	ScheduleId               bool
	ScheduleRunId            bool
	ScheduleKind             bool
	ScheduleTimezone         bool
	ScheduleCronExpr         bool
	ExternalTaskRef          bool
}

type ConversationSlice 

type ConversationSlice []*Conversation

func (ConversationSlice) IndexById 

func (c ConversationSlice) IndexById() IndexedConversation

type Conversations 

type Conversations = MutableConversationViews

type DeleteHandler 

type DeleteHandler struct{}

func (*DeleteHandler) Exec 

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

type DeleteInput 

type DeleteInput struct {
	Rows []*MutableConversationView `parameter:",kind=body,in=data"`
}

type DeleteOutput 

type DeleteOutput struct {
	response.Status `parameter:",kind=output,in=status" json:",omitempty"`
}

type Handler 

type Handler struct{}

func (*Handler) Exec 

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

type IndexedConversation 

type IndexedConversation map[string]*Conversation

type Input 

type Input struct {
	Conversations []*Conversation `parameter:",kind=body,in=data"`

	CurConversationsId *struct{ Values []string } `` /* 126-byte string literal not displayed */

	CurConversation []*Conversation `parameter:",kind=view,in=CurConversation" view:"CurConversation" sql:"uri=sql/cur_conversation.sql"`

	CurConversationById IndexedConversation
}

func (*Input) EmbedFS 

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

func (*Input) Init 

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

func (*Input) Validate 

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

type MutableConversationView 

type MutableConversationView struct {
	Id                       string           `sqlx:"id,primaryKey" validate:"required"`
	Summary                  *string          `sqlx:"summary" json:",omitempty"`
	LastActivity             *time.Time       `sqlx:"last_activity" json:",omitempty"`
	UsageInputTokens         *int             `sqlx:"usage_input_tokens" json:",omitempty"`
	UsageOutputTokens        *int             `sqlx:"usage_output_tokens" json:",omitempty"`
	UsageEmbeddingTokens     *int             `sqlx:"usage_embedding_tokens" json:",omitempty"`
	CreatedAt                *time.Time       `sqlx:"created_at" json:",omitempty"`
	UpdatedAt                *time.Time       `sqlx:"updated_at" json:",omitempty"`
	CreatedByUserID          *string          `sqlx:"created_by_user_id" json:",omitempty"`
	AgentId                  *string          `sqlx:"agent_id" json:",omitempty"`
	DefaultModelProvider     *string          `sqlx:"default_model_provider" json:",omitempty"`
	DefaultModel             *string          `sqlx:"default_model" json:",omitempty"`
	DefaultModelParams       *string          `sqlx:"default_model_params" json:",omitempty"`
	Title                    *string          `sqlx:"title" json:",omitempty"`
	ConversationParentId     *string          `sqlx:"conversation_parent_id" json:",omitempty"`
	ConversationParentTurnId *string          `sqlx:"conversation_parent_turn_id" json:",omitempty"`
	Metadata                 *string          `sqlx:"metadata" json:",omitempty"`
	Visibility               *string          `sqlx:"visibility" json:",omitempty"`
	Shareable                int              `sqlx:"shareable" json:",omitempty"`
	Status                   *string          `sqlx:"status" json:",omitempty"`
	Scheduled                *int             `sqlx:"scheduled" json:",omitempty"`
	ScheduleId               *string          `sqlx:"schedule_id" json:",omitempty"`
	ScheduleRunId            *string          `sqlx:"schedule_run_id" json:",omitempty"`
	ScheduleKind             *string          `sqlx:"schedule_kind" json:",omitempty"`
	ScheduleTimezone         *string          `sqlx:"schedule_timezone" json:",omitempty"`
	ScheduleCronExpr         *string          `sqlx:"schedule_cron_expr" json:",omitempty"`
	ExternalTaskRef          *string          `sqlx:"external_task_ref" json:",omitempty"`
	Has                      *ConversationHas `setMarker:"true" format:"-" sqlx:"-" diff:"-" json:"-"`
}

func NewConversationStatus 

func NewConversationStatus(id, status string) *MutableConversationView

func NewMutableConversationView 

func NewMutableConversationView(opts ...MutableConversationViewOption) *MutableConversationView

func (*MutableConversationView) SetAgentId 

func (c *MutableConversationView) SetAgentId(value string)

func (*MutableConversationView) SetConversationParentId 

func (c *MutableConversationView) SetConversationParentId(value string)

func (*MutableConversationView) SetConversationParentTurnId 

func (c *MutableConversationView) SetConversationParentTurnId(value string)

func (*MutableConversationView) SetCreatedAt 

func (c *MutableConversationView) SetCreatedAt(value time.Time)

func (*MutableConversationView) SetCreatedByUserID 

func (c *MutableConversationView) SetCreatedByUserID(value string)

func (*MutableConversationView) SetDefaultModel 

func (c *MutableConversationView) SetDefaultModel(value string)

func (*MutableConversationView) SetDefaultModelParams 

func (c *MutableConversationView) SetDefaultModelParams(value string)

func (*MutableConversationView) SetDefaultModelProvider 

func (c *MutableConversationView) SetDefaultModelProvider(value string)

func (*MutableConversationView) SetExternalTaskRef 

func (c *MutableConversationView) SetExternalTaskRef(value string)

func (*MutableConversationView) SetId 

func (c *MutableConversationView) SetId(value string)

func (*MutableConversationView) SetLastActivity 

func (c *MutableConversationView) SetLastActivity(value time.Time)

func (*MutableConversationView) SetMetadata 

func (c *MutableConversationView) SetMetadata(value string)

func (*MutableConversationView) SetScheduleCronExpr 

func (c *MutableConversationView) SetScheduleCronExpr(value string)

func (*MutableConversationView) SetScheduleId 

func (c *MutableConversationView) SetScheduleId(value string)

func (*MutableConversationView) SetScheduleKind 

func (c *MutableConversationView) SetScheduleKind(value string)

func (*MutableConversationView) SetScheduleRunId 

func (c *MutableConversationView) SetScheduleRunId(value string)

func (*MutableConversationView) SetScheduleTimezone 

func (c *MutableConversationView) SetScheduleTimezone(value string)

func (*MutableConversationView) SetScheduled 

func (c *MutableConversationView) SetScheduled(value int)

func (*MutableConversationView) SetShareable 

func (c *MutableConversationView) SetShareable(value int)

func (*MutableConversationView) SetStatus 

func (c *MutableConversationView) SetStatus(value string)

func (*MutableConversationView) SetSummary 

func (c *MutableConversationView) SetSummary(value string)

func (*MutableConversationView) SetTitle 

func (c *MutableConversationView) SetTitle(value string)

func (*MutableConversationView) SetUpdatedAt 

func (c *MutableConversationView) SetUpdatedAt(value time.Time)

func (*MutableConversationView) SetUsageEmbeddingTokens 

func (c *MutableConversationView) SetUsageEmbeddingTokens(value int)

func (*MutableConversationView) SetUsageInputTokens 

func (c *MutableConversationView) SetUsageInputTokens(value int)

func (*MutableConversationView) SetUsageOutputTokens 

func (c *MutableConversationView) SetUsageOutputTokens(value int)

func (*MutableConversationView) SetVisibility 

func (c *MutableConversationView) SetVisibility(value string)

type MutableConversationViewOption 

type MutableConversationViewOption func(*MutableConversationView)

func WithConversationID 

func WithConversationID(v string) MutableConversationViewOption

func WithConversationShareable 

func WithConversationShareable(v int) MutableConversationViewOption

func WithConversationStatus 

func WithConversationStatus(v string) MutableConversationViewOption

func WithConversationSummary 

func WithConversationSummary(v string) MutableConversationViewOption

func WithConversationVisibility 

func WithConversationVisibility(v string) MutableConversationViewOption

type MutableConversationViews 

type MutableConversationViews struct {
	Conversations []*MutableConversationView
}

func NewMutableConversationViews 

func NewMutableConversationViews(rows ...*MutableConversationView) *MutableConversationViews

type Output 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.