client

Documentation

Index

• func CreateConnection(ctx api.StreamContext) modules.Connection
• func ParseDBUrl(urlstr string) (string, string, error)
• func ParseDriver(url string) (string, error)
• type SQLConnection
  • func (s *SQLConnection) Close(ctx api.StreamContext) error
  • func (s *SQLConnection) DetachSub(ctx api.StreamContext, props map[string]any)
  • func (s *SQLConnection) Dial(ctx api.StreamContext) error
  • func (s *SQLConnection) GetDB() *sql.DB
  • func (s *SQLConnection) GetId(ctx api.StreamContext) string
  • func (s *SQLConnection) Ping(ctx api.StreamContext) error
  • func (s *SQLConnection) Provision(ctx api.StreamContext, conId string, props map[string]any) error
  • func (s *SQLConnection) Reconnect() error

Functions

func CreateConnection

func CreateConnection(ctx api.StreamContext) modules.Connection

func ParseDBUrl

func ParseDBUrl(urlstr string) (string, string, error)

func ParseDriver

func ParseDriver(url string) (string, error)

Types

type SQLConnection

type SQLConnection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*SQLConnection) Close

func (s *SQLConnection) Close(ctx api.StreamContext) error

func (*SQLConnection) DetachSub

func (s *SQLConnection) DetachSub(ctx api.StreamContext, props map[string]any)

func (*SQLConnection) Dial

func (s *SQLConnection) Dial(ctx api.StreamContext) error

func (*SQLConnection) GetDB

func (s *SQLConnection) GetDB() *sql.DB

func (*SQLConnection) GetId

func (s *SQLConnection) GetId(ctx api.StreamContext) string

func (*SQLConnection) Ping

func (s *SQLConnection) Ping(ctx api.StreamContext) error

func (*SQLConnection) Provision

func (s *SQLConnection) Provision(ctx api.StreamContext, conId string, props map[string]any) error

func (*SQLConnection) Reconnect

func (s *SQLConnection) Reconnect() error