skykiss

package
v1.2.0-rc3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 23, 2019 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VariantNCS = iota
	VariantRFC4122
	VariantMicrosoft
	VariantFuture
)

UUID layout variants.

View Source 
const (
	DomainPerson = iota
	DomainGroup
	DomainOrg
)

UUID DCE domains.

Variables

View Source 
var (
	NamespaceDNS, _  = FromString("6ba7b810-9dad-11d1-80b4-00c04fd430c8")
	NamespaceURL, _  = FromString("6ba7b811-9dad-11d1-80b4-00c04fd430c8")
	NamespaceOID, _  = FromString("6ba7b812-9dad-11d1-80b4-00c04fd430c8")
	NamespaceX500, _ = FromString("6ba7b814-9dad-11d1-80b4-00c04fd430c8")
)

Predefined namespace UUIDs.

View Source 
var (
	ErrDisposed = errors.New(`queue: disposed`)
)
View Source 
var Nil = UUID{}

The nil UUID is special form of UUID that is specified to have all 128 bits set to zero.

Functions

func BytesRelease 

func BytesRelease(b BytesPackage)

func Chunker 

func Chunker(sliceLen, chunkSize int, callable func(from, to int) error) (err error)

func Equal 

func Equal(u1 UUID, u2 UUID) bool

Equal returns true if u1 and u2 equals, otherwise returns false.

func MultiListener 

func MultiListener(ll ...net.Listener) net.Listener

func WaitTimeout 

func WaitTimeout(c *sync.Cond, timeout time.Duration)

Types

type AutoIncSequence 

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

func (*AutoIncSequence) Last 

func (self *AutoIncSequence) Last() uint64

func (*AutoIncSequence) Next 

func (self *AutoIncSequence) Next() uint64

func (*AutoIncSequence) Reset 

func (self *AutoIncSequence) Reset(v uint64)

type BytePool 

type BytePool struct {
	Size int
	Pool *sync.Pool
}

func BytePoolX 

func BytePoolX(x int) BytePool

type BytesPackage 

type BytesPackage struct {
	Bytes []byte
	// contains filtered or unexported fields
}

func BytesNew 

func BytesNew(size int) BytesPackage

type IOLoop 

type IOLoop struct {
	io.Reader
	io.Writer
}

type NullReader 

type NullReader struct {
	Chunk int
}

func (NullReader) Read 

func (self NullReader) Read(p []byte) (n int, err error)

type Reader 

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

A Reader implements the io.Reader, io.ReaderAt, io.WriterTo, io.Seeker, io.ByteScanner, and io.RuneScanner interfaces by reading from a byte slice. Unlike a Buffer, a Reader is read-only and supports seeking.

func NewReader 

func NewReader(b []byte) *Reader

NewReader returns a new Reader reading from b.

func (*Reader) Len 

func (r *Reader) Len() int

Len returns the number of bytes of the unread portion of the slice.

func (*Reader) Read 

func (r *Reader) Read(b []byte) (n int, err error)

func (*Reader) ReadAt 

func (r *Reader) ReadAt(b []byte, off int64) (n int, err error)

func (*Reader) ReadByte 

func (r *Reader) ReadByte() (b byte, err error)

func (*Reader) ReadRune 

func (r *Reader) ReadRune() (ch rune, size int, err error)

func (*Reader) Reset 

func (r *Reader) Reset(b []byte) (n int64, err error)

func (*Reader) Seek 

func (r *Reader) Seek(offset int64, whence int) (int64, error)

Seek implements the io.Seeker interface.

func (*Reader) Size 

func (r *Reader) Size() int64

Size returns the original length of the underlying byte slice. Size is the number of bytes available for reading via ReadAt. The returned value is always the same and is not affected by calls to any other method.

func (*Reader) UnreadByte 

func (r *Reader) UnreadByte() error

func (*Reader) UnreadRune 

func (r *Reader) UnreadRune() error

func (*Reader) WriteTo 

func (r *Reader) WriteTo(w io.Writer) (n int64, err error)

WriteTo implements the io.WriterTo interface.

type RingBuffer 

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

RingBuffer is a MPMC buffer that achieves threadsafety with CAS operations only. A put on full or get on empty call will block until an item is put or retrieved. Calling Dispose on the RingBuffer will unblock any blocked threads with an error. This buffer is similar to the buffer described here: http://www.1024cores.net/home/lock-free-algorithms/queues/bounded-mpmc-queue with some minor additions.

func NewRingBuffer 

func NewRingBuffer(size uint64) *RingBuffer

NewRingBuffer will allocate, initialize, and return a ring buffer with the specified size.

func (*RingBuffer) Cap 

func (rb *RingBuffer) Cap() uint64

Cap returns the capacity of this ring buffer.

func (*RingBuffer) Dispose 

func (rb *RingBuffer) Dispose()

Dispose will dispose of this queue and free any blocked threads in the Put and/or Get methods. Calling those methods on a disposed queue will return an error.

func (*RingBuffer) Get 

func (rb *RingBuffer) Get() (interface{}, error)

Get will return the next item in the queue. This call will block if the queue is empty. This call will unblock when an item is added to the queue or Dispose is called on the queue. An error will be returned if the queue is disposed.

func (*RingBuffer) IsDisposed 

func (rb *RingBuffer) IsDisposed() bool

IsDisposed will return a bool indicating if this queue has been disposed.

func (*RingBuffer) Len 

func (rb *RingBuffer) Len() uint64

Len returns the number of items in the queue.

func (*RingBuffer) Offer 

func (rb *RingBuffer) Offer(item interface{}) (bool, error)

Offer adds the provided item to the queue if there is space. If the queue is full, this call will return false. An error will be returned if the queue is disposed.

func (*RingBuffer) Put 

func (rb *RingBuffer) Put(item interface{}) error

Put adds the provided item to the queue. If the queue is full, this call will block until an item is added to the queue or Dispose is called on the queue. An error will be returned if the queue is disposed.

type SkipHash 

type SkipHash struct {
	hash.Hash32
	// contains filtered or unexported fields
}

func (*SkipHash) Write 

func (self *SkipHash) Write(p []byte) (n int, err error)

type SliceBuf 

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

func SliceBufNew 

func SliceBufNew(pSize int) *SliceBuf

func (*SliceBuf) Acquire 

func (self *SliceBuf) Acquire() *SliceBufAgent

func (*SliceBuf) Release 

func (self *SliceBuf) Release(b *SliceBufAgent)

type SliceBufAgent 

type SliceBufAgent struct {
	Bytes []byte
}

type UUID 

type UUID [16]byte

UUID representation compliant with specification described in RFC 4122.

func And 

func And(u1 UUID, u2 UUID) UUID

And returns result of binary AND of two UUIDs.

func FromBytes 

func FromBytes(input []byte) (u UUID, err error)

FromBytes returns UUID converted from raw byte slice input. It will return error if the slice isn't 16 bytes long.

func FromBytesOrNil 

func FromBytesOrNil(input []byte) UUID

FromBytesOrNil returns UUID converted from raw byte slice input. Same behavior as FromBytes, but returns a Nil UUID on error.

func FromString 

func FromString(input string) (u UUID, err error)

FromString returns UUID parsed from string input. Input is expected in a form accepted by UnmarshalText.

func FromStringOrNil 

func FromStringOrNil(input string) UUID

FromStringOrNil returns UUID parsed from string input. Same behavior as FromString, but returns a Nil UUID on error.

func NewV1 

func NewV1() UUID

NewV1 returns UUID based on current timestamp and MAC address.

func NewV2 

func NewV2(domain byte) UUID

NewV2 returns DCE Security UUID based on POSIX UID/GID.

func NewV3 

func NewV3(ns UUID, name string) UUID

NewV3 returns UUID based on MD5 hash of namespace UUID and name.

func NewV4 

func NewV4() UUID

NewV4 returns random generated UUID.

func NewV5 

func NewV5(ns UUID, name string) UUID

NewV5 returns UUID based on SHA-1 hash of namespace UUID and name.

func Or 

func Or(u1 UUID, u2 UUID) UUID

Or returns result of binary OR of two UUIDs.

func (UUID) Bytes 

func (u UUID) Bytes() []byte

Bytes returns bytes slice representation of UUID.

func (UUID) MarshalBinary 

func (u UUID) MarshalBinary() (data []byte, err error)

MarshalBinary implements the encoding.BinaryMarshaler interface.

func (UUID) MarshalText 

func (u UUID) MarshalText() (text []byte, err error)

MarshalText implements the encoding.TextMarshaler interface. The encoding is the same as returned by String.

func (*UUID) Scan 

func (u *UUID) Scan(src interface{}) error

Scan implements the sql.Scanner interface. A 16-byte slice is handled by UnmarshalBinary, while a longer byte slice or a string is handled by UnmarshalText.

func (*UUID) SetVariant 

func (u *UUID) SetVariant()

SetVariant sets variant bits as described in RFC 4122.

func (*UUID) SetVersion 

func (u *UUID) SetVersion(v byte)

SetVersion sets version bits.

func (UUID) String 

func (u UUID) String() string

Returns canonical string representation of UUID: xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx.

func (*UUID) UnmarshalBinary 

func (u *UUID) UnmarshalBinary(data []byte) (err error)

UnmarshalBinary implements the encoding.BinaryUnmarshaler interface. It will return error if the slice isn't 16 bytes long.

func (*UUID) UnmarshalText 

func (u *UUID) UnmarshalText(text []byte) (err error)

UnmarshalText implements the encoding.TextUnmarshaler interface. Following formats are supported: "6ba7b810-9dad-11d1-80b4-00c04fd430c8", "{6ba7b810-9dad-11d1-80b4-00c04fd430c8}", "urn:uuid:6ba7b810-9dad-11d1-80b4-00c04fd430c8"

func (UUID) Value 

func (u UUID) Value() (driver.Value, error)

Value implements the driver.Valuer interface.

func (UUID) Variant 

func (u UUID) Variant() uint

Variant returns UUID layout variant.

func (UUID) Version 

func (u UUID) Version() uint

Version returns algorithm version used to generate UUID.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.