Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

connector

package

Go to main page

Versions in this module

v0

v0.2.3

Nov 13, 2025

v0.2.2

Nov 3, 2025

v0.2.1

Oct 30, 2025

v0.2.0

Oct 30, 2025

Changes in this version

type Service

+ func (s *Service) Namespace(ctx context.Context) (string, error)

v0.1.0

Sep 22, 2025

Changes in this version

+ var ErrConnectorNotFound = errors.New("connector not found")

+ var ErrNamespaceNotFound = errors.New("namespace not found")

+ type AddOutput struct

+ CallbackURL string

+ Connector string

+ Error string

+ State string

+ Status string

+ type Config struct

+ BackendForFrontend *auth.BackendForFrontend

+ CallbackBaseURL string

+ DefaultConnectors []*Namespaced

+ Policy *policy.Policy

+ SecretBaseLocation string

+ type ConnectionInput struct

+ Db string

+ Driver string

+ Host string

+ Name string

+ Options string

+ Port int

+ Project string

+ func (i *ConnectionInput) Expand(dsn string) string

+ func (i *ConnectionInput) Init(config *meta.Config)

+ func (i *ConnectionInput) Validate(config *meta.Config) error

+ type Connector struct

+ DSN string

+ Driver string

+ Name string

+ Secrets *scy.Resource

+ func (c *Connector) Close() error

+ func (c *Connector) Db(ctx context.Context) (*sql.DB, error)

+ func (c *Connector) ExpandDSN(ctx context.Context) (string, error)

+ func (c *Connector) SetSecrets(secrets *scy.Service)

+ type Connectors struct

+ func NewConnectors() *Connectors

+ type ListInput struct

+ Pattern string

+ type ListOutput struct

+ Data []interface{}

+ Error string

+ Status string

+ type Manager struct

+ Config *Config

+ func NewManager(cfg *Config, authSvc *auth.Service, secrets *scy.Service) *Manager

+ func (c *Manager) CancelPending(ctx context.Context, uuid string) error

+ func (c *Manager) CompletePending(uuid string) error

+ func (c *Manager) Connection(ctx context.Context, name string) (*Connector, error)

+ func (c *Manager) Get(name string) *Connector

+ func (c *Manager) Pending(uuid string) (*PendingSecret, bool)

+ type Namespace struct

+ Name string

+ func NewNamespace(name string) *Namespace

+ type Namespaced struct

+ Connectors []*Connector

+ Namespace string

+ type Namespaces struct

+ func NewNamespaces() *Namespaces

+ type PendingSecret struct

+ CallbackURL string

+ Connector *Connector

+ ConnectorMeta *meta.Config

+ CredType reflect.Type

+ ElicitID string

+ MCP client.Operations

+ NS *Namespace

+ Namespace string

+ OAuth2Config *oauth2.Config

+ UUID string

+ type PendingSecrets struct

+ func NewPendingSecrets() *PendingSecrets

+ func (p *PendingSecrets) Close(uuid string)

+ type Service struct

+ func NewService(manager *Manager, mcp client.Operations) *Service

+ func (s *Service) AddConnection(ctx context.Context, input *ConnectionInput) (*AddOutput, error)

+ func (s *Service) Connection(ctx context.Context, name string) (*Connector, error)

+ func (s *Service) GeneratePendingSecret(ctx context.Context, connector *Connector) (*PendingSecret, error)

+ func (s *Service) List(ctx context.Context) []*Connector

+ func (s *Service) ListConnectors(ctx context.Context, input *ListInput) *ListOutput

+ func (s *Service) Remove(ctx context.Context, name string)

+ func (s *Service) Set(ctx context.Context, connector *Connector) (*AddOutput, error)

+ func (s *Service) UpsertConnection(ctx context.Context, input *ConnectionInput) error

+ type UpdateOutput AddOutput