coordinator

package

Go to main page

Versions in this module

v1

v1.3.4

Dec 11, 2024

Changes in this version

type Object

+ func ReadAllObjects(rs ResultSet) ([]Object, error)

v1.3.3

Aug 22, 2024

v1.3.2

May 21, 2024

v1.3.1

May 18, 2024

v1.3.0

Dec 30, 2023

v1.2.0

Nov 14, 2023

v1.1.1

Nov 2, 2023

v1.1.0

Oct 19, 2023

v1.0.3

Sep 30, 2023

v1.0.2

Sep 13, 2023

v1.0.1

Sep 6, 2023

v1.0.0

Aug 29, 2023

Changes in this version

+ const CBOR

+ const JobHeaderObject

+ const MessageHeaderObject

+ const OrderAsc

+ const OrderDesc

+ const OrderNone

+ const PrimaryIndex

+ const SecondaryIndex

+ const StateHeaderObject

+ const Unknown

+ const V1

+ var ErrNoMessage = errors.New("no message")

+ var JobObjectKeyHeader = [2]byte

+ var MessageObjectKeyHeader = [2]byte

+ var NoLimit = int(0)

+ var NoOffset = uint(0)

+ var StateObjectKeyHeader = [2]byte

+ func GetAllHeaderPrefixes() [][]byte

+ func HeaderByteFromVersion(v Version) byte

+ func NewErrObjectNotSupported(v any) error

+ func TypeFromHeaderByte(b byte) byte

type Coordinator

+ GetStateObject func(t StateType, key Key) (Object, error)

+ GetStateObjects func(t StateType) (ResultSet, error)

+ PostMessage func(msg Message) error

+ SetNode func(node cluster.Node)

+ SetStateObject func(t StateType, obj Object) error

+ type DocumentType byte

type EventType

+ const CreatedEvent

+ const DeletedEvent

+ const UpdatedEvent

+ type HeaderType byte

+ func GetAllHeaderTypes() []HeaderType

+ type IndexType byte

type Key

+ func NewMessageKeyWith(msg Message, clock cluster.Clock) Key

+ func NewMessageScanKey() Key

+ func NewScanStateKeyWith(t StateType) Key

+ func NewStateKeyWith(t StateType, elems ...any) Key

+ type KeyCoder interface

+ type KeyDecoder interface

+ DecodeKey func([]byte) (Key, error)

+ type KeyEncoder interface

+ EncodeKey func(Key) ([]byte, error)

+ type KeyHeader [2]byte

+ func NewKeyHeaderFrom(b []byte) KeyHeader

+ func (header KeyHeader) Bytes() []byte

+ func (header KeyHeader) DocumentType() DocumentType

+ func (header KeyHeader) IndexType() IndexType

+ func (header KeyHeader) String() string

+ func (header KeyHeader) Type() HeaderType

+ func (header KeyHeader) Version() Version

+ type LimitOption struct

+ Limit int

+ func NewLimitOption(limit int) *LimitOption

type Message

+ func NewMessageFrom(obj *MessageObject) Message

+ Clock func() cluster.Clock

+ Equals func(Message) bool

+ Event func() EventType

+ From func() cluster.Node

+ String func() string

+ UnmarshalTo func(to any) error

+ type MessageObject struct

+ EncBytes []byte

+ EvtType byte

+ FromCluster string

+ FromHost string

+ FromID uuid.UUID

+ MsgClock uint64

+ MsgType byte

+ func NewMessageObject() *MessageObject

+ func NewMessageObjectWith(msg Message, node cluster.Node, clock cluster.Clock) (*MessageObject, error)

+ func (obj *MessageObject) Clock() cluster.Clock

+ func (obj *MessageObject) Equals(other Message) bool

+ func (obj *MessageObject) Event() EventType

+ func (obj *MessageObject) From() cluster.Node

+ func (obj *MessageObject) ID() uuid.UUID

+ func (obj *MessageObject) Object() (any, error)

+ func (obj *MessageObject) String() string

+ func (obj *MessageObject) Type() MessageType

+ func (obj *MessageObject) UnmarshalTo(to any) error

type MessageType

+ const CollectionMessage

+ const DatabaseMessage

+ const ObjectMessage

+ const UserMessage

+ func (t MessageType) String() string

type Object

+ func NewObjectFrom(key Key, val any) (Object, error)

+ Bytes func() []byte

+ Unmarshal func(toj any) error

type Observer

+ OnMessageReceived func(msg Message)

+ type OffsetOption struct

+ Offset uint

+ func NewOffsetOption(offset uint) *OffsetOption

+ type Option = any

+ type Order = int

+ type OrderOption struct

+ Order Order

+ func NewOrderOptionWith(order Order) *OrderOption

+ type StateType uint8

+ const NodeState

+ func (t StateType) String() string

+ type Store interface

+ DecodeKey func([]byte) (Key, error)

+ EncodeKey func(Key) ([]byte, error)

+ SetKeyCoder func(coder KeyCoder)

+ Transact func() (Transaction, error)

type Transaction

+ GetRange func(key Key, opts ...Option) (ResultSet, error)

+ Remove func(key Key) error

+ Truncate func() error

+ type Version byte

+ func VertionFromHeaderByte(b byte) Version

v0

v0.9.0

May 7, 2023

Changes in this version

+ var ErrNotSupported = errors.New("not supported")

+ func NewErrNotSupported(v any) error

type Coordinator

+ Watch func(key Key, w Watcher) error

type Event

+ Equals func(Event) bool

+ String func() string

type EventType

+ func (t EventType) String() string

type Key

+ func (key Key) Equals(other Key) bool

+ func (key Key) String() string

type Object

+ Equals func(Object) bool

+ String func() string

+ type Watcher interface

+ ProcessEvent func(evt Event)

v0.8.0

Apr 9, 2023

Changes in this version

+ var ErrInvalid = errors.New("invalid")

+ var ErrNotExist = errors.New("not exist")

+ func NewKeyNotExistError(v any) error

+ type Coordinator interface

+ AddObserver func(key Key, observer Observer) error

+ Transact func() (Transaction, error)

+ type Event interface

+ Object func() Object

+ Type func() EventType

+ func NewEventWith(t EventType, obj Object) Event

+ type EventType uint8

+ const ObjectCreated

+ const ObjectDeleted

+ const ObjectUpdated

+ type Key []string

+ func NewKey() Key

+ func NewKeyFrom(v any) (Key, error)

+ func NewKeyWith(elems ...string) Key

+ func (key Key) Elements() []string

+ func (key Key) Encode() (string, error)

+ type Message interface

+ Object func() any

+ Type func() MessageType

+ func NewMessageWith(typ MessageType, obj any) Message

+ type MessageType uint8

+ type Object interface

+ Encode func() ([]byte, error)

+ Key func() Key

+ Value func() Value

+ func NewObjectWith(key Key, value Value) Object

+ type Observer interface

+ ProcessEvent func(evt Event)

+ type ResultSet interface

+ Next func() bool

+ Object func() Object

+ Objects func() []Object

+ type Transaction interface

+ Cancel func() error

+ Commit func() error

+ Delete func(key Key) error

+ Get func(key Key) (Object, error)

+ Range func(key Key) (ResultSet, error)

+ Set func(obj Object) error

+ type Value any

+ func NewValueFrom(v any) (Value, error)

+ func NewValueWith(v any) Value

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