sdk

Documentation

Index

• func DestroyInstance() error
• func InitInstance(token string, address string, httpPort string, grpcPort string, ...) error
• type DataContainerDatabaseColumnSpec
• type DataContainerDatabaseSpec
  • func (spec *DataContainerDatabaseSpec) ToMap() map[string]any
• type DataSourceDatabaseSpec
  • func (spec *DataSourceDatabaseSpec) ToMap() map[string]any
• type Option
  • func WithTimeout(timeout time.Duration) Option
• type Options
• type SDK
  • func GetInstance() *SDK
  • func (s *SDK) ExecuteRawSql(sql string, values ...any) ([]map[string]any, int64, error)
  • func (s *SDK) Transaction(txFunc TxFunc) error
• type Transaction
  • func (tx *Transaction) ExecuteRawSql(sql string, values ...any) ([]map[string]any, int64, error)
• type TxFunc

Functions

func DestroyInstance

func DestroyInstance() error

func InitInstance

func InitInstance(token string, address string, httpPort string, grpcPort string, namespace string, dataSource string, opts ...Option) error

Types

type DataContainerDatabaseColumnSpec

type DataContainerDatabaseColumnSpec struct {
	Name        string `structs:"name"`
	Type        string `structs:"type"`
	Comment     string `structs:"comment"`
	PrimaryKey  bool   `structs:"primary_key"`
	Size        int    `structs:"size"`
	Unique      bool   `structs:"unique"`
	NotNull     bool   `structs:"not_null"`
	Index       bool   `structs:"index"`
	UniqueIndex string `structs:"unique_index"`
	Default     any    `structs:"default"`
}

type DataContainerDatabaseSpec

type DataContainerDatabaseSpec struct {
	TableName string                            `structs:"table_name"`
	Columns   []DataContainerDatabaseColumnSpec `structs:"columns"`
}

func (*DataContainerDatabaseSpec) ToMap

func (spec *DataContainerDatabaseSpec) ToMap() map[string]any

type DataSourceDatabaseSpec

type DataSourceDatabaseSpec struct {
	Type               string `structs:"type"`
	UserName           string `structs:"user_name"`
	Password           string `structs:"password"`
	Address            string `structs:"address"`
	Port               string `structs:"port"`
	Database           string `structs:"database"`
	MaxConnections     int    `structs:"max_connections"`
	MaxIdleConnections int    `structs:"max_idle_connections"`
}

func (*DataSourceDatabaseSpec) ToMap

func (spec *DataSourceDatabaseSpec) ToMap() map[string]any

type Option

type Option func(opts *Options)

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Options

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

type SDK

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

func GetInstance

func GetInstance() *SDK

func (*SDK) ExecuteRawSql

func (s *SDK) ExecuteRawSql(sql string, values ...any) ([]map[string]any, int64, error)

func (*SDK) Transaction

func (s *SDK) Transaction(txFunc TxFunc) error

type Transaction

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

func (*Transaction) ExecuteRawSql

func (tx *Transaction) ExecuteRawSql(sql string, values ...any) ([]map[string]any, int64, error)

type TxFunc

type TxFunc func(tx *Transaction) error