handlers

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Apr 18, 2026 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssistantProfileHandler 

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

func NewAssistantProfileHandler 

func NewAssistantProfileHandler(store *assistants.Store) *AssistantProfileHandler

func (*AssistantProfileHandler) Get 

func (h *AssistantProfileHandler) Get(c *fiber.Ctx) error

func (*AssistantProfileHandler) RestoreDefaults 

func (h *AssistantProfileHandler) RestoreDefaults(c *fiber.Ctx) error

func (*AssistantProfileHandler) Update 

func (h *AssistantProfileHandler) Update(c *fiber.Ctx) error

type AuthHandler 

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

func NewAuthHandler 

func NewAuthHandler(service *auth.Service) *AuthHandler

func (*AuthHandler) Login 

func (h *AuthHandler) Login(c *fiber.Ctx) error

func (*AuthHandler) Logout 

func (h *AuthHandler) Logout(c *fiber.Ctx) error

func (*AuthHandler) Session 

func (h *AuthHandler) Session(c *fiber.Ctx) error

type ChannelHandler 

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

func NewChannelHandler 

func NewChannelHandler(store *query.ChannelStore, contactStore *query.ChannelContactStore, service *channels.Service) *ChannelHandler

func (*ChannelHandler) Connect 

func (h *ChannelHandler) Connect(c *fiber.Ctx) error

func (*ChannelHandler) Create 

func (h *ChannelHandler) Create(c *fiber.Ctx) error

func (*ChannelHandler) Delete 

func (h *ChannelHandler) Delete(c *fiber.Ctx) error

func (*ChannelHandler) Get 

func (h *ChannelHandler) Get(c *fiber.Ctx) error

func (*ChannelHandler) List 

func (h *ChannelHandler) List(c *fiber.Ctx) error

func (*ChannelHandler) ListContacts 

func (h *ChannelHandler) ListContacts(c *fiber.Ctx) error

func (*ChannelHandler) Update 

func (h *ChannelHandler) Update(c *fiber.Ctx) error

type ClusterHandler 

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

func NewClusterHandler 

func NewClusterHandler(store *query.ClusterStore) *ClusterHandler

func (*ClusterHandler) Create 

func (h *ClusterHandler) Create(c *fiber.Ctx) error

func (*ClusterHandler) Delete 

func (h *ClusterHandler) Delete(c *fiber.Ctx) error

func (*ClusterHandler) Get 

func (h *ClusterHandler) Get(c *fiber.Ctx) error

func (*ClusterHandler) List 

func (h *ClusterHandler) List(c *fiber.Ctx) error

func (*ClusterHandler) Update 

func (h *ClusterHandler) Update(c *fiber.Ctx) error

type DashboardHandler 

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

func NewDashboardHandler 

func NewDashboardHandler(
	clusters *query.ClusterStore,
	pipelines *query.PipelineStore,
	executions *query.ExecutionStore,
	channels *query.ChannelStore,
	scheduler *scheduler.Scheduler,
) *DashboardHandler

func (*DashboardHandler) Stats 

func (h *DashboardHandler) Stats(c *fiber.Ctx) error

type EditorAssistantHandler 

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

func NewEditorAssistantHandler 

func NewEditorAssistantHandler(
	providerStore *query.LLMProviderStore,
	assistantProfiles *assistants.Store,
	skillStore skills.Reader,
	validators ...assistants.FlowValidator,
) *EditorAssistantHandler

func (*EditorAssistantHandler) ChatStream 

func (h *EditorAssistantHandler) ChatStream(c *fiber.Ctx) error

type ExecutionHandler 

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

func NewExecutionHandler 

func NewExecutionHandler(store *query.ExecutionStore, runner *pipeline.ExecutionRunner) *ExecutionHandler

func (*ExecutionHandler) Cancel 

func (h *ExecutionHandler) Cancel(c *fiber.Ctx) error

func (*ExecutionHandler) Get 

func (h *ExecutionHandler) Get(c *fiber.Ctx) error

func (*ExecutionHandler) ListActiveByPipeline 

func (h *ExecutionHandler) ListActiveByPipeline(c *fiber.Ctx) error

func (*ExecutionHandler) ListByPipeline 

func (h *ExecutionHandler) ListByPipeline(c *fiber.Ctx) error

type KubernetesClusterHandler 

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

KubernetesClusterHandler manages Kubernetes cluster settings.

func NewKubernetesClusterHandler 

func NewKubernetesClusterHandler(store *query.KubernetesClusterStore) *KubernetesClusterHandler

NewKubernetesClusterHandler creates a handler for Kubernetes clusters.

func (*KubernetesClusterHandler) Create 

func (h *KubernetesClusterHandler) Create(c *fiber.Ctx) error

Create validates and stores a Kubernetes cluster.

func (*KubernetesClusterHandler) Delete 

func (h *KubernetesClusterHandler) Delete(c *fiber.Ctx) error

Delete removes a Kubernetes cluster definition.

func (*KubernetesClusterHandler) Get 

func (h *KubernetesClusterHandler) Get(c *fiber.Ctx) error

Get returns a single Kubernetes cluster including the normalized kubeconfig.

func (*KubernetesClusterHandler) List 

func (h *KubernetesClusterHandler) List(c *fiber.Ctx) error

List returns normalized Kubernetes clusters without kubeconfig payloads.

func (*KubernetesClusterHandler) Test 

func (h *KubernetesClusterHandler) Test(c *fiber.Ctx) error

Test validates a Kubernetes connection draft without storing it.

func (*KubernetesClusterHandler) Update 

func (h *KubernetesClusterHandler) Update(c *fiber.Ctx) error

Update validates and replaces a Kubernetes cluster.

type LLMChatHandler 

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

func NewLLMChatHandler 

func NewLLMChatHandler(
	providerStore *query.LLMProviderStore,
	clusterStore *query.ClusterStore,
	kubernetesStore *query.KubernetesClusterStore,
	pipelineStore *query.PipelineStore,
	chatStore *query.ChatStore,
	runner *pipeline.ExecutionRunner,
	scheduler llm.ToolPipelineReloader,
	skillStore skills.Reader,
	shellRunner shellcmd.Runner,
	assistantProfiles *assistants.Store,
) *LLMChatHandler

func (*LLMChatHandler) Chat 

func (h *LLMChatHandler) Chat(c *fiber.Ctx) error

func (*LLMChatHandler) ChatStream 

func (h *LLMChatHandler) ChatStream(c *fiber.Ctx) error

func (*LLMChatHandler) DeleteConversation 

func (h *LLMChatHandler) DeleteConversation(c *fiber.Ctx) error

func (*LLMChatHandler) GetConversation 

func (h *LLMChatHandler) GetConversation(c *fiber.Ctx) error

func (*LLMChatHandler) ListConversations 

func (h *LLMChatHandler) ListConversations(c *fiber.Ctx) error

func (*LLMChatHandler) UpdateConversation 

func (h *LLMChatHandler) UpdateConversation(c *fiber.Ctx) error

type LLMProviderHandler 

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

func NewLLMProviderHandler 

func NewLLMProviderHandler(store *query.LLMProviderStore) *LLMProviderHandler

func (*LLMProviderHandler) Create 

func (h *LLMProviderHandler) Create(c *fiber.Ctx) error

func (*LLMProviderHandler) Delete 

func (h *LLMProviderHandler) Delete(c *fiber.Ctx) error

func (*LLMProviderHandler) DiscoverModels 

func (h *LLMProviderHandler) DiscoverModels(c *fiber.Ctx) error

func (*LLMProviderHandler) Get 

func (h *LLMProviderHandler) Get(c *fiber.Ctx) error

func (*LLMProviderHandler) List 

func (h *LLMProviderHandler) List(c *fiber.Ctx) error

func (*LLMProviderHandler) ListModels 

func (h *LLMProviderHandler) ListModels(c *fiber.Ctx) error

func (*LLMProviderHandler) Update 

func (h *LLMProviderHandler) Update(c *fiber.Ctx) error

type NodeDefinitionsHandler 

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

func NewNodeDefinitionsHandler 

func NewNodeDefinitionsHandler(service *nodedefs.Service, reloaders ...nodeDefinitionsReloader) *NodeDefinitionsHandler

func (*NodeDefinitionsHandler) List 

func (h *NodeDefinitionsHandler) List(c *fiber.Ctx) error

func (*NodeDefinitionsHandler) Refresh 

func (h *NodeDefinitionsHandler) Refresh(c *fiber.Ctx) error

type PipelineHandler 

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

func NewPipelineHandler 

func NewPipelineHandler(store *query.PipelineStore, reloader reloader, validators ...definitionValidator) *PipelineHandler

func (*PipelineHandler) Create 

func (h *PipelineHandler) Create(c *fiber.Ctx) error

func (*PipelineHandler) Delete 

func (h *PipelineHandler) Delete(c *fiber.Ctx) error

func (*PipelineHandler) Export 

func (h *PipelineHandler) Export(c *fiber.Ctx) error

func (*PipelineHandler) Get 

func (h *PipelineHandler) Get(c *fiber.Ctx) error

func (*PipelineHandler) List 

func (h *PipelineHandler) List(c *fiber.Ctx) error

func (*PipelineHandler) SetActivationValidator 

func (h *PipelineHandler) SetActivationValidator(validator activationValidator)

func (*PipelineHandler) Update 

func (h *PipelineHandler) Update(c *fiber.Ctx) error

type PipelineRunHandler 

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

func NewPipelineRunHandler 

func NewPipelineRunHandler(
	pipelineStore *query.PipelineStore,
	runner *pipeline.ExecutionRunner,
) *PipelineRunHandler

func (*PipelineRunHandler) Run 

func (h *PipelineRunHandler) Run(c *fiber.Ctx) error

type SecretHandler 

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

func NewSecretHandler 

func NewSecretHandler(store *query.SecretStore) *SecretHandler

func (*SecretHandler) Create 

func (h *SecretHandler) Create(c *fiber.Ctx) error

func (*SecretHandler) Delete 

func (h *SecretHandler) Delete(c *fiber.Ctx) error

func (*SecretHandler) Get 

func (h *SecretHandler) Get(c *fiber.Ctx) error

func (*SecretHandler) List 

func (h *SecretHandler) List(c *fiber.Ctx) error

func (*SecretHandler) Update 

func (h *SecretHandler) Update(c *fiber.Ctx) error

type TemplateHandler 

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

func NewTemplateHandler 

func NewTemplateHandler(service *templateops.Service) *TemplateHandler

func (*TemplateHandler) Clone 

func (h *TemplateHandler) Clone(c *fiber.Ctx) error

func (*TemplateHandler) Create 

func (h *TemplateHandler) Create(c *fiber.Ctx) error

func (*TemplateHandler) CreatePipeline 

func (h *TemplateHandler) CreatePipeline(c *fiber.Ctx) error

func (*TemplateHandler) Delete 

func (h *TemplateHandler) Delete(c *fiber.Ctx) error

func (*TemplateHandler) Export 

func (h *TemplateHandler) Export(c *fiber.Ctx) error

func (*TemplateHandler) ExportAll 

func (h *TemplateHandler) ExportAll(c *fiber.Ctx) error

func (*TemplateHandler) Get 

func (h *TemplateHandler) Get(c *fiber.Ctx) error

func (*TemplateHandler) Import 

func (h *TemplateHandler) Import(c *fiber.Ctx) error

func (*TemplateHandler) List 

func (h *TemplateHandler) List(c *fiber.Ctx) error

type UserHandler 

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

func NewUserHandler 

func NewUserHandler(store *query.UserStore, authService *auth.Service) *UserHandler

func (*UserHandler) ChangePassword 

func (h *UserHandler) ChangePassword(c *fiber.Ctx) error

func (*UserHandler) Create 

func (h *UserHandler) Create(c *fiber.Ctx) error

func (*UserHandler) Delete 

func (h *UserHandler) Delete(c *fiber.Ctx) error

func (*UserHandler) List 

func (h *UserHandler) List(c *fiber.Ctx) error

type WebhookHandler 

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

func NewWebhookHandler 

func NewWebhookHandler(dispatcher webhookDispatcher) *WebhookHandler

func (*WebhookHandler) Handle 

func (h *WebhookHandler) Handle(c *fiber.Ctx) error

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.