internal

package

v0.0.0-...-0228d8e Latest Latest Go to latest Published: Nov 10, 2021 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/reddec/pqueue

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type IntSet ¶

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

func (*IntSet) Add ¶

func (is *IntSet) Add(value uint64) bool

Add element to set. Returns true if was no value before.

func (*IntSet) Remove ¶

func (is *IntSet) Remove(value uint64) bool

Remove element from set. Return true if was value before.

func (*IntSet) Size ¶

func (is *IntSet) Size() int

Size of set.

type Metadata ¶

type Metadata struct {
	// Payload storing type
	PackageType PackagingType `msg:"t,omitempty"`
	// Payload size in bytes
	Size int64 `msg:"s,omitempty"`
	// Number of attempts. 0 means fresh messaged. Should grow every re-queue operation (except abnormal shutdown).
	Attempts int64 `msg:"a,omitempty"`
	// inline data, valid ony in case package type = inline
	InlineData []byte `msg:"d,omitempty"`
	// user-defined properties
	Properties map[string][]byte `msg:"p,omitempty"`
}

Metadata of message, stored directly in queue.

func (*Metadata) DecodeMsg ¶

func (z *Metadata) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (*Metadata) EncodeMsg ¶

func (z *Metadata) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (*Metadata) MarshalMsg ¶

func (z *Metadata) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (*Metadata) Msgsize ¶

func (z *Metadata) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*Metadata) UnmarshalMsg ¶

func (z *Metadata) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

type PackagingType ¶

type PackagingType byte

PackagingType defines how to store payload

const (
	InlineData PackagingType = 0 // content stored in next bytes
	LinkedData PackagingType = 1 // content stored in attached file
)

func (*PackagingType) DecodeMsg ¶

func (z *PackagingType) DecodeMsg(dc *msgp.Reader) (err error)

DecodeMsg implements msgp.Decodable

func (PackagingType) EncodeMsg ¶

func (z PackagingType) EncodeMsg(en *msgp.Writer) (err error)

EncodeMsg implements msgp.Encodable

func (PackagingType) MarshalMsg ¶

func (z PackagingType) MarshalMsg(b []byte) (o []byte, err error)

MarshalMsg implements msgp.Marshaler

func (PackagingType) Msgsize ¶

func (z PackagingType) Msgsize() (s int)

Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message

func (*PackagingType) UnmarshalMsg ¶

func (z *PackagingType) UnmarshalMsg(bts []byte) (o []byte, err error)

UnmarshalMsg implements msgp.Unmarshaler

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL