router

Documentation

Index

• Variables
• type RouteMethod
• type Router
  • func NewRouter(config *repo.Config, privateKey crypto.PrivateKey, logger logrus.FieldLogger, ...) Router

Variables

var (
	Single    = "single"
	Multicast = "multicast"
	Broadcast = "broadcast"
	Official  = "official"
	Random    = "random"
)

Types

type RouteMethod

type RouteMethod interface {
	Single([]string) []port.Port
	Multicast([]string) []port.Port
	Broadcast([]string) []port.Port
	Official([]string) []port.Port
	Random([]string) []port.Port
}

type Router

type Router interface {
	internal.Launcher

	Add(p port.Port)

	Adds(p []port.Port)

	Route(ibtp *pb.Message) error

	Load(key string) (value port.Port, ok bool)

	Send(id string, msg *pb.Message) (*pb.Message, error)

	AsyncSend(id string, msg *pb.Message) error
}

func NewRouter

func NewRouter(config *repo.Config, privateKey crypto.PrivateKey, logger logrus.FieldLogger, checker checker.Checker) Router