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
  • 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
  • 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

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

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.