src

Documentation

Index

• Constants
• func NewConn() pluginDriver.Driver
• type Conn
  • func (This *Conn) CheckUri() error
  • func (This *Conn) Close() bool
  • func (This *Conn) Commit(data *pluginDriver.PluginDataType, retry bool) (LastSuccessCommitData *pluginDriver.PluginDataType, ...)
  • func (This *Conn) Connect() bool
  • func (This *Conn) Declare(Queue *string, Exchange *string, RoutingKey *string) error
  • func (This *Conn) Del(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)
  • func (This *Conn) GetParam(p interface{}) (*PluginParam, error)
  • func (This *Conn) GetUriExample() string
  • func (This *Conn) Insert(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)
  • func (This *Conn) Open() error
  • func (This *Conn) Query(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)
  • func (This *Conn) ReConnect() bool
  • func (This *Conn) SendAndNoWait(exchange *string, routingkey *string, c *[]byte, DeliveryMode uint8) (bool, error)
  • func (This *Conn) SendAndWait(exchange *string, routingkey *string, c *[]byte, DeliveryMode uint8) (bool, error)
  • func (This *Conn) SetOption(uri *string, param map[string]interface{})
  • func (This *Conn) SetParam(p interface{}) (interface{}, error)
  • func (This *Conn) TimeOutCommit() (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)
  • func (This *Conn) Update(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)
• type Exchange
• type PluginParam
• type Queue

Constants

const BIFROST_VERION = "v1.0.0"

const VERSION = "v1.6.0"

Functions

func NewConn

func NewConn() pluginDriver.Driver

Types

type Conn

type Conn struct {
	pluginDriver.PluginDriverInterface
	// contains filtered or unexported fields
}

func (*Conn) CheckUri

func (This *Conn) CheckUri() error

func (*Conn) Close

func (This *Conn) Close() bool

func (*Conn) Commit

func (This *Conn) Commit(data *pluginDriver.PluginDataType, retry bool) (LastSuccessCommitData *pluginDriver.PluginDataType, ErrData *pluginDriver.PluginDataType, err error)

func (*Conn) Connect

func (This *Conn) Connect() bool

func (*Conn) Declare

func (This *Conn) Declare(Queue *string, Exchange *string, RoutingKey *string) error

func (*Conn) Del

func (This *Conn) Del(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) GetParam

func (This *Conn) GetParam(p interface{}) (*PluginParam, error)

func (*Conn) GetUriExample

func (This *Conn) GetUriExample() string

func (*Conn) Insert

func (This *Conn) Insert(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) Open

func (This *Conn) Open() error

func (*Conn) Query

func (This *Conn) Query(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) ReConnect

func (This *Conn) ReConnect() bool

func (*Conn) SendAndNoWait

func (This *Conn) SendAndNoWait(exchange *string, routingkey *string, c *[]byte, DeliveryMode uint8) (bool, error)

func (*Conn) SendAndWait

func (This *Conn) SendAndWait(exchange *string, routingkey *string, c *[]byte, DeliveryMode uint8) (bool, error)

func (*Conn) SetOption

func (This *Conn) SetOption(uri *string, param map[string]interface{})

func (*Conn) SetParam

func (This *Conn) SetParam(p interface{}) (interface{}, error)

func (*Conn) TimeOutCommit

func (This *Conn) TimeOutCommit() (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

func (*Conn) Update

func (This *Conn) Update(data *pluginDriver.PluginDataType, retry bool) (*pluginDriver.PluginDataType, *pluginDriver.PluginDataType, error)

type Exchange

type Exchange struct {
	Name       string
	Type       string
	Durable    bool
	AutoDelete bool
}

type PluginParam

type PluginParam struct {
	Queue      Queue
	Exchange   Exchange
	Confirm    bool
	Persistent bool
	RoutingKey string
	Expir      int
	Declare    bool

	BifrostFilterQuery bool // bifrost server 保留,是否过滤sql事件
	// contains filtered or unexported fields
}

type Queue

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
}