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 IQBProblemProcessor
  • func NewQBProblemProcessor(pSettings ISettings, pClient client.IClient) IQBProblemProcessor
• type ISettings
  • func NewSettings(pSett *SSettings) ISettings
• type SQueueError
  • func (err *SQueueError) Error() string
• type SSettings

Variables

var (
	ErrRunning        = &SQueueError{"queue running"}
	ErrQueueLimit     = &SQueueError{"queue limit"}
	ErrEncryptMessage = &SQueueError{"encrypt message"}
)

Types

type IQBProblemProcessor

type IQBProblemProcessor interface {
	types.IRunner

	GetSettings() ISettings
	GetClient() client.IClient

	EnqueueMessage(asymmetric.IPubKey, []byte) error
	DequeueMessage(context.Context) layer1.IMessage
}

func NewQBProblemProcessor

func NewQBProblemProcessor(pSettings ISettings, pClient client.IClient) IQBProblemProcessor

type ISettings

type ISettings interface {
	GetMessageConstructSettings() layer1.IConstructSettings
	GetNetworkMask() uint32
	GetConsumersCap() uint64
	GetQueuePeriod() time.Duration
	GetQueuePoolCap() [2]uint64
}

func NewSettings

func NewSettings(pSett *SSettings) ISettings

type SQueueError

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

func (*SQueueError) Error

func (err *SQueueError) Error() string

type SSettings

type SSettings sSettings