connector

Documentation

Index

• type Connector
  • func New(owner Driver, opts ...Option) Connector
• type Driver
• type Option
  • func With(options ...config.Option) Option
  • func WithAccessTokenCredentials(accessToken string) Option
  • func WithAnonymousCredentials() Option
  • func WithConnectionString(connection string) Option
  • func WithCredentials(creds credentials.Credentials) Option
  • func WithDatabase(database string) Option
  • func WithDefaultExecDataQueryOption(opts ...options.ExecuteDataQueryOption) Option
  • func WithDefaultExecScanQueryOption(opts ...options.ExecuteScanQueryOption) Option
  • func WithDiscoveryInterval(discoveryInterval time.Duration) Option
  • func WithEndpoint(endpoint string) Option
  • func WithTraceDriver(t trace.Driver) Option
  • func WithTraceTable(t trace.Table) Option

Types

type Connector

type Connector interface {
	driver.Connector

	Close(ctx context.Context) error
}

func New

func New(owner Driver, opts ...Option) Connector

type Driver

type Driver interface {
	driver.Driver

	Done() <-chan struct{}
}

type Option

type Option func(*connector)

func With

func With(options ...config.Option) Option

func WithAccessTokenCredentials

func WithAccessTokenCredentials(accessToken string) Option

func WithAnonymousCredentials

func WithAnonymousCredentials() Option

func WithConnectionString

func WithConnectionString(connection string) Option

func WithCredentials

func WithCredentials(creds credentials.Credentials) Option

func WithDatabase

func WithDatabase(database string) Option

func WithDefaultExecDataQueryOption

func WithDefaultExecDataQueryOption(opts ...options.ExecuteDataQueryOption) Option

func WithDefaultExecScanQueryOption

func WithDefaultExecScanQueryOption(opts ...options.ExecuteScanQueryOption) Option

func WithDiscoveryInterval

func WithDiscoveryInterval(discoveryInterval time.Duration) Option

func WithEndpoint

func WithEndpoint(endpoint string) Option

func WithTraceDriver

func WithTraceDriver(t trace.Driver) Option

func WithTraceTable

func WithTraceTable(t trace.Table) Option