managers

Documentation

Index

• func NewExecutorAgentMemoryService(deps ExecutorAgentMemoryServiceDependencies) domain.AgentMemoryService
• func NewExecutorCredentialDecryptionService(privateKeyBase64 string) *executorCredentialDecryptionService
• func NewExecutorCredentialManager(client flowbaker.ClientInterface, ...) domain.ExecutorCredentialManager
• func NewExecutorIntegrationManager(deps ExecutorIntegrationManagerDependencies) domain.ExecutorIntegrationManager
• func NewExecutorKnowledgeManager(deps ExecutorKnowledgeManagerDependencies) domain.ExecutorKnowledgeManager
• func NewExecutorModelManager(deps ExecutorModelManagerDependencies) domain.ExecutorModelManager
• func NewExecutorRouteManager(deps ExecutorRouteManagerDependencies) domain.ExecutorRouteManager
• func NewExecutorScheduleManager(deps ExecutorScheduleManagerDependencies) domain.ExecutorScheduleManager
• func NewExecutorStorageManager(deps ExecutorStorageManagerDependencies) domain.ExecutorStorageManager
• func NewExecutorTaskPublisher(deps ExecutorTaskPublisherDependencies) domain.ExecutorTaskPublisher
• func NewExecutorWorkspaceManager(deps ExecutorWorkspaceManagerDependencies) domain.ExecutorWorkspaceManager
• type ExecutorAgentMemoryService
  • func (s *ExecutorAgentMemoryService) DeleteOldConversations(ctx context.Context, workspaceID string, sessionID string, keepCount int) error
  • func (s *ExecutorAgentMemoryService) GetConversations(ctx context.Context, params domain.GetConversationsParams) ([]*domain.AgentConversation, error)
  • func (s *ExecutorAgentMemoryService) SaveConversation(ctx context.Context, conversation *domain.AgentConversation) error
• type ExecutorAgentMemoryServiceDependencies
• type ExecutorCredentialGetter
  • func NewExecutorCredentialGetter[T any](manager domain.ExecutorCredentialManager) *ExecutorCredentialGetter[T]
  • func (e *ExecutorCredentialGetter[T]) GetDecryptedCredential(ctx context.Context, credentialID string) (T, error)
• type ExecutorEventPublisher
  • func NewExecutorEventPublisher(api *flowbaker.Client) *ExecutorEventPublisher
  • func (p *ExecutorEventPublisher) PublishEvent(ctx context.Context, event domain.Event) error
• type ExecutorIntegrationManagerDependencies
• type ExecutorKnowledgeManagerDependencies
• type ExecutorModelManagerDependencies
• type ExecutorRouteManagerDependencies
• type ExecutorScheduleManagerDependencies
• type ExecutorStorageManagerDependencies
• type ExecutorTaskPublisherDependencies
• type ExecutorWorkspaceManagerDependencies

Functions

func NewExecutorAgentMemoryService

func NewExecutorAgentMemoryService(deps ExecutorAgentMemoryServiceDependencies) domain.AgentMemoryService

func NewExecutorCredentialDecryptionService

func NewExecutorCredentialDecryptionService(privateKeyBase64 string) *executorCredentialDecryptionService

func NewExecutorCredentialManager

func NewExecutorCredentialManager(client flowbaker.ClientInterface, decryptionSvc domain.ExecutorCredentialDecryptionService) domain.ExecutorCredentialManager

func NewExecutorIntegrationManager

func NewExecutorIntegrationManager(deps ExecutorIntegrationManagerDependencies) domain.ExecutorIntegrationManager

func NewExecutorKnowledgeManager

func NewExecutorKnowledgeManager(deps ExecutorKnowledgeManagerDependencies) domain.ExecutorKnowledgeManager

func NewExecutorModelManager

func NewExecutorModelManager(deps ExecutorModelManagerDependencies) domain.ExecutorModelManager

func NewExecutorRouteManager

func NewExecutorRouteManager(deps ExecutorRouteManagerDependencies) domain.ExecutorRouteManager

func NewExecutorScheduleManager

func NewExecutorScheduleManager(deps ExecutorScheduleManagerDependencies) domain.ExecutorScheduleManager

func NewExecutorStorageManager

func NewExecutorStorageManager(deps ExecutorStorageManagerDependencies) domain.ExecutorStorageManager

func NewExecutorTaskPublisher

func NewExecutorTaskPublisher(deps ExecutorTaskPublisherDependencies) domain.ExecutorTaskPublisher

func NewExecutorWorkspaceManager

func NewExecutorWorkspaceManager(deps ExecutorWorkspaceManagerDependencies) domain.ExecutorWorkspaceManager

Types

type ExecutorAgentMemoryService

type ExecutorAgentMemoryService struct {
	// contains filtered or unexported fields
}

func (*ExecutorAgentMemoryService) DeleteOldConversations

func (s *ExecutorAgentMemoryService) DeleteOldConversations(ctx context.Context, workspaceID string, sessionID string, keepCount int) error

func (*ExecutorAgentMemoryService) GetConversations

func (s *ExecutorAgentMemoryService) GetConversations(ctx context.Context, params domain.GetConversationsParams) ([]*domain.AgentConversation, error)

func (*ExecutorAgentMemoryService) SaveConversation

func (s *ExecutorAgentMemoryService) SaveConversation(ctx context.Context, conversation *domain.AgentConversation) error

type ExecutorAgentMemoryServiceDependencies

type ExecutorAgentMemoryServiceDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorCredentialGetter

type ExecutorCredentialGetter[T any] struct {
	// contains filtered or unexported fields
}

ExecutorCredentialGetter retrieves and decrypts credentials from the API for executors

func NewExecutorCredentialGetter

func NewExecutorCredentialGetter[T any](
	manager domain.ExecutorCredentialManager,
) *ExecutorCredentialGetter[T]

func (*ExecutorCredentialGetter[T]) GetDecryptedCredential

func (e *ExecutorCredentialGetter[T]) GetDecryptedCredential(ctx context.Context, credentialID string) (T, error)

type ExecutorEventPublisher

type ExecutorEventPublisher struct {
	// contains filtered or unexported fields
}

func NewExecutorEventPublisher

func NewExecutorEventPublisher(api *flowbaker.Client) *ExecutorEventPublisher

func (*ExecutorEventPublisher) PublishEvent

func (p *ExecutorEventPublisher) PublishEvent(ctx context.Context, event domain.Event) error

type ExecutorIntegrationManagerDependencies

type ExecutorIntegrationManagerDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorKnowledgeManagerDependencies

type ExecutorKnowledgeManagerDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorModelManagerDependencies

type ExecutorModelManagerDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorRouteManagerDependencies

type ExecutorRouteManagerDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorScheduleManagerDependencies

type ExecutorScheduleManagerDependencies struct {
	Client flowbaker.ClientInterface
}

type ExecutorStorageManagerDependencies

type ExecutorStorageManagerDependencies struct {
	Client *flowbaker.Client
}

type ExecutorTaskPublisherDependencies

type ExecutorTaskPublisherDependencies struct {
	Client *flowbaker.Client
}

type ExecutorWorkspaceManagerDependencies

type ExecutorWorkspaceManagerDependencies struct {
	FlowbakerClient *flowbaker.Client
}