queue

Documentation

Index

• func NewClientStopReasonQueue(p interfaces.ConfigProvider) interfaces.ClientStopQueue
• func NewHashQueue(p interfaces.ConfigProvider) interfaces.FlushingQueue
• func NewHashingRequestQueue() interfaces.RequestQueue
• func NewHashingSubmissionQueue() interfaces.SubmissionQueue
• func NewPasswordQueue(p interfaces.ConfigProvider) interfaces.Queue
• type ClientStopReasonQueue
  • func (c ClientStopReasonQueue) Get() (models.ClientStopReason, error)
  • func (c ClientStopReasonQueue) Put(reason models.ClientStopReason) error
• type HashQueue
  • func (q HashQueue) Flush() error
  • func (q HashQueue) Get() (string, error)
  • func (q HashQueue) Put(hash string) error
  • func (q HashQueue) Size() int
• type HashingRequestQueue
  • func (q HashingRequestQueue) Get() (models.HashingRequest, error)
  • func (q HashingRequestQueue) Put(request models.HashingRequest) error
  • func (q HashingRequestQueue) Size() int
• type HashingSubmissionQueue
  • func (q HashingSubmissionQueue) Get() (models.HashSubmission, error)
  • func (q HashingSubmissionQueue) Put(submission models.HashSubmission) error
  • func (q HashingSubmissionQueue) Size() int
• type PasswordQueue
  • func (q PasswordQueue) Get() (string, error)
  • func (q PasswordQueue) Put(password string) error
  • func (q PasswordQueue) Size() int

Functions

func NewClientStopReasonQueue

func NewClientStopReasonQueue(p interfaces.ConfigProvider) interfaces.ClientStopQueue

func NewHashQueue

func NewHashQueue(p interfaces.ConfigProvider) interfaces.FlushingQueue

func NewHashingRequestQueue

func NewHashingRequestQueue() interfaces.RequestQueue

func NewHashingSubmissionQueue

func NewHashingSubmissionQueue() interfaces.SubmissionQueue

func NewPasswordQueue

func NewPasswordQueue(p interfaces.ConfigProvider) interfaces.Queue

Types

type ClientStopReasonQueue

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

func (ClientStopReasonQueue) Get

func (c ClientStopReasonQueue) Get() (models.ClientStopReason, error)

func (ClientStopReasonQueue) Put

func (c ClientStopReasonQueue) Put(reason models.ClientStopReason) error

type HashQueue

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

func (HashQueue) Flush

func (q HashQueue) Flush() error

func (HashQueue) Get

func (q HashQueue) Get() (string, error)

func (HashQueue) Put

func (q HashQueue) Put(hash string) error

func (HashQueue) Size

func (q HashQueue) Size() int

type HashingRequestQueue

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

func (HashingRequestQueue) Get

func (q HashingRequestQueue) Get() (models.HashingRequest, error)

func (HashingRequestQueue) Put

func (q HashingRequestQueue) Put(request models.HashingRequest) error

func (HashingRequestQueue) Size

func (q HashingRequestQueue) Size() int

type HashingSubmissionQueue

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

func (HashingSubmissionQueue) Get

func (q HashingSubmissionQueue) Get() (models.HashSubmission, error)

func (HashingSubmissionQueue) Put

func (q HashingSubmissionQueue) Put(submission models.HashSubmission) error

func (HashingSubmissionQueue) Size

func (q HashingSubmissionQueue) Size() int

type PasswordQueue

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

func (PasswordQueue) Get

func (q PasswordQueue) Get() (string, error)

func (PasswordQueue) Put

func (q PasswordQueue) Put(password string) error

func (PasswordQueue) Size

func (q PasswordQueue) Size() int