handlers

Documentation

Overview

Package handlers contains common code used for message handling

Index

• func DebugContext(ctx gotocol.Context) gotocol.Context
• func Forget(dependencies *map[string]time.Time, router *ribbon.Router, msg gotocol.Message)
• func GetRequest(msg gotocol.Message, name string, listener chan gotocol.Message, ...)
• func GetResponse(msg gotocol.Message, name string, listener chan gotocol.Message, ...)
• func Inform(msg gotocol.Message, name string, listener chan gotocol.Message) chan gotocol.Message
• func NameDrop(dependencies *map[string]time.Time, router *ribbon.Router, msg gotocol.Message, ...)
• func Put(msg gotocol.Message, name string, listener chan gotocol.Message, ...)

Functions

func DebugContext

func DebugContext(ctx gotocol.Context) gotocol.Context

DebugContext turns on debug context logging for eureka and edda messages

func Forget

func Forget(dependencies *map[string]time.Time, router *ribbon.Router, msg gotocol.Message)

Forget removes a buddy from the buddy list

func GetRequest

func GetRequest(msg gotocol.Message, name string, listener chan gotocol.Message, requestor *map[string]gotocol.Routetype, router *ribbon.Router)

GetRequest sends a GetRequest message to a service

func GetResponse

func GetResponse(msg gotocol.Message, name string, listener chan gotocol.Message, requestor *map[string]gotocol.Routetype)

GetResponse provides generic response handling

func Inform

func Inform(msg gotocol.Message, name string, listener chan gotocol.Message) chan gotocol.Message

Inform default handler for Inform message

func NameDrop

func NameDrop(dependencies *map[string]time.Time, router *ribbon.Router, msg gotocol.Message, name string, listener chan gotocol.Message, eureka map[string]chan gotocol.Message, crosszone ...bool)

NameDrop updates local buddy list

func Put

func Put(msg gotocol.Message, name string, listener chan gotocol.Message, requestor *map[string]gotocol.Routetype, router *ribbon.Router)

Put sends a Put message to a service