queue

Documentation

Overview

Package queue allows you to queue and retrieve network encrypted messages from the queue.

The internal process of the queue generates constantly false messages for the continuous possibility of receiving messages. Taking messages from the queue involves a generation or waiting period.

Index

• type IMessageQueue
  • func NewMessageQueue(pSett ISettings, pClient client.IClient) IMessageQueue
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type SSettings

Types

type IMessageQueue

type IMessageQueue interface {
	types.IRunner
	WithNetworkSettings(uint64, net_message.ISettings) IMessageQueue

	GetSettings() ISettings
	GetClient() client.IClient

	EnqueueMessage(message.IMessage) error
	DequeueMessage(context.Context) net_message.IMessage
}

func NewMessageQueue

func NewMessageQueue(pSett ISettings, pClient client.IClient) IMessageQueue

type ISettings

type ISettings interface {
	GetMainCapacity() uint64
	GetPoolCapacity() uint64
	GetParallel() uint64
	GetDuration() time.Duration
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type SSettings

type SSettings sSettings