utils

Documentation

Index

• Constants
• func CheckPredecessorCommand() string
• func ComputeId(input string) uint32
• func CreateRingCommand() string
• func Debug(log string, args ...string)
• func FindRingPredecessorCommand() string
• func FindRingSuccessorCommand(id uint32, replyTo string) string
• func FixRingFingersCommand() string
• func GetCommand(key string, replyTo string) string
• func GetRandomPort() int
• func InitRingFingersCommand() string
• func IsBetween(start uint32, end uint32, val uint32) bool
• func JoinRingCommand(sponsoringNode string) string
• func LeaveRingCommand(mode string) string
• func ListItemsCommand(replyTo string) string
• func NotifyOrderlyLeaveCommand(leaver uint32, pred *uint32, succ *uint32) string
• func ParseToUInt32(input string) (uint32, error)
• func PingCommand() string
• func Pop(msg []string) ([]string, []string, error)
• func PutCommand(key string, value string, replyTo string) string
• func RemoveCommand(key string, replyTo string) string
• func RingNotifyCommand(id uint32, replyTo string) string
• func SendMessage(msg string, address string) (string, error)
• func SetId(socket *zmq.Socket)
• func StabilizeRingCommand() string

Constants

const ERROR_MSG = "NORESPONSE"

const Localhost = "127.0.0.1"

const MaxPort = 47808

const MinPort = 1025

Inclusive

Functions

func CheckPredecessorCommand

func CheckPredecessorCommand() string

func ComputeId

func ComputeId(input string) uint32

func CreateRingCommand

func CreateRingCommand() string

func Debug

func Debug(log string, args ...string)

func FindRingPredecessorCommand

func FindRingPredecessorCommand() string

func FindRingSuccessorCommand

func FindRingSuccessorCommand(id uint32, replyTo string) string

{"do": "find-ring-successor", "id": id, "reply-to": address}

func FixRingFingersCommand

func FixRingFingersCommand() string

func GetCommand

func GetCommand(key string, replyTo string) string

func GetRandomPort

func GetRandomPort() int

func InitRingFingersCommand

func InitRingFingersCommand() string

func IsBetween

func IsBetween(start uint32, end uint32, val uint32) bool

func JoinRingCommand

func JoinRingCommand(sponsoringNode string) string

func LeaveRingCommand

func LeaveRingCommand(mode string) string

func ListItemsCommand

func ListItemsCommand(replyTo string) string

func NotifyOrderlyLeaveCommand

func NotifyOrderlyLeaveCommand(leaver uint32, pred *uint32, succ *uint32) string

func ParseToUInt32

func ParseToUInt32(input string) (uint32, error)

func PingCommand

func PingCommand() string

func Pop

func Pop(msg []string) ([]string, []string, error)

From: https://github.com/pebbe/zmq4/blob/master/examples/asyncsrv.go

func PutCommand

func PutCommand(key string, value string, replyTo string) string

func RemoveCommand

func RemoveCommand(key string, replyTo string) string

func RingNotifyCommand

func RingNotifyCommand(id uint32, replyTo string) string

func SendMessage

func SendMessage(msg string, address string) (string, error)

func SetId

func SetId(socket *zmq.Socket)

From: https://github.com/pebbe/zmq4/blob/master/examples/asyncsrv.go

func StabilizeRingCommand

func StabilizeRingCommand() string