reign

package module

Go to main page

Versions in this module

v0

v0.9.2

Oct 12, 2018

Changes in this version

+ var ErrIllegalNilSlice = errors.New("cannot unmarshal nil slice into an address")

v0.9.1

Sep 21, 2018

Changes in this version

+ var DefaultPingInterval = time.Second * 30

+ var ErrFailOnClusterHandshake = errors.New("Failing on ssl handshake, as instructed")

+ var ErrMailboxClosed = errors.New("mailbox has been closed")

+ var MaxSequentialPingFailures uint8 = 5

type Address

+ func (a *Address) MarshalJSON() ([]byte, error)

+ func (a *Address) OnCloseNotify(addr *Address)

+ func (a *Address) RemoveNotify(addr *Address)

+ func (a *Address) UnmarshalJSON(b []byte) error

type Mailbox

+ func (m *Mailbox) Close()

+ func (m *Mailbox) MessageCount() int

+ func (m *Mailbox) ReceiveAsync() (interface{}, bool)

+ func (m *Mailbox) ReceiveMatch(matcher func(interface{}) bool) interface{}

+ func (m *Mailbox) ReceiveTimeout(timeout time.Duration) (interface{}, bool)

+ type MailboxClosed MailboxID

type Names

+ LookupAll func(string) []*Address

+ MessageCount func() int

+ MultipleClaimCount func() int32

type NamesDebugger

+ MessageCount func() int

+ MultipleClaimCount func() int32

v0.9.0

Dec 22, 2016

Changes in this version

+ var DeadlineInterval = time.Minute * 5

+ var ErrCantGloballyRegister = errors.New("can't globally register this address")

+ var ErrIllegalAddressFormat = errors.New("illegally-formatted address")

+ var ErrMailboxTerminated = errors.New("mailbox has been terminated")

+ var ErrNoAddressRegistered = errors.New("no address is registered with that name")

+ var ErrNotLocalMailbox = errors.New("function required a local mailbox ID but this is a remote MailboxID")

+ var NullLogger = nullLogger

+ var PingInterval = time.Second * 30

+ var StdLogger = stdLogger

+ func CreateFromReader(r io.Reader, thisNode NodeID, log ClusterLogger) (ConnectionService, Names, error)

+ func CreateFromSpec(spec *ClusterSpec, thisNode NodeID, log ClusterLogger) (cs ConnectionService, n Names, err error)

+ func CreateFromSpecFile(clusterSpecLocation string, thisNode NodeID, log ClusterLogger) (ConnectionService, Names, error)

+ func NoClustering() (ConnectionService, Names)

+ func RegisterType(value interface{})

+ type Address struct

+ func (a *Address) GetID() MailboxID

+ func (a *Address) MarshalBinary() ([]byte, error)

+ func (a *Address) MarshalText() ([]byte, error)

+ func (a *Address) NotifyAddressOnTerminate(addr *Address)

+ func (a *Address) RemoveNotifyAddress(addr *Address)

+ func (a *Address) Send(m interface{}) error

+ func (a *Address) String() string

+ func (a *Address) UnmarshalBinary(b []byte) error

+ func (a *Address) UnmarshalFromID(mID MailboxID)

+ func (a *Address) UnmarshalText(b []byte) error

+ type Cluster struct

+ Certificate tls.Certificate

+ ClusterCertificate *x509.Certificate

+ Nodes map[NodeID]*NodeDefinition

+ PermittedProtocols []uint16

+ RootCAs *x509.CertPool

+ ThisNode *NodeDefinition

+ func (c *Cluster) AddConnectionStatusCallback(f func(NodeID, bool))

+ type ClusterLogger interface

+ Error func(...interface{})

+ Errorf func(format string, args ...interface{})

+ Info func(...interface{})

+ Infof func(format string, args ...interface{})

+ Trace func(...interface{})

+ Tracef func(format string, args ...interface{})

+ Warn func(...interface{})

+ Warnf func(format string, args ...interface{})

+ func WrapLogger(l *log.Logger) ClusterLogger

+ type ClusterSpec struct

+ ClusterCertPEM string

+ ClusterCertPath string

+ NodeCertPEM string

+ NodeCertPath string

+ NodeKeyPEM string

+ NodeKeyPath string

+ Nodes []*NodeDefinition

+ PermittedProtocols []string

+ type ConnectionService interface

+ AddConnectionStatusCallback func(f func(NodeID, bool))

+ NewMailbox func() (*Address, *Mailbox)

+ Serve func()

+ Stop func()

+ Terminate func()

+ type Mailbox struct

+ func (m *Mailbox) Receive(matcher func(interface{}) bool) interface{}

+ func (m *Mailbox) ReceiveNext() interface{}

+ func (m *Mailbox) ReceiveNextAsync() (interface{}, bool)

+ func (m *Mailbox) ReceiveNextTimeout(timeout time.Duration) (interface{}, bool)

+ func (m *Mailbox) Terminate()

+ type MailboxID uint64

+ func (mID MailboxID) NodeID() NodeID

+ type MailboxTerminated MailboxID

+ type MultipleClaim struct

+ Claimants []Address

+ Name string

+ type Names interface

+ GetDebugger func() NamesDebugger

+ Lookup func(string) *Address

+ Register func(string, *Address) error

+ SeenNames func(...string) []bool

+ Serve func()

+ Stop func()

+ Sync func()

+ Unregister func(string, *Address)

+ type NamesDebugger interface

+ AddressCount func() uint

+ AllNames func() []string

+ DumpClaims func() map[string][]MailboxID

+ DumpJSON func() string

+ SeenNames func(...string) []bool

+ type NodeDefinition struct

+ Address string

+ ID NodeID

+ ListenAddress string

+ LocalAddress string

+ type NodeID byte

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