mysql

Documentation

Index

• func NewDB(dsn string) (*sqlx.DB, error)
• func NewRepository(db *sqlx.DB) repository.Repository
• type Proxy
  • func NewProxy(db *sqlx.DB) *Proxy
  • func (p *Proxy) Delete(ctx context.Context, proxyID string) error
  • func (p *Proxy) Get(ctx context.Context, proxyID string) (entity.Proxy, error)
  • func (p *Proxy) Upsert(ctx context.Context, proxy entity.Proxy) error
• type Route
  • func NewRoute(db *sqlx.DB) *Route
  • func (r *Route) Delete(ctx context.Context, routes []entity.Route) error
  • func (r *Route) GetWithProxyID(ctx context.Context, proxyID string) ([]entity.Route, error)
  • func (r *Route) Upsert(ctx context.Context, routes []entity.Route) error

Functions

func NewDB

func NewDB(dsn string) (*sqlx.DB, error)

func NewRepository

func NewRepository(db *sqlx.DB) repository.Repository

Types

type Proxy

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

func NewProxy

func NewProxy(db *sqlx.DB) *Proxy

func (*Proxy) Delete

func (p *Proxy) Delete(ctx context.Context, proxyID string) error

func (*Proxy) Get

func (p *Proxy) Get(ctx context.Context, proxyID string) (entity.Proxy, error)

func (*Proxy) Upsert

func (p *Proxy) Upsert(ctx context.Context, proxy entity.Proxy) error

type Route

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

func NewRoute

func NewRoute(db *sqlx.DB) *Route

func (*Route) Delete

func (r *Route) Delete(ctx context.Context, routes []entity.Route) error

func (*Route) GetWithProxyID

func (r *Route) GetWithProxyID(ctx context.Context, proxyID string) ([]entity.Route, error)

func (*Route) Upsert

func (r *Route) Upsert(ctx context.Context, routes []entity.Route) error