rabbitmq

Documentation

Index

• Constants
• type Config
  • func NewConfig(addr, user, pass, vhost, tag, exchange, queue, key string) *Config
  • func NewConfigWithDefault(addr, user, pass, vhost string) *Config
  • func (c *Config) Clone() *Config
  • func (c *Config) GetURL() string
• type Message
  • func NewEmptyMessage() *Message
  • func NewMessage(sqlType string, isDDL bool, dbName string, tableName string, pkNames []string, ...) *Message
  • func (m *Message) ConvertToSQL(ignoreDDL bool, useReplace bool) ([]map[string][]interface{}, error)
  • func (m *Message) GetColumnNames() []string
  • func (m *Message) GetColumns() map[string]string
  • func (m *Message) GetDBName() string
  • func (m *Message) GetData() []map[string]interface{}
  • func (m *Message) GetIsDDL() bool
  • func (m *Message) GetOld() []map[string]interface{}
  • func (m *Message) GetPKNames() []string
  • func (m *Message) GetSQLType() string
  • func (m *Message) GetTableName() string
  • func (m *Message) Split() []*Message
• type PoolConfig
  • func NewPoolConfig(addr, user, host, vhost, tag, exchange, queue, key string, ...) *PoolConfig
  • func NewPoolConfigWithConfig(config *Config, ...) *PoolConfig
  • func (pc *PoolConfig) Clone() *PoolConfig
  • func (pc *PoolConfig) Validate() error

Constants

const (
	DefaultUnlimitedWaitTime   = -1 // seconds
	DefaultUnlimitedRetryCount = -1
)

const (
	SQLTypeInsert = "INSERT"
	SQLTypeUpdate = "UPDATE"
	SQLTypeDelete = "DELETE"
)

Types

type Config

type Config struct {
	Addr     string
	User     string
	Pass     string
	Vhost    string
	Tag      string
	Exchange string
	Queue    string
	Key      string
}

func NewConfig

func NewConfig(addr, user, pass, vhost, tag, exchange, queue, key string) *Config

NewConfig returns a new *Config

func NewConfigWithDefault

func NewConfigWithDefault(addr, user, pass, vhost string) *Config

NewConfigWithDefault returns a new *Config with default values

func (*Config) Clone

func (c *Config) Clone() *Config

Clone returns a new *Config

func (*Config) GetURL

func (c *Config) GetURL() string

GetURL returns the URL

type Message

type Message struct {
	SQLType   string                   `json:"type"`
	IsDDL     bool                     `json:"isDdl"`
	DBName    string                   `json:"database"`
	TableName string                   `json:"table"`
	PKNames   []string                 `json:"pkNames"`
	Columns   map[string]string        `json:"mysqlType"`
	Data      []map[string]interface{} `json:"data"`
	Old       []map[string]interface{} `json:"old"`
}

func NewEmptyMessage

func NewEmptyMessage() *Message

NewEmptyMessage returns a new empty *Message

func NewMessage

func NewMessage(sqlType string, isDDL bool, dbName string, tableName string, pkNames []string,
	columns map[string]string, data, old []map[string]interface{}) *Message

NewMessage returns a new *Message

func (*Message) ConvertToSQL

func (m *Message) ConvertToSQL(ignoreDDL bool, useReplace bool) ([]map[string][]interface{}, error)

ConvertToSQL returns a map of the sql statement and the values if ignoreDDL is true, and sql type is ddl, it will only return nil, nil, if ignoreDDL is false, and sql type is ddl, it will return nil, error if useReplace is true, message with insert or update type will be converted to statements like "replace into ... values ..." if useReplace is false, message with insert type will be converted to statements like "insert into ... values ... on duplicate key update ..." if useReplace is false, message with update type will be converted to statements like "update ... set ... where ..."

func (*Message) GetColumnNames

func (m *Message) GetColumnNames() []string

GetColumnNames gets the column names

func (*Message) GetColumns

func (m *Message) GetColumns() map[string]string

GetColumns returns the Columns

func (*Message) GetDBName

func (m *Message) GetDBName() string

GetDBName returns the DBName

func (*Message) GetData

func (m *Message) GetData() []map[string]interface{}

GetData returns the Data

func (*Message) GetIsDDL

func (m *Message) GetIsDDL() bool

GetIsDDL returns the IsDDL

func (*Message) GetOld

func (m *Message) GetOld() []map[string]interface{}

GetOld returns the Old

func (*Message) GetPKNames

func (m *Message) GetPKNames() []string

GetPKNames returns the PKNames

func (*Message) GetSQLType

func (m *Message) GetSQLType() string

GetSQLType returns the SQLType

func (*Message) GetTableName

func (m *Message) GetTableName() string

GetTableName returns the TableName

func (*Message) Split

func (m *Message) Split() []*Message

Split splits the message if the message contains multiple data

type PoolConfig

type PoolConfig struct {
	*Config
	MaxConnections     int
	InitConnections    int
	MaxIdleConnections int
	MaxIdleTime        int
	MaxWaitTime        int
	MaxRetryCount      int
	KeepAliveInterval  int
}

func NewPoolConfig

func NewPoolConfig(addr, user, host, vhost, tag, exchange, queue, key string,
	maxConnections, initConnections, maxIdleConnections, maxIdleTime, maxWaitTime, maxRetryCount, keepAliveInterval int) *PoolConfig

NewPoolConfig returns a new PoolConfig

func NewPoolConfigWithConfig

func NewPoolConfigWithConfig(config *Config, maxConnections, initConnections, maxIdleConnections,
	maxIdleTime, maxWaitTime, maxRetryCount, keepAliveInterval int) *PoolConfig

NewPoolConfigWithConfig returns a new PoolConfig

func (*PoolConfig) Clone

func (pc *PoolConfig) Clone() *PoolConfig

Clone returns a new PoolConfig with same values

func (*PoolConfig) Validate

func (pc *PoolConfig) Validate() error

Validate validates pool config