queue

type Queue interface {
	// Put request to queue
	Put(ctx context.Context, request *types.Request) error
	// Peek oldest request or wait till new data arrived/context expiration
	Peek(ctx context.Context) (*types.Request, error)
	// Commit (remove) oldest record
	Commit(ctx context.Context) error
	// Clean all internal allocated resource
	Destroy() error
}