network

README

网络领域组件编程规范

1.领域上下文。

2.对外暴露接口。

3.驱动组件约束接口。

4.公共数据结构。

Documentation

Index

• func Drivers() []string
• func Register(name string, f NewP2PServFunc)
• type Network
  • func NewNetwork(ctx *nctx.NetCtx) (Network, error)
• 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

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对外提供的接口

func NewNetwork

func NewNetwork(ctx *nctx.NetCtx) (Network, error)

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

type NewP2PServFunc

type NewP2PServFunc func() p2p.Server

创建P2PServer实例方法