client

Documentation

Index

• Variables
• func CloseClient(dsn string) error
• type Client
  • func NewClient(dsn string) (c Client, err error)
• type ClientPostgres
  • func NewCLientPostgres(dsn string) (*ClientPostgres, error)
  • func (c *ClientPostgres) Columns(ctx context.Context, s string, n string) ([]ColumnSQL, error)
  • func (c *ClientPostgres) Tables(ctx context.Context) ([]TableSQL, error)
• type ClientRedis
  • func NewClientRedis(dsn string) (*ClientRedis, error)
  • func (c *ClientRedis) Close() error
  • func (c *ClientRedis) Columns(ctx context.Context, s string, n string) ([]ColumnSQL, error)
  • func (c *ClientRedis) Get(ctx context.Context, key string) (any, error)
  • func (c *ClientRedis) GetDB() (*bun.DB, error)
  • func (c *ClientRedis) GetWithExpiration(ctx context.Context, key string) (any, *int64, error)
  • func (c *ClientRedis) Keys(ctx context.Context, input string) ([]string, error)
  • func (c *ClientRedis) Set(ctx context.Context, t string, k string, v any) error
  • func (c *ClientRedis) SetWithExpiration(ctx context.Context, t string, k string, v any, e *int64) error
  • func (c *ClientRedis) Tables(ctx context.Context) ([]TableSQL, error)
  • func (c *ClientRedis) TestConnection(ctx context.Context) error
• type ClientSQL
  • func (c *ClientSQL) Close() error
  • func (c *ClientSQL) Debug()
  • func (c *ClientSQL) GetDB() (*bun.DB, error)
  • func (c *ClientSQL) TestConnection(ctx context.Context) error
• type ColumnPostgres
• type ColumnSQL
• type TablePostgres
• type TableSQL

Variables

var Clients = make(map[string]Client)

Functions

func CloseClient

func CloseClient(dsn string) error

Types

type Client

type Client interface {
	TestConnection(ctx context.Context) error
	Close() error
	Tables(ctx context.Context) ([]TableSQL, error)
	Columns(ctx context.Context, schema string, name string) ([]ColumnSQL, error)
	GetDB() (*bun.DB, error)
}

func NewClient

func NewClient(dsn string) (c Client, err error)

type ClientPostgres

type ClientPostgres struct {
	*ClientSQL
}

func NewCLientPostgres

func NewCLientPostgres(dsn string) (*ClientPostgres, error)

func (*ClientPostgres) Columns

func (c *ClientPostgres) Columns(ctx context.Context, s string, n string) ([]ColumnSQL, error)

func (*ClientPostgres) Tables

func (c *ClientPostgres) Tables(ctx context.Context) ([]TableSQL, error)

type ClientRedis

type ClientRedis struct {
	Client *redis.Client
}

func NewClientRedis

func NewClientRedis(dsn string) (*ClientRedis, error)

func (*ClientRedis) Close

func (c *ClientRedis) Close() error

func (*ClientRedis) Columns

func (c *ClientRedis) Columns(ctx context.Context, s string, n string) ([]ColumnSQL, error)

func (*ClientRedis) Get

func (c *ClientRedis) Get(ctx context.Context, key string) (any, error)

func (*ClientRedis) GetDB

func (c *ClientRedis) GetDB() (*bun.DB, error)

func (*ClientRedis) GetWithExpiration

func (c *ClientRedis) GetWithExpiration(ctx context.Context, key string) (any, *int64, error)

func (*ClientRedis) Keys

func (c *ClientRedis) Keys(ctx context.Context, input string) ([]string, error)

func (*ClientRedis) Set

func (c *ClientRedis) Set(ctx context.Context, t string, k string, v any) error

func (*ClientRedis) SetWithExpiration

func (c *ClientRedis) SetWithExpiration(ctx context.Context, t string, k string, v any, e *int64) error

func (*ClientRedis) Tables

func (c *ClientRedis) Tables(ctx context.Context) ([]TableSQL, error)

func (*ClientRedis) TestConnection

func (c *ClientRedis) TestConnection(ctx context.Context) error

type ClientSQL

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

func (*ClientSQL) Close

func (c *ClientSQL) Close() error

func (*ClientSQL) Debug

func (c *ClientSQL) Debug()

func (*ClientSQL) GetDB

func (c *ClientSQL) GetDB() (*bun.DB, error)

func (*ClientSQL) TestConnection

func (c *ClientSQL) TestConnection(ctx context.Context) error

type ColumnPostgres

type ColumnPostgres struct {
	Name     string `json:"column_name"`
	DataType string `json:"data_type"`
}

type ColumnSQL

type ColumnSQL struct {
	Name     string `json:"name"`
	DataType string `json:"dataType"`
}

type TablePostgres

type TablePostgres struct {
	Name   string `json:"tablename"`
	Schema string `json:"schemaname"`
}

type TableSQL

type TableSQL struct {
	Name    string           `json:"name"`
	Schema  string           `json:"schema"`
	Columns []ColumnSQL      `json:"columns"`
	Records []map[string]any `json:"records"`
}