UnmarshalMsg implements msgp.Unmarshaler

NewJournal creates a new journal backed by a BoltDB bucket, in the context of a transaction.

EmitEventAnnounce never blocks. Internal workers will eventually handle the events to emit.

MarshalMsg implements msgp.Marshaler

UnmarshalMsg implements msgp.Unmarshaler

GetObject gets an object from the local storage of the node. Used for private API, when other nodes ask for an object.

Diff finds the difference between serialized exernal journal represented as list, and journals currently available on this local node.

ListenAndServe initializes a HTTP listener for private services, starts listening on a TCP address for virtual network transport.

MakeJournal allows to represent a serialized list of events as an in-memory journal compatible with journals backed by a real KV store.

MarshalMsg implements msgp.Marshaler

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

PutObject writes object to the local storage, emits cluster announcements, optionally writes object to remote storage, e.g. Amazon S3. Returns amount

PUMP CODE — a circular buffer Copyright 2014 The Go Authors pumpEventAnnounces returns a channel src such that sending on src will eventually send on

DecodeMsg implements msgp.Decodable

DeleteObject marks object as deleted in journals and deletes it from the local storage. This operation does not delete object from remote storage.

EncodeMsg implements msgp.Encodable

ExposeAPI initiates HTTP routing to the private API via loopback.

FindObject gets and object from any node, if not found then tries to acquire from the remote storage, e.g. Amazon S3.

HeadObject gets object's meta data from the local journal.

JoinCluster connects to another machines via TCP to join the virtual network.

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

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

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

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

ReceiveEventAnnounce never blocks. Internal workers will eventually handle the received events.