Documentation
¶
Index ¶
- func NewDatly(ctx context.Context) (*datly.Service, error)
- func NewDatlyServiceFromEnv(ctx context.Context) (*datly.Service, error)
- type Service
- func (s *Service) CountToolApprovalQueues(ctx context.Context, in *queueCount.QueueTotalInput) (int, error)
- func (s *Service) DeleteConversation(ctx context.Context, id string) error
- func (s *Service) DeleteMessage(ctx context.Context, conversationID, messageID string) error
- func (s *Service) GetConversation(ctx context.Context, id string, options ...convcli.Option) (*convcli.Conversation, error)
- func (s *Service) GetConversations(ctx context.Context, input *convcli.Input) ([]*convcli.Conversation, error)
- func (s *Service) GetGeneratedFiles(ctx context.Context, input *generatedfileread.Input) ([]*generatedfileread.GeneratedFileView, error)
- func (s *Service) GetMessage(ctx context.Context, id string, options ...convcli.Option) (*convcli.Message, error)
- func (s *Service) GetMessageByElicitation(ctx context.Context, conversationID, elicitationID string) (*convcli.Message, error)
- func (s *Service) GetMessageByParentAndElicitation(ctx context.Context, parentMessageID, elicitationID string) (*convcli.Message, error)
- func (s *Service) GetPayload(ctx context.Context, id string) (*convcli.Payload, error)
- func (s *Service) ListToolApprovalOutcomes(ctx context.Context, in *queueOutcome.OutcomeRowsInput) ([]*queueOutcome.OutcomeRowView, error)
- func (s *Service) ListToolApprovalQueues(ctx context.Context, in *queueRead.QueueRowsInput) ([]*queueRead.QueueRowView, error)
- func (s *Service) ListToolApprovalQueuesWithSelectors(ctx context.Context, in *queueRead.QueueRowsInput, ...) ([]*queueRead.QueueRowView, error)
- func (s *Service) PatchConversations(ctx context.Context, conversations *convcli.MutableConversation) error
- func (s *Service) PatchGeneratedFile(ctx context.Context, generatedFile *generatedfilewrite.GeneratedFile) error
- func (s *Service) PatchMessage(ctx context.Context, message *convcli.MutableMessage) error
- func (s *Service) PatchModelCall(ctx context.Context, modelCall *convcli.MutableModelCall) error
- func (s *Service) PatchPayload(ctx context.Context, payload *convcli.MutablePayload) error
- func (s *Service) PatchToolApprovalQueue(ctx context.Context, queue *queueWrite.ToolApprovalQueue) error
- func (s *Service) PatchToolCall(ctx context.Context, toolCall *convcli.MutableToolCall) error
- func (s *Service) PatchTurn(ctx context.Context, turn *convcli.MutableTurn) error
- func (s *Service) SetStreamPublisher(p streaming.Publisher)
- func (s *Service) ToolCallTraceByOp(ctx context.Context, conversationID, opID string) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func New ¶
New constructs a conversation Service using the provided datly service and registers the rich conversation components.
func (*Service) CountToolApprovalQueues ¶ added in v0.1.10
func (s *Service) CountToolApprovalQueues(ctx context.Context, in *queueCount.QueueTotalInput) (int, error)
func (*Service) DeleteConversation ¶
DeleteConversation removes a conversation by id. Dependent rows are removed via DB FKs (ON DELETE CASCADE).
func (*Service) DeleteMessage ¶
DeleteMessage removes a single message from a conversation using the dedicated DELETE component.
func (*Service) GetConversation ¶
func (s *Service) GetConversation(ctx context.Context, id string, options ...convcli.Option) (*convcli.Conversation, error)
GetConversation implements conversation.API using the generated component and returns SDK Conversation.
func (*Service) GetConversations ¶
func (s *Service) GetConversations(ctx context.Context, input *convcli.Input) ([]*convcli.Conversation, error)
GetConversations implements conversation.API using the generated component and returns SDK Conversation.
func (*Service) GetGeneratedFiles ¶
func (s *Service) GetGeneratedFiles(ctx context.Context, input *generatedfileread.Input) ([]*generatedfileread.GeneratedFileView, error)
func (*Service) GetMessage ¶
func (*Service) GetMessageByElicitation ¶
func (*Service) GetMessageByParentAndElicitation ¶ added in v0.1.13
func (*Service) GetPayload ¶
func (*Service) ListToolApprovalOutcomes ¶ added in v0.1.10
func (s *Service) ListToolApprovalOutcomes(ctx context.Context, in *queueOutcome.OutcomeRowsInput) ([]*queueOutcome.OutcomeRowView, error)
func (*Service) ListToolApprovalQueues ¶
func (s *Service) ListToolApprovalQueues(ctx context.Context, in *queueRead.QueueRowsInput) ([]*queueRead.QueueRowView, error)
func (*Service) ListToolApprovalQueuesWithSelectors ¶ added in v0.1.10
func (s *Service) ListToolApprovalQueuesWithSelectors(ctx context.Context, in *queueRead.QueueRowsInput, selectors ...*hstate.NamedQuerySelector) ([]*queueRead.QueueRowView, error)
func (*Service) PatchConversations ¶
func (*Service) PatchGeneratedFile ¶
func (s *Service) PatchGeneratedFile(ctx context.Context, generatedFile *generatedfilewrite.GeneratedFile) error
func (*Service) PatchMessage ¶
func (*Service) PatchModelCall ¶
func (*Service) PatchPayload ¶
func (*Service) PatchToolApprovalQueue ¶
func (s *Service) PatchToolApprovalQueue(ctx context.Context, queue *queueWrite.ToolApprovalQueue) error
func (*Service) PatchToolCall ¶
func (*Service) SetStreamPublisher ¶
func (*Service) ToolCallTraceByOp ¶
func (s *Service) ToolCallTraceByOp(ctx context.Context, conversationID, opID string) (string, error)
ToolCallTraceByOp returns the persisted trace_id (LLM response.id anchor) for a tool call op_id scoped to a conversation. It returns an empty string when not found.