inmem

Documentation

Index

• type QueueInMem
  • func New(pubsub pubsub.PublishSubscriber, logger log.Logger) *QueueInMem
  • func (q *QueueInMem) Clear(_ context.Context, event mdm.CheckinEvent) error
  • func (q *QueueInMem) Next(_ context.Context, resp mdm.Response) ([]byte, error)

Types

type QueueInMem

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

QueueInMem represents an in-memory command queue

func New

func New(pubsub pubsub.PublishSubscriber, logger log.Logger) *QueueInMem

New creates a new in-memory command queue

func (*QueueInMem) Clear

func (q *QueueInMem) Clear(_ context.Context, event mdm.CheckinEvent) error

Clear clears a command queue for the enrollment in event

func (*QueueInMem) Next

func (q *QueueInMem) Next(_ context.Context, resp mdm.Response) ([]byte, error)

Next delivers the next command from the command queue for the enrollment in resp