callback

package

v0.7.0 Latest Latest Go to latest Published: Apr 12, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rstefan1/bimodal-multicast

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddPeerCallback(data any, logger *slog.Logger) error
func RemovePeerCallback(data any, logger *slog.Logger) error
func ValidateCustomCallbacks(customCallbacks map[string]func(any, *slog.Logger) error) error
type PeerCallbackData
type Registry
- func NewRegistry(cb map[string]func(any, *slog.Logger) error) (*Registry, error)
- func (r *Registry) GetCallback(t string) func(any, *slog.Logger) error

Constants ¶

View Source

const (
	// 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"
)

View Source

const NOCALLBACK = "no-callback"

NOCALLBACK is the type of messages without callback.

Variables ¶

This section is empty.

Functions ¶

func AddPeerCallback ¶ added in v0.7.0

func AddPeerCallback(data any, logger *slog.Logger) error

AddPeerCallback is the callback for adding peers in peers buffer.

func RemovePeerCallback ¶ added in v0.7.0

func RemovePeerCallback(data any, logger *slog.Logger) error

RemovePeerCallback is the callback for removing peers from peers buffer.

func ValidateCustomCallbacks ¶ added in v0.5.0

func ValidateCustomCallbacks(customCallbacks map[string]func(any, *slog.Logger) error) error

ValidateCustomCallbacks validates custom callbacks. NOTE: must be called before adding internal callbacks.

Types ¶

type PeerCallbackData ¶ added in v0.7.0

type PeerCallbackData struct {
	Element buffer.Element
	Buffer  *peer.Buffer
}

PeerCallbackData contains data for add-peer & remove-peer callbacks.

type Registry ¶ added in v0.7.0

type Registry struct {
	Callbacks map[string]func(any, *slog.Logger) error
}

Registry is a registry for callbacks.

func NewRegistry ¶ added in v0.7.0

func NewRegistry(cb map[string]func(any, *slog.Logger) error) (*Registry, error)

NewRegistry creates a callback registry.

func (*Registry) GetCallback ¶ added in v0.7.0

func (r *Registry) GetCallback(t string) func(any, *slog.Logger) error

GetCallback returns a callback from registry.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL