mq

Documentation

Index

• type Conf
• type MQType
• type MessageQueue
  • func NewMessageQueue(mqType MQType) MessageQueue
  • func NewNatsMQ() MessageQueue

Types

type Conf

type Conf struct {
	NatsAddress string `json:"nats_address"`
}

Conf is the configuration for the message queue.

type MQType

type MQType string

MQType is the type of message queue.

const (
	NATS MQType = "nats"
)

Message queue types

type MessageQueue

type MessageQueue interface {
	Connect() error
	Close() error
	Publish(subject string, data interface{}) error
	Subscribe(subject string, insertFunc insertFunction) error
	UnSubscribe() error
}

MessageQueue is the interface that wraps the basic message queue operations.

func NewMessageQueue

func NewMessageQueue(mqType MQType) MessageQueue

NewMessageQueue returns a new message queue instance.

func NewNatsMQ

func NewNatsMQ() MessageQueue

NewNatsMQ - create new nats message queue