openai

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2026 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package openai provides an OpenAI-compatible API adapter for OmniAgent.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdapterOption 

type AdapterOption func(*AgentAdapter)

AdapterOption configures the adapter.

func WithModelID 

func WithModelID(id string) AdapterOption

WithModelID sets the model ID reported by the adapter.

func WithModelOwner 

func WithModelOwner(owner string) AdapterOption

WithModelOwner sets the model owner reported by the adapter.

func WithSession 

func WithSession(enabled bool) AdapterOption

WithSession enables session-based message processing.

type AgentAdapter 

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

AgentAdapter adapts agent.Agent to openai.AgentHandler.

func NewAgentAdapter 

func NewAgentAdapter(ag *agent.Agent, opts ...AdapterOption) *AgentAdapter

NewAgentAdapter creates a new adapter for the given agent.

func (*AgentAdapter) ChatCompletion 

func (a *AgentAdapter) ChatCompletion(ctx context.Context, req *openai.ChatCompletionRequest) (*openai.ChatCompletionResponse, error)

ChatCompletion implements openai.AgentHandler.

func (*AgentAdapter) ChatCompletionStream 

func (a *AgentAdapter) ChatCompletionStream(ctx context.Context, req *openai.ChatCompletionRequest, onDelta func(*openai.ChatCompletionChunk) error) error

ChatCompletionStream implements openai.AgentHandler.

func (*AgentAdapter) CreateCronJob 

func (h *AgentAdapter) CreateCronJob(ctx context.Context, req *openai.CreateCronJobRequest) (*openai.CronJobInfo, error)

CreateCronJob creates a new cron job.

func (*AgentAdapter) DeleteCronJob 

func (h *AgentAdapter) DeleteCronJob(ctx context.Context, id string) error

DeleteCronJob deletes a cron job.

func (*AgentAdapter) DisableCronJob 

func (h *AgentAdapter) DisableCronJob(ctx context.Context, id string) error

DisableCronJob disables a cron job.

func (*AgentAdapter) EnableCronJob 

func (h *AgentAdapter) EnableCronJob(ctx context.Context, id string) error

EnableCronJob enables a cron job.

func (*AgentAdapter) GetCronJob 

func (h *AgentAdapter) GetCronJob(ctx context.Context, id string) (*openai.CronJobInfo, error)

GetCronJob returns a cron job by ID.

func (*AgentAdapter) GetModel 

func (a *AgentAdapter) GetModel(ctx context.Context, modelID string) (*openai.Model, error)

GetModel implements openai.AgentHandler.

func (*AgentAdapter) ListCronJobs 

func (h *AgentAdapter) ListCronJobs(ctx context.Context) ([]openai.CronJobInfo, error)

ListCronJobs returns all cron jobs.

func (*AgentAdapter) ListModels 

func (a *AgentAdapter) ListModels(ctx context.Context) ([]openai.Model, error)

ListModels implements openai.AgentHandler.

func (*AgentAdapter) ListTools 

func (a *AgentAdapter) ListTools(ctx context.Context) ([]openai.ToolInfo, error)

ListTools implements openai.AgentHandler.

func (*AgentAdapter) TriggerCronJob 

func (h *AgentAdapter) TriggerCronJob(ctx context.Context, id string) (*openai.CronJobResult, error)

TriggerCronJob triggers a cron job to run immediately.

func (*AgentAdapter) UpdateCronJob 

func (h *AgentAdapter) UpdateCronJob(ctx context.Context, id string, req *openai.UpdateCronJobRequest) (*openai.CronJobInfo, error)

UpdateCronJob updates an existing cron job.

type MultiAdapterOption 

type MultiAdapterOption func(*MultiAgentAdapter)

MultiAdapterOption configures the multi-agent adapter.

func WithMultiModelOwner 

func WithMultiModelOwner(owner string) MultiAdapterOption

WithMultiModelOwner sets the model owner reported by the adapter.

func WithMultiSession 

func WithMultiSession(enabled bool) MultiAdapterOption

WithMultiSession enables session-based message processing.

type MultiAgentAdapter 

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

MultiAgentAdapter adapts a registry of agents to openai.AgentHandler. It routes requests to the appropriate agent based on the model name.

func NewMultiAgentAdapter 

func NewMultiAgentAdapter(reg *registry.Registry, opts ...MultiAdapterOption) *MultiAgentAdapter

NewMultiAgentAdapter creates a new multi-agent adapter.

func (*MultiAgentAdapter) ChatCompletion 

func (a *MultiAgentAdapter) ChatCompletion(ctx context.Context, req *openai.ChatCompletionRequest) (*openai.ChatCompletionResponse, error)

ChatCompletion implements openai.AgentHandler.

func (*MultiAgentAdapter) ChatCompletionStream 

func (a *MultiAgentAdapter) ChatCompletionStream(ctx context.Context, req *openai.ChatCompletionRequest, onDelta func(*openai.ChatCompletionChunk) error) error

ChatCompletionStream implements openai.AgentHandler.

func (*MultiAgentAdapter) CloneAgent 

func (a *MultiAgentAdapter) CloneAgent(ctx context.Context, id string, req *openai.CloneAgentRequest) (*openai.AgentInfo, error)

CloneAgent implements openai.AgentManager.

func (*MultiAgentAdapter) CreateAgent 

func (a *MultiAgentAdapter) CreateAgent(ctx context.Context, req *openai.CreateAgentRequest) (*openai.AgentInfo, error)

CreateAgent implements openai.AgentManager.

func (*MultiAgentAdapter) CreateCronJob 

func (h *MultiAgentAdapter) CreateCronJob(ctx context.Context, req *openai.CreateCronJobRequest) (*openai.CronJobInfo, error)

CreateCronJob creates a new cron job.

func (*MultiAgentAdapter) DeleteAgent 

func (a *MultiAgentAdapter) DeleteAgent(ctx context.Context, id string) error

DeleteAgent implements openai.AgentManager.

func (*MultiAgentAdapter) DeleteCronJob 

func (h *MultiAgentAdapter) DeleteCronJob(ctx context.Context, id string) error

DeleteCronJob deletes a cron job.

func (*MultiAgentAdapter) DisableCronJob 

func (h *MultiAgentAdapter) DisableCronJob(ctx context.Context, id string) error

DisableCronJob disables a cron job.

func (*MultiAgentAdapter) EnableCronJob 

func (h *MultiAgentAdapter) EnableCronJob(ctx context.Context, id string) error

EnableCronJob enables a cron job.

func (*MultiAgentAdapter) GetAgent 

func (a *MultiAgentAdapter) GetAgent(ctx context.Context, id string) (*openai.AgentInfo, error)

GetAgent implements openai.AgentManager.

func (*MultiAgentAdapter) GetCronJob 

func (h *MultiAgentAdapter) GetCronJob(ctx context.Context, id string) (*openai.CronJobInfo, error)

GetCronJob returns a cron job by ID.

func (*MultiAgentAdapter) GetModel 

func (a *MultiAgentAdapter) GetModel(ctx context.Context, modelID string) (*openai.Model, error)

GetModel implements openai.AgentHandler.

func (*MultiAgentAdapter) ListAgents 

func (a *MultiAgentAdapter) ListAgents(ctx context.Context) ([]openai.AgentInfo, error)

ListAgents implements openai.AgentManager.

func (*MultiAgentAdapter) ListCronJobs 

func (h *MultiAgentAdapter) ListCronJobs(ctx context.Context) ([]openai.CronJobInfo, error)

ListCronJobs returns all cron jobs.

func (*MultiAgentAdapter) ListModels 

func (a *MultiAgentAdapter) ListModels(ctx context.Context) ([]openai.Model, error)

ListModels implements openai.AgentHandler. Returns all enabled agents as models.

func (*MultiAgentAdapter) ListTools 

func (a *MultiAgentAdapter) ListTools(ctx context.Context) ([]openai.ToolInfo, error)

ListTools implements openai.AgentHandler. Returns tools from the default agent.

func (*MultiAgentAdapter) Registry 

func (a *MultiAgentAdapter) Registry() *registry.Registry

Registry returns the underlying registry.

func (*MultiAgentAdapter) TriggerCronJob 

func (h *MultiAgentAdapter) TriggerCronJob(ctx context.Context, id string) (*openai.CronJobResult, error)

TriggerCronJob triggers a cron job to run immediately.

func (*MultiAgentAdapter) UpdateAgent 

func (a *MultiAgentAdapter) UpdateAgent(ctx context.Context, id string, req *openai.UpdateAgentRequest) (*openai.AgentInfo, error)

UpdateAgent implements openai.AgentManager.

func (*MultiAgentAdapter) UpdateCronJob 

func (h *MultiAgentAdapter) UpdateCronJob(ctx context.Context, id string, req *openai.UpdateCronJobRequest) (*openai.CronJobInfo, error)

UpdateCronJob updates an existing cron job.

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.