README
¶
网络领域组件编程规范
1.领域上下文。
2.对外暴露接口。
3.驱动组件约束接口。
4.公共数据结构。
Documentation
¶
Index ¶
- func Drivers() []string
- func Register(name string, f NewP2PServFunc)
- type Network
- type NetworkImpl
- func (t *NetworkImpl) Context() *nctx.NetCtx
- func (t *NetworkImpl) NewSubscriber(typ pb.XuperMessage_MessageType, v interface{}, opts ...p2p.SubscriberOption) p2p.Subscriber
- func (t *NetworkImpl) PeerInfo() pb.PeerInfo
- func (t *NetworkImpl) Register(sub p2p.Subscriber) error
- func (t *NetworkImpl) SendMessage(ctx xctx.XContext, msg *pb.XuperMessage, opts ...p2p.OptionFunc) error
- func (t *NetworkImpl) SendMessageWithResponse(ctx xctx.XContext, msg *pb.XuperMessage, opts ...p2p.OptionFunc) ([]*pb.XuperMessage, error)
- func (t *NetworkImpl) Start()
- func (t *NetworkImpl) Stop()
- func (t *NetworkImpl) UnRegister(sub p2p.Subscriber) error
- type NewP2PServFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Drivers ¶
func Drivers() []string
Drivers returns a sorted list of the names of the registered drivers.
func Register ¶
func Register(name string, f NewP2PServFunc)
Register makes a driver available by the provided name. If Register is called twice with the same name or if driver is nil,it panics.
Types ¶
type Network ¶
type Network interface {
Start()
Stop()
SendMessage(xctx.XContext, *pb.XuperMessage, ...p2p.OptionFunc) error
SendMessageWithResponse(xctx.XContext, *pb.XuperMessage,
...p2p.OptionFunc) ([]*pb.XuperMessage, error)
NewSubscriber(pb.XuperMessage_MessageType, interface{}, ...p2p.SubscriberOption) p2p.Subscriber
Register(p2p.Subscriber) error
UnRegister(p2p.Subscriber) error
Context() *nctx.NetCtx
PeerInfo() pb.PeerInfo
}
network对外提供的接口
type NetworkImpl ¶
type NetworkImpl struct {
// contains filtered or unexported fields
}
如果有领域内公共逻辑，可以在这层扩展，对上层暴露高级接口 暂时没有特殊的逻辑，先简单透传，预留方便后续扩展
func (*NetworkImpl) Context ¶
func (t *NetworkImpl) Context() *nctx.NetCtx
func (*NetworkImpl) NewSubscriber ¶
func (t *NetworkImpl) NewSubscriber(typ pb.XuperMessage_MessageType, v interface{}, opts ...p2p.SubscriberOption) p2p.Subscriber
func (*NetworkImpl) PeerInfo ¶
func (t *NetworkImpl) PeerInfo() pb.PeerInfo
func (*NetworkImpl) Register ¶
func (t *NetworkImpl) Register(sub p2p.Subscriber) error
func (*NetworkImpl) SendMessage ¶
func (t *NetworkImpl) SendMessage(ctx xctx.XContext, msg *pb.XuperMessage, opts ...p2p.OptionFunc) error
func (*NetworkImpl) SendMessageWithResponse ¶
func (t *NetworkImpl) SendMessageWithResponse(ctx xctx.XContext, msg *pb.XuperMessage, opts ...p2p.OptionFunc) ([]*pb.XuperMessage, error)
func (*NetworkImpl) Start ¶
func (t *NetworkImpl) Start()
func (*NetworkImpl) Stop ¶
func (t *NetworkImpl) Stop()
func (*NetworkImpl) UnRegister ¶
func (t *NetworkImpl) UnRegister(sub p2p.Subscriber) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.