callback

Documentation

Index

• Constants
• func ComposeAddPeerMessage(addr, port string) string
• func ComposeRemovePeerMessage(addr, port string) string
• func DecomposeAddPeerMessage(msg string) (string, string, error)
• func DecomposeRemovePeerMessage(msg string) (string, string, error)
• func ValidateCustomCallbacks(customCallbacks map[string]func(interface{}, *log.Logger) error) error
• type CustomRegistry
  • func NewCustomRegistry(cb map[string]func(interface{}, *log.Logger) error) (*CustomRegistry, error)
  • func (r *CustomRegistry) GetCallback(t string) (func(interface{}, *log.Logger) error, error)
  • func (r *CustomRegistry) RunCallbacks(m buffer.Element, logger *log.Logger) error
• type DefaultRegistry
  • func NewDefaultRegistry() (*DefaultRegistry, error)
  • func (r *DefaultRegistry) GetCallback(t string) (func(buffer.Element, *peer.Buffer, *log.Logger) error, error)
  • func (r *DefaultRegistry) RunCallbacks(m buffer.Element, peerBuf *peer.Buffer, logger *log.Logger) error

Constants

const (
	// NOCALLBACK is the type of messages without callback
	NOCALLBACK = "no-callback"

	// ADDPEER is the type of messages used for adding new peer in peers buffer
	ADDPEER = "add-peer"
	// REMOVEPEER is the type of messages used for deleting a peer from peers buffer
	REMOVEPEER = "remove-peer"
)

Functions

func ComposeAddPeerMessage

func ComposeAddPeerMessage(addr, port string) string

ComposeAddPeerMessage returns a `add peer` message with given addr and port

func ComposeRemovePeerMessage

func ComposeRemovePeerMessage(addr, port string) string

ComposeRemovePeerMessage returns a `remove peer` message with given addr and port

func DecomposeAddPeerMessage

func DecomposeAddPeerMessage(msg string) (string, string, error)

DecomposeAddPeerMessage decomposes given `add peer` message to addr and port

func DecomposeRemovePeerMessage

func DecomposeRemovePeerMessage(msg string) (string, string, error)

DecomposeRemovePeerMessage decomposes given `remove peer` message to addr and port

func ValidateCustomCallbacks

func ValidateCustomCallbacks(customCallbacks map[string]func(interface{}, *log.Logger) error) error

ValidateCustomCallbacks validates custom callbacks

Types

type CustomRegistry

type CustomRegistry struct {
	// contains filtered or unexported fields
}

CustomRegistry is a custom callbacks registry

func NewCustomRegistry

func NewCustomRegistry(cb map[string]func(interface{}, *log.Logger) error) (*CustomRegistry, error)

NewCustomRegistry creates a custom callback registry

func (*CustomRegistry) GetCallback

func (r *CustomRegistry) GetCallback(t string) (func(interface{}, *log.Logger) error, error)

GetCallback returns a custom callback from registry

func (*CustomRegistry) RunCallbacks

func (r *CustomRegistry) RunCallbacks(m buffer.Element, logger *log.Logger) error

RunCallbacks runs custom callbacks.

type DefaultRegistry

type DefaultRegistry struct {
	// contains filtered or unexported fields
}

DefaultRegistry is a default callbacks registry

func NewDefaultRegistry

func NewDefaultRegistry() (*DefaultRegistry, error)

NewDefaultRegistry creates a default callback registry

func (*DefaultRegistry) GetCallback

func (r *DefaultRegistry) GetCallback(t string) (func(buffer.Element, *peer.Buffer, *log.Logger) error, error)

GetCallback returns a default callback from registry

func (*DefaultRegistry) RunCallbacks

func (r *DefaultRegistry) RunCallbacks(m buffer.Element, peerBuf *peer.Buffer, logger *log.Logger) error

RunCallbacks runs default callbacks.