The highest tagged major version is v7.

atomic

package

v4.5.2+incompatible Latest Latest Go to latest Published: May 28, 2021 License: Apache-2.0 Imports: 3 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/aerospike/aerospike-client-go

Links

Open Source Insights

Documentation ¶

Index ¶

type Array
- func NewArray(length int) *Array
type Bool
- func NewBool(value bool) *Bool
type Int
- func NewInt(value int) *Int
type Queue
- func NewQueue(size int) *Queue
- func (q *Queue) Offer(obj interface{}) bool
- func (q *Queue) Poll() (res interface{})
type SyncVal
- func NewSyncVal(val interface{}) *SyncVal

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Array ¶

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

Array implement a fixed width array with atomic semantics

func NewArray ¶

func NewArray(length int) *Array

NewArray generates a new Array instance.

func (*Array) Get ¶

func (aa *Array) Get(idx int) interface{}

Get atomically retrieves an element from the Array. If idx is out of range, it will return nil

func (*Array) Length ¶

func (aa *Array) Length() int

Length returns the array size.

func (*Array) Set ¶

func (aa *Array) Set(idx int, node interface{}) error

Set atomically sets an element in the Array. If idx is out of range, it will return an error

type Bool ¶

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

Bool implements a synchronized boolean value

func NewBool ¶

func NewBool(value bool) *Bool

NewBool generates a new Boolean instance.

func (*Bool) CompareAndToggle ¶

func (ab *Bool) CompareAndToggle(expect bool) bool

CompareAndToggle atomically sets the boolean value if the current value is equal to updated value.

func (*Bool) Get ¶

func (ab *Bool) Get() bool

Get atomically retrieves the boolean value.

func (*Bool) Or ¶

func (ab *Bool) Or(newVal bool) bool

Or atomically applies OR operation to the boolean value.

func (*Bool) Set ¶

func (ab *Bool) Set(newVal bool)

Set atomically sets the boolean value.

type Int ¶

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

Int implements an int value with atomic semantics

func NewInt ¶

func NewInt(value int) *Int

NewInt generates a newVal Int instance.

func (*Int) AddAndGet ¶

func (ai *Int) AddAndGet(delta int) int

AddAndGet atomically adds the given value to the current value.

func (*Int) CompareAndSet ¶

func (ai *Int) CompareAndSet(expect int, update int) bool

CompareAndSet atomically sets the value to the given updated value if the current value == expected value. Returns true if the expectation was met

func (*Int) DecrementAndGet ¶

func (ai *Int) DecrementAndGet() int

DecrementAndGet atomically decrements current value by one and returns the result.

func (*Int) Get ¶

func (ai *Int) Get() int

Get atomically retrieves the current value.

func (*Int) GetAndAdd ¶

func (ai *Int) GetAndAdd(delta int) int

GetAndAdd atomically adds the given delta to the current value and returns the result.

func (*Int) GetAndDecrement ¶

func (ai *Int) GetAndDecrement() int

GetAndDecrement atomically decrements the current value by one and returns the result.

func (*Int) GetAndIncrement ¶

func (ai *Int) GetAndIncrement() int

GetAndIncrement atomically increments current value by one and returns the result.

func (*Int) GetAndSet ¶

func (ai *Int) GetAndSet(newValue int) int

GetAndSet atomically sets current value to the given value and returns the old value.

func (*Int) IncrementAndGet ¶

func (ai *Int) IncrementAndGet() int

IncrementAndGet atomically increments current value by one and returns the result.

func (*Int) Set ¶

func (ai *Int) Set(newValue int)

Set atomically sets current value to the given value.

type Queue ¶

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

Queue is a non-blocking FIFO queue. If the queue is empty, nil is returned. if the queue is full, offer will return false

func NewQueue ¶

func NewQueue(size int) *Queue

NewQueue creates a new queue with initial size.

func (*Queue) Offer ¶

func (q *Queue) Offer(obj interface{}) bool

Offer adds an item to the queue unless the queue is full. In case the queue is full, the item will not be added to the queue and false will be returned

func (*Queue) Poll ¶

func (q *Queue) Poll() (res interface{})

Poll removes and returns an item from the queue. If the queue is empty, nil will be returned.

type SyncVal ¶

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

SyncVal allows synchronized access to a value

func NewSyncVal ¶

func NewSyncVal(val interface{}) *SyncVal

NewSyncVal creates a new instance of SyncVal

func (*SyncVal) Get ¶

func (sv *SyncVal) Get() interface{}

Get returns the value inside the SyncVal

func (*SyncVal) GetSyncedVia ¶

func (sv *SyncVal) GetSyncedVia(f func(interface{}) (interface{}, error)) (interface{}, error)

GetSyncedVia returns the value returned by the function f.

func (*SyncVal) Set ¶

func (sv *SyncVal) Set(val interface{})

Set updates the value of SyncVal with the passed argument

func (*SyncVal) Update ¶

func (sv *SyncVal) Update(f func(interface{}) (interface{}, error)) error

Update gets a function and passes the value of SyncVal to it. If the resulting err is nil, it will update the value of SyncVal. It will return the resulting error to the caller.

Source Files ¶

View all Source files

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