Documentation ¶
Index ¶
- Constants
- type NMQType
- func (nmq *NMQType) Backout() error
- func (nmq *NMQType) Close() error
- func (nmq *NMQType) Commit() error
- func (nmq *NMQType) Connect(shared bool) error
- func (nmq *NMQType) Disconnect() error
- func (nmq *NMQType) Get(wait int64) (data []byte, err error)
- func (nmq *NMQType) GetUUID() uuid.UUID
- func (nmq *NMQType) Init(name, host, port, channel string)
- func (nmq *NMQType) OpenQueue(qname string) error
- func (nmq *NMQType) Ping() bool
- func (nmq *NMQType) Put(qname string, data []byte) (err error)
- func (nmq *NMQType) Stat(qname string) bool
- type NMQType2
- func (nmq *NMQType2) Backout() error
- func (nmq *NMQType2) Close() error
- func (nmq *NMQType2) Commit() error
- func (nmq *NMQType2) Connect(shared bool) error
- func (nmq *NMQType2) Disconnect() error
- func (nmq *NMQType2) Get(wait int64) (data []byte, err error)
- func (nmq *NMQType2) GetUUID() uuid.UUID
- func (nmq *NMQType2) Init(name, host, port, channel string)
- func (nmq *NMQType2) OpenQueue(qname string) error
- func (nmq *NMQType2) Ping() bool
- func (nmq *NMQType2) Put(qname string, data []byte) (err error)
- func (nmq *NMQType2) Stat(qname string) bool
- type PMQType
- func (pmq *PMQType) Backout() error
- func (pmq *PMQType) Commit() error
- func (pmq *PMQType) Connect(shared bool) error
- func (pmq *PMQType) Disconnect() error
- func (pmq *PMQType) Get(wait int64) (data []byte, err error)
- func (pmq *PMQType) GetUUID() uuid.UUID
- func (pmq *PMQType) Init(name, host, port, channel string)
- func (pmq *PMQType) OpenQueue(qname string) error
- func (pmq *PMQType) Ping() bool
- func (pmq *PMQType) Put(qname string, data []byte) (err error)
- func (pmq *PMQType) Stat(qname string) bool
- type SQSType
- func (s *SQSType) Backout() error
- func (s *SQSType) Commit() error
- func (s *SQSType) Connect(shared bool) error
- func (s *SQSType) Disconnect() error
- func (s *SQSType) Get(wait int64) (data []byte, handle []byte, err error)
- func (s *SQSType) GetUUID() uuid.UUID
- func (s *SQSType) Init(accesskeyid, secretkey, region, msgGroupId string)
- func (s *SQSType) OpenQueue(qname string) error
- func (s *SQSType) Ping() bool
- func (s *SQSType) Put(qname string, data []byte) (err error)
- func (s *SQSType) SetHandle(handle []byte) error
- func (s *SQSType) Stat(qname string) bool
Constants ¶
View Source
const ( INSERT_QUEUE = `INSERT INTO QT___QUEUE_NAME__ (queue_id,queue_data, queued_time, queued_by) values ($1,$2,$3,$4)` SELECT_QUEUE = `` /* 192-byte string literal not displayed */ )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NMQType ¶
type NMQType struct {
// contains filtered or unexported fields
}
func (*NMQType) Disconnect ¶
type NMQType2 ¶
type NMQType2 struct {
// contains filtered or unexported fields
}
func (*NMQType2) Disconnect ¶
type PMQType ¶
type PMQType struct {
// contains filtered or unexported fields
}
func (*PMQType) Disconnect ¶
Click to show internal directories.
Click to hide internal directories.