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

• Variables
• type IMessageQueue
  • func NewMessageQueue(pSettings ISettings, pVSettings IVSettings, pClient client.IClient) IMessageQueue
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type IVSettings
  • func NewVSettings(pSett *SVSettings) IVSettings
• type SSettings
• type SVSettings

Variables

var (
	ErrRunning    = errors.New("queue running")
	ErrQueueLimit = errors.New("queue limit")
)

Types

type IMessageQueue

type IMessageQueue interface {
	types.IRunner

	SetVSettings(IVSettings)
	GetVSettings() IVSettings

	GetSettings() ISettings
	GetClient() client.IClient

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

func NewMessageQueue

func NewMessageQueue(pSettings ISettings, pVSettings IVSettings, pClient client.IClient) IMessageQueue

type ISettings

type ISettings interface {
	GetNetworkMask() uint64
	GetWorkSizeBits() uint64
	GetMainCapacity() uint64
	GetVoidCapacity() uint64
	GetParallel() uint64
	GetDuration() time.Duration
	GetRandDuration() time.Duration
	GetLimitVoidSizeBytes() uint64
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type IVSettings

type IVSettings interface {
	GetNetworkKey() string
}

func NewVSettings

func NewVSettings(pSett *SVSettings) IVSettings

type SSettings

type SSettings sSettings

type SVSettings

type SVSettings sVSettings