dist

Documentation

Index

• Constants
• func CreateHandshake(options HandshakeOptions) node.HandshakeInterface
• func CreateProto(options node.ProtoOptions) node.ProtoInterface
• func CreateRegistrar() node.Registrar
• func CreateRegistrarWithLocalEPMD(host string, port uint16) node.Registrar
• func CreateRegistrarWithRemoteEPMD(host string, port uint16) node.Registrar
• type DistHandshake
  • func (dh *DistHandshake) Accept(remote net.Addr, conn lib.NetReadWriter, tls bool, cookie string) (node.HandshakeDetails, error)
  • func (dh *DistHandshake) Init(nodename string, creation uint32, flags node.Flags) error
  • func (dh *DistHandshake) Start(remote net.Addr, conn lib.NetReadWriter, tls bool, cookie string) (node.HandshakeDetails, error)
  • func (dh *DistHandshake) Version() node.HandshakeVersion
• type HandshakeOptions

Constants

const (
	HandshakeVersion5 node.HandshakeVersion = 5
	HandshakeVersion6 node.HandshakeVersion = 6

	DefaultHandshakeVersion = HandshakeVersion5
	DefaultHandshakeTimeout = 5 * time.Second
)

const (
	DefaultEPMDPort uint16 = 4369
)

Functions

func CreateHandshake

func CreateHandshake(options HandshakeOptions) node.HandshakeInterface

func CreateProto

func CreateProto(options node.ProtoOptions) node.ProtoInterface

func CreateRegistrar

func CreateRegistrar() node.Registrar

func CreateRegistrarWithLocalEPMD

func CreateRegistrarWithLocalEPMD(host string, port uint16) node.Registrar

func CreateRegistrarWithRemoteEPMD

func CreateRegistrarWithRemoteEPMD(host string, port uint16) node.Registrar

Types

type DistHandshake

type DistHandshake struct {
	node.Handshake
	// contains filtered or unexported fields
}

DistHandshake implements Erlang handshake

func (*DistHandshake) Accept

func (dh *DistHandshake) Accept(remote net.Addr, conn lib.NetReadWriter, tls bool, cookie string) (node.HandshakeDetails, error)

func (*DistHandshake) Init

func (dh *DistHandshake) Init(nodename string, creation uint32, flags node.Flags) error

Init implements Handshake interface mothod

func (*DistHandshake) Start

func (dh *DistHandshake) Start(remote net.Addr, conn lib.NetReadWriter, tls bool, cookie string) (node.HandshakeDetails, error)

func (*DistHandshake) Version

func (dh *DistHandshake) Version() node.HandshakeVersion

type HandshakeOptions

type HandshakeOptions struct {
	Timeout time.Duration
	Version node.HandshakeVersion // 5 or 6
}