vmq

README

verniy-mq-sdk

Documentation

Index

• Constants
• func CreateQueue(s Session, queueName string) error
• func Delete(s Session, queueName string, messageID MessageID) error
• func DeleteQueue(s Session, queueName string) error
• func ListQueue(s Session) ([]string, error)
• func Ping(s Session) error
• func Publish[T any](s Session, queueName string, msg T) error
• type Config
• type Message
  • func Consume[T any](s Session, queueName string) (Message[T], error)
• type MessageID
  • func (m MessageID) String() string
• type QueueSession
  • func NewQueueSession[MESSAGE_TYPE any](cfg *QueueSessionConfig) (QueueSession[MESSAGE_TYPE], error)
• type QueueSessionConfig
• type Session
  • func NewSession(cfg *Config) (Session, error)
• type SessionID

Constants

const (
	ResOK uint8
	ResError
)

Functions

func CreateQueue

func CreateQueue(s Session, queueName string) error

CreateQueue ...

func Delete

func Delete(s Session, queueName string, messageID MessageID) error

Delete ...

func DeleteQueue

func DeleteQueue(s Session, queueName string) error

DeleteQueue ...

func ListQueue

func ListQueue(s Session) ([]string, error)

ListQueue ...

func Ping

func Ping(s Session) error

Ping ...

func Publish

func Publish[T any](s Session, queueName string, msg T) error

Publish ...

Types

type Config

type Config struct {
	Addr     string
	UserID   string
	Password string
}

Config ...

type Message

type Message[T any] struct {
	ID   MessageID
	Data T
}

Message ...

func Consume

func Consume[T any](s Session, queueName string) (Message[T], error)

Consume ...

type MessageID

type MessageID [26]byte

MessageID ...

func (MessageID) String

func (m MessageID) String() string

String ...

type QueueSession

type QueueSession[MESSAGE_TYPE any] interface {
	ID() string
	Close() error
	Ping() error
	Consume() (Message[MESSAGE_TYPE], error)
	Delete(messageID MessageID) error
	Publish(msg MESSAGE_TYPE) error
}

QueueSession ...

func NewQueueSession

func NewQueueSession[MESSAGE_TYPE any](cfg *QueueSessionConfig) (QueueSession[MESSAGE_TYPE], error)

NewQueueSession ...

type QueueSessionConfig

type QueueSessionConfig struct {
	Addr      string
	QueueName string
	UserID    string
	Password  string
}

QueueSessionConfig ...

type Session

type Session interface {
	ID() string
	Close() error
	Ping() error
	CreateQueue(queueName string) error
	ListQueue() ([]string, error)
	DeleteQueue(queueName string) error
	Consume(queueName string) (any, error)
	Delete(queueName string, messageID MessageID) error
	Publish(queueName string, msg any) error
	// contains filtered or unexported methods
}

Session ...

func NewSession

func NewSession(cfg *Config) (Session, error)

NewSession ...

type SessionID

type SessionID [32]rune

SessionID ...