client

Documentation

Index

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

Functions

func CreateConnection

func CreateConnection(ctx api.StreamContext, props map[string]any) (modules.Connection, error)

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 CreateClient

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

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) GetDB

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

func (*SQLConnection) Ping

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

func (*SQLConnection) Reconnect

func (s *SQLConnection) Reconnect() error