sdk

package

v0.0.1 Latest Latest Go to latest Published: Feb 19, 2025 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func ConnectMq(ctx context.Context, addr string, safe bool, auth string) (*MqClient, error)

func (m *MqClient) Active(mq string, id uint64) (err error)

将消息存档

func (m *MqClient) CreateMq(mq string) (err error)

创建队列

func (m *MqClient) Delete(mq string, id uint64) (err error)

从队列中删除指定消息

func (m *MqClient) DeleteMq(mq string) (err error)

删除队列

func (m *MqClient) Drop(mq string) (err error)

清空队列

func (m *MqClient) Ping() (err error)

func (m *MqClient) Pop(mq string, num int) (msgs []definition.Msg, err error)

从队列中读取指定条数消息并在队列中删除消息

func (m *MqClient) Push(mq string, msg string) (id uint64, err error)

向队列里添加消息

func (m *MqClient) Read(mq string, num int, timeout time.Duration) (msgs []definition.Msg, err error)

读取指定条数消息，并设置超时时间在时间范围内，消息不能再次被读取如果超出时间范围没有将消息删除或归档，消息会在下次被读取