mqueue

package
v1.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 30, 2025 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const POLL_INTERVAL = 10 * time.Millisecond
View Source 
const RECV_TIMEOUT = 1 * time.Second
View Source 
const SEND_TIMEOUT = 1 * time.Second

Variables

View Source 
var DefaultQueueConfig = QueueConfig{SendTimeout: SEND_TIMEOUT, RecvTimeout: RECV_TIMEOUT, PollInterval: POLL_INTERVAL}

Functions

This section is empty.

Types

type MessageQueueIFace 

type MessageQueueIFace interface {
	SetConfig(QueueConfig)
	GetConfig() QueueConfig
	Connect(string)
	UseTopic(string)
	Send([]byte)
	Receive(StopCondFunc, RecvCallbackFunc)
	Close()
}

func NewScalableMessageQueue 

func NewScalableMessageQueue(config QueueConfig) MessageQueueIFace

func NewSimpleMessageQueue 

func NewSimpleMessageQueue(config QueueConfig) MessageQueueIFace

type NetworkHandler 

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

func NewNetworkHandler 

func NewNetworkHandler() *NetworkHandler

func (*NetworkHandler) GetErrorChan 

func (nh *NetworkHandler) GetErrorChan() <-chan error

func (*NetworkHandler) GetReceiverChannelFor 

func (nh *NetworkHandler) GetReceiverChannelFor(topicName string) <-chan []byte

func (*NetworkHandler) GetSenderChannelFor 

func (nh *NetworkHandler) GetSenderChannelFor(topicName string) chan<- []byte

func (*NetworkHandler) Shutdown 

func (nh *NetworkHandler) Shutdown()

type QueueConfig added in v1.2.5 

type QueueConfig struct {
	SendTimeout  time.Duration
	RecvTimeout  time.Duration
	PollInterval time.Duration
}

type RecvCallbackFunc added in v1.4.0 

type RecvCallbackFunc func(data []byte)

type ScalableMessageQueue 

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

func (*ScalableMessageQueue) Close 

func (smq *ScalableMessageQueue) Close()

func (*ScalableMessageQueue) Connect 

func (smq *ScalableMessageQueue) Connect(url string)

func (*ScalableMessageQueue) GetConfig added in v1.2.5 

func (smq *ScalableMessageQueue) GetConfig() QueueConfig

func (*ScalableMessageQueue) Init 

func (smq *ScalableMessageQueue) Init()

func (*ScalableMessageQueue) Receive 

func (smq *ScalableMessageQueue) Receive(stopCond StopCondFunc, recvCBFunc RecvCallbackFunc)

func (*ScalableMessageQueue) Send 

func (smq *ScalableMessageQueue) Send(message []byte)

func (*ScalableMessageQueue) SetConfig added in v1.2.5 

func (smq *ScalableMessageQueue) SetConfig(config QueueConfig)

func (*ScalableMessageQueue) UseTopic 

func (smq *ScalableMessageQueue) UseTopic(topicName string)

type SimpleMessageQueue 

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

func (*SimpleMessageQueue) Close 

func (mq *SimpleMessageQueue) Close()

func (*SimpleMessageQueue) Connect 

func (mq *SimpleMessageQueue) Connect(url string)

func (*SimpleMessageQueue) GetConfig added in v1.2.5 

func (mq *SimpleMessageQueue) GetConfig() QueueConfig

func (*SimpleMessageQueue) Init 

func (mq *SimpleMessageQueue) Init()

func (*SimpleMessageQueue) Receive 

func (mq *SimpleMessageQueue) Receive(stopCond StopCondFunc, recvCBFunc RecvCallbackFunc)

func (*SimpleMessageQueue) Send 

func (mq *SimpleMessageQueue) Send(message []byte)

func (*SimpleMessageQueue) SetConfig added in v1.2.5 

func (mq *SimpleMessageQueue) SetConfig(config QueueConfig)

func (*SimpleMessageQueue) UseTopic 

func (mq *SimpleMessageQueue) UseTopic(topicName string)

type StopCondFunc added in v1.4.0 

type StopCondFunc func([]byte) bool

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.