sql

Documentation

Index

• func New(ctx context.Context, driver string, dsn string, prefix string) (configx.Entrypoint, error)
• func NewDAO(ctx context.Context, o dao.DAO) (dao.DAO, error)
• type DAO
• type SQL
  • func (s *SQL) Del() error
  • func (s *SQL) Get() configx.Value
  • func (s *SQL) Init(ctx context.Context, options configx.Values) error
  • func (s *SQL) Save(ctxUser, ctxMessage string) error
  • func (s *SQL) Set(data interface{}) error
  • func (s *SQL) Val(path ...string) configx.Values
  • func (s *SQL) Watch(oo ...configx.WatchOption) (configx.Receiver, error)

Functions

func New

func New(ctx context.Context, driver string, dsn string, prefix string) (configx.Entrypoint, error)

func NewDAO

func NewDAO(ctx context.Context, o dao.DAO) (dao.DAO, error)

Types

type DAO

type DAO interface {
	dao.DAO

	Get() ([]byte, error)
	Set([]byte) error
}

type SQL

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

func (*SQL) Del

func (s *SQL) Del() error

func (*SQL) Get

func (s *SQL) Get() configx.Value

func (*SQL) Init

func (s *SQL) Init(ctx context.Context, options configx.Values) error

Init handler for the SQL DAO

func (*SQL) Save

func (s *SQL) Save(ctxUser, ctxMessage string) error

func (*SQL) Set

func (s *SQL) Set(data interface{}) error

func (*SQL) Val

func (s *SQL) Val(path ...string) configx.Values

func (*SQL) Watch

func (s *SQL) Watch(oo ...configx.WatchOption) (configx.Receiver, error)