types

Documentation

Index

• Constants
• Variables
• type AtomicLLSN
  • func (llsn *AtomicLLSN) Add(delta uint64) LLSN
  • func (llsn *AtomicLLSN) CompareAndSwap(old, new LLSN) (swapped bool)
  • func (llsn *AtomicLLSN) Load() LLSN
  • func (llsn *AtomicLLSN) Store(val LLSN)
• type ClusterID
  • func NewClusterIDFromUint(u uint) (ClusterID, error)
  • func ParseClusterID(s string) (ClusterID, error)
  • func (cid ClusterID) String() string
• type GLSN
  • func (glsn GLSN) Invalid() bool
• type LLSN
  • func (llsn LLSN) Invalid() bool
• type LogStreamID
  • func ParseLogStreamID(s string) (LogStreamID, error)
  • func (lsid LogStreamID) Invalid() bool
  • func (lsid LogStreamID) String() string
• type NodeID
  • func NewNodeID(addr string) NodeID
  • func NewNodeIDFromURL(rawurl string) NodeID
  • func (nid NodeID) Reverse() string
  • func (nid NodeID) String() string
• type StorageNodeID
  • func ParseStorageNodeID(s string) (StorageNodeID, error)
  • func (snid StorageNodeID) Invalid() bool
  • func (snid StorageNodeID) String() string
• type TopicID
  • func ParseTopicID(s string) (TopicID, error)
  • func (tpid TopicID) Invalid() bool
  • func (tpid TopicID) String() string
• type Version
  • func (ver Version) Invalid() bool

Constants

const (
	InvalidVersion = Version(0)
	MinVersion     = Version(1)
	MaxVersion     = Version(math.MaxUint64)
)

const (
	InvalidGLSN = GLSN(0)
	MinGLSN     = GLSN(1)
	MaxGLSN     = GLSN(math.MaxUint64)
)

const (
	InvalidLLSN = LLSN(0)
	MinLLSN     = LLSN(1)
	MaxLLSN     = LLSN(math.MaxUint64)
)

const (
	InvalidNodeID = NodeID(0)
	MinNodeID     = NodeID(1)
	MaxNodeID     = NodeID(math.MaxUint64)
)

const MaxLogStreamID = LogStreamID(math.MaxInt32)

const MinLogStreamID = LogStreamID(1)

const MinStorageNodeID = StorageNodeID(1)

const MinTopicID = TopicID(1)

Variables

var GLSNLen = binary.Size(InvalidGLSN)

var LLSNLen = binary.Size(InvalidLLSN)

var VersionLen = binary.Size(InvalidVersion)

Types

type AtomicLLSN

type AtomicLLSN uint64

func (*AtomicLLSN) Add

func (llsn *AtomicLLSN) Add(delta uint64) LLSN

func (*AtomicLLSN) CompareAndSwap

func (llsn *AtomicLLSN) CompareAndSwap(old, new LLSN) (swapped bool)

func (*AtomicLLSN) Load

func (llsn *AtomicLLSN) Load() LLSN

func (*AtomicLLSN) Store

func (llsn *AtomicLLSN) Store(val LLSN)

type ClusterID

type ClusterID uint32

func NewClusterIDFromUint

func NewClusterIDFromUint(u uint) (ClusterID, error)

func ParseClusterID

func ParseClusterID(s string) (ClusterID, error)

func (ClusterID) String

func (cid ClusterID) String() string

type GLSN

type GLSN uint64

func (GLSN) Invalid

func (glsn GLSN) Invalid() bool

type LLSN

type LLSN uint64

func (LLSN) Invalid

func (llsn LLSN) Invalid() bool

type LogStreamID

type LogStreamID int32

func ParseLogStreamID

func ParseLogStreamID(s string) (LogStreamID, error)

func (LogStreamID) Invalid

func (lsid LogStreamID) Invalid() bool

func (LogStreamID) String

func (lsid LogStreamID) String() string

type NodeID

type NodeID uint64

func NewNodeID

func NewNodeID(addr string) NodeID

convert string(ip:port) to uint64 TODO:: LookupHost

func NewNodeIDFromURL

func NewNodeIDFromURL(rawurl string) NodeID

func (NodeID) Reverse

func (nid NodeID) Reverse() string

func (NodeID) String

func (nid NodeID) String() string

type StorageNodeID

type StorageNodeID int32

func ParseStorageNodeID

func ParseStorageNodeID(s string) (StorageNodeID, error)

func (StorageNodeID) Invalid

func (snid StorageNodeID) Invalid() bool

func (StorageNodeID) String

func (snid StorageNodeID) String() string

type TopicID

type TopicID int32

func ParseTopicID

func ParseTopicID(s string) (TopicID, error)

func (TopicID) Invalid

func (tpid TopicID) Invalid() bool

func (TopicID) String

func (tpid TopicID) String() string

type Version

type Version uint64

func (Version) Invalid

func (ver Version) Invalid() bool