multicast

package
v1.3.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 25, 2022 License: BSD-3-Clause Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ConvertGIDs added in v1.3.6 

func ConvertGIDs(GIDs [][]byte) []boson.Address

func ConvertHashToGID 

func ConvertHashToGID(h common.Hash) boson.Address

func GenerateGID 

func GenerateGID(name string) boson.Address

func RandomPeer 

func RandomPeer(peers []boson.Address) boson.Address

func RandomPeersLimit 

func RandomPeersLimit(peers []boson.Address, limit int) []boson.Address

Types

type Group 

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

type GroupInterface 

type GroupInterface interface {
	Multicast(info *pb.MulticastMsg, skip ...boson.Address) error
	AddGroup(groups []model.ConfigNodeGroup) error
	RemoveGroup(gid boson.Address, gType model.GType) error
	Snapshot() *model.KadParams
	StartDiscover()
	SubscribeLogContent(n *rpc.Notifier, sub *rpc.Subscription)
	SubscribeMulticastMsg(n *rpc.Notifier, sub *rpc.Subscription, gid boson.Address) (err error)
	GetGroupPeers(groupName string) (out *GroupPeers, err error)
	GetOptimumPeer(groupName string) (peer boson.Address, err error)
	GetSendStream(ctx context.Context, gid, dest boson.Address) (out SendStreamCh, err error)
	SendReceive(ctx context.Context, data []byte, gid, dest boson.Address) (result []byte, err error)
	Send(ctx context.Context, data []byte, gid, dest boson.Address) (err error)
}

type GroupMessage added in v1.3.0 

type GroupMessage struct {
	SessionID rpc.ID        `json:"sessionID,omitempty"`
	GID       boson.Address `json:"gid"`
	Data      []byte        `json:"data"`
	From      boson.Address `json:"from"`
}

type GroupPeers added in v1.3.0 

type GroupPeers struct {
	Connected []boson.Address `json:"connected"`
	Keep      []boson.Address `json:"keep"`
}

type LogContent 

type LogContent struct {
	Event string
	Time  int64 // ms
	Data  Message
}

type Message 

type Message struct {
	ID         uint64
	CreateTime int64
	GID        boson.Address
	Origin     boson.Address
	Data       []byte
	From       boson.Address
}

Message multicast message

type NotifyStatus 

type NotifyStatus int
const (
	NotifyJoinGroup NotifyStatus = iota + 1
	NotifyLeaveGroup
)

type Option 

type Option struct {
	Dev bool
}

type PeersSubClient added in v1.3.0 

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

type SendOption added in v1.3.0 

type SendOption int
const (
	SendOnly SendOption = iota
	SendReceive
	SendStream
)

func (SendOption) String added in v1.3.2 

func (s SendOption) String() string

type SendStreamCh added in v1.3.0 

type SendStreamCh struct {
	Read     chan []byte
	ReadErr  chan error
	Write    chan []byte
	WriteErr chan error
	Close    chan struct{}
}

type Service 

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

func NewService 

func NewService(self boson.Address, nodeMode aurora.Model, service p2p.Service, streamer p2p.Streamer, kad topology.Driver, route routetab.RouteTab, logger logging.Logger, subPub subscribe.SubPub, o Option) *Service

func (*Service) API 

func (s *Service) API() rpc.API

func (*Service) AddGroup added in v1.3.0 

func (s *Service) AddGroup(groups []model.ConfigNodeGroup) error

func (*Service) Close 

func (s *Service) Close() error

func (*Service) GetGroupPeers added in v1.3.0 

func (s *Service) GetGroupPeers(groupName string) (out *GroupPeers, err error)

GetGroupPeers the peers order by EWMA optimal

func (*Service) GetOptimumPeer added in v1.3.2 

func (s *Service) GetOptimumPeer(groupName string) (peer boson.Address, err error)

func (*Service) GetSendStream added in v1.3.0 

func (s *Service) GetSendStream(ctx context.Context, gid, dest boson.Address) (out SendStreamCh, err error)

func (*Service) Handshake 

func (s *Service) Handshake(ctx context.Context, addr boson.Address) (err error)

func (*Service) HandshakeAll added in v1.3.6 

func (s *Service) HandshakeAll()

func (*Service) HandshakeAllKept added in v1.3.6 

func (s *Service) HandshakeAllKept(gs []*Group, connected bool)

func (*Service) HandshakeAllPeers added in v1.3.6 

func (s *Service) HandshakeAllPeers(ps *pslice.PSlice)

func (*Service) HandshakeIncoming 

func (s *Service) HandshakeIncoming(ctx context.Context, peer p2p.Peer, stream p2p.Stream) (err error)

func (*Service) Multicast 

func (s *Service) Multicast(info *pb.MulticastMsg, skip ...boson.Address) error

func (*Service) Protocol 

func (s *Service) Protocol() p2p.ProtocolSpec

func (*Service) RemoveGroup added in v1.3.0 

func (s *Service) RemoveGroup(gid boson.Address, gType model.GType) error

func (*Service) Send added in v1.3.0 

func (s *Service) Send(ctx context.Context, data []byte, gid, dest boson.Address) (err error)

func (*Service) SendReceive added in v1.3.0 

func (s *Service) SendReceive(ctx context.Context, data []byte, gid, dest boson.Address) (result []byte, err error)

func (*Service) Snapshot 

func (s *Service) Snapshot() *model.KadParams

func (*Service) Start 

func (s *Service) Start()

func (*Service) StartDiscover 

func (s *Service) StartDiscover()

func (*Service) SubscribeGroupMessage added in v1.3.0 

func (s *Service) SubscribeGroupMessage(n *rpc.Notifier, sub *rpc.Subscription, gid boson.Address) (err error)

func (*Service) SubscribeLogContent 

func (s *Service) SubscribeLogContent(n *rpc.Notifier, sub *rpc.Subscription)

func (*Service) SubscribeMulticastMsg 

func (s *Service) SubscribeMulticastMsg(n *rpc.Notifier, sub *rpc.Subscription, gid boson.Address) (err error)

type WsStream added in v1.3.0 

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

Source Files

View all Source files

Directories

Path Synopsis
Package pb holds only Protocol Buffer definitions and generated code.
 Package pb holds only Protocol Buffer definitions and generated code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.