mq

Documentation

Index

• Constants
• Variables
• type MQClient
  • func NewNATSClient(addrs string) (MQClient, error)

Constants

const (
	MessageQueueTypeNATS = "nats"
)

Message queue type constants

Variables

var (
	ErrorMessageQueueTypeUnsupported = errors.New("unsupported message queue type")
)

Types

type MQClient

type MQClient interface {
	Publish(string, interface{}) error
	Subscribe(string, func(interface{})) (int64, error)
	SubscribeWithGroup(string, string, func(interface{})) (int64, error)
	Unsubscribe(int64) error
	Group(int64) (string, error)
	Close() error
}

func NewNATSClient

func NewNATSClient(addrs string) (MQClient, error)

NewNATSClient return MessageQueueClient