dispatcher

Documentation

Index

• type Dispatcher
  • func New(ctx context.Context, invoker *invoke.Invoker, c kclient.Client, ...) *Dispatcher
  • func (d *Dispatcher) ListConfiguredAuthProviders(namespace string) []string
  • func (d *Dispatcher) ModelsForProvider(ctx context.Context, modelProviderNamespace, modelProviderName string) (*openai.ModelsList, error)
  • func (d *Dispatcher) ModelsForProviderWithEnv(ctx context.Context, modelProviderNamespace, modelProviderName string, ...) (*openai.ModelsList, error)
  • func (d *Dispatcher) ScanFile(ctx context.Context, contents []byte) (bool, error)
  • func (d *Dispatcher) StopAuthProvider(namespace, authProviderName string)
  • func (d *Dispatcher) StopFileScannerProvider(namespace, fileScannerProviderName string)
  • func (d *Dispatcher) StopModelProvider(namespace, modelProviderName string)
  • func (d *Dispatcher) TransformRequest(u url.URL, credEnv map[string]string) func(req *http.Request)
  • func (d *Dispatcher) URLForAuthProvider(ctx context.Context, namespace, authProviderName string) (url.URL, error)
  • func (d *Dispatcher) URLForModelProvider(ctx context.Context, namespace, modelProviderName string) (url.URL, error)
  • func (d *Dispatcher) UpdateConfiguredAuthProviders(ctx context.Context)

Types

type Dispatcher

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

func New

func New(ctx context.Context, invoker *invoke.Invoker, c kclient.Client, gClient *gptscript.GPTScript, gatewayClient *client.Client, postgresDSN string) *Dispatcher

func (*Dispatcher) ListConfiguredAuthProviders

func (d *Dispatcher) ListConfiguredAuthProviders(namespace string) []string

func (*Dispatcher) ModelsForProvider

func (d *Dispatcher) ModelsForProvider(ctx context.Context, modelProviderNamespace, modelProviderName string) (*openai.ModelsList, error)

func (*Dispatcher) ModelsForProviderWithEnv

func (d *Dispatcher) ModelsForProviderWithEnv(ctx context.Context, modelProviderNamespace, modelProviderName string, env map[string]string) (*openai.ModelsList, error)

func (*Dispatcher) ScanFile

func (d *Dispatcher) ScanFile(ctx context.Context, contents []byte) (bool, error)

func (*Dispatcher) StopAuthProvider

func (d *Dispatcher) StopAuthProvider(namespace, authProviderName string)

func (*Dispatcher) StopFileScannerProvider

func (d *Dispatcher) StopFileScannerProvider(namespace, fileScannerProviderName string)

func (*Dispatcher) StopModelProvider

func (d *Dispatcher) StopModelProvider(namespace, modelProviderName string)

func (*Dispatcher) TransformRequest

func (d *Dispatcher) TransformRequest(u url.URL, credEnv map[string]string) func(req *http.Request)

func (*Dispatcher) URLForAuthProvider

func (d *Dispatcher) URLForAuthProvider(ctx context.Context, namespace, authProviderName string) (url.URL, error)

func (*Dispatcher) URLForModelProvider

func (d *Dispatcher) URLForModelProvider(ctx context.Context, namespace, modelProviderName string) (url.URL, error)

func (*Dispatcher) UpdateConfiguredAuthProviders

func (d *Dispatcher) UpdateConfiguredAuthProviders(ctx context.Context)