Versions in this module Expand all Collapse all v1 v1.3.3 Nov 16, 2019 Changes in this version + const ConcurrentHealthCheckCount + const MsgSendDelay + const PeerHealthcheckInterval + const PolarisPingTTL + const PolarisSvc + const ResponseMaxPeerLimit + var EmptyMsgID = p2pcommon.MsgID(uuid.Nil) + var FarawayFuture = time.Date(99999, 1, 1, 0, 0, 0, 0, time.UTC) + var NotFoundError = errors.New("ban status not found") + var NotSupportError = fmt.Errorf("not supported cmd") + var UndefinedTime = time.Unix(0, 0) + func NewHCM(mapService *PeerMapService, nt p2pcommon.NetworkTransport) *healthCheckManager + func NewPolarisListManager(conf *config.PolarisConfig, authDir string, logger *log.Logger) *polarisListManager + type BlackListMsg PaginationMsg + type CurrentListMsg PaginationMsg + type HealthCheckManager interface + Start func() + Stop func() + type ListEntriesMarshaller struct + func (m ListEntriesMarshaller) MarshalZerologArray(a *zerolog.Array) + type ListEntriesMsg struct + type LiteContainerService struct + func NewNTContainer(cfg *config.Config) *LiteContainerService + func (lntc *LiteContainerService) AfterStart() + func (lntc *LiteContainerService) BeforeStart() + func (lntc *LiteContainerService) BeforeStop() + func (lntc *LiteContainerService) CallRequest(actor string, msg interface{}, timeout time.Duration) (interface{}, error) + func (lntc *LiteContainerService) CallRequestDefaultTimeout(actor string, msg interface{}) (interface{}, error) + func (lntc *LiteContainerService) CertificateManager() p2pcommon.CertificateManager + func (lntc *LiteContainerService) FutureRequest(actor string, msg interface{}, timeout time.Duration) *actor.Future + func (lntc *LiteContainerService) FutureRequestDefaultTimeout(actor string, msg interface{}) *actor.Future + func (lntc *LiteContainerService) GenesisChainID() *types.ChainID + func (lntc *LiteContainerService) GetChainAccessor() types.ChainAccessor + func (lntc *LiteContainerService) GetNetworkTransport() p2pcommon.NetworkTransport + func (lntc *LiteContainerService) LocalSettings() p2pcommon.LocalSettings + func (lntc *LiteContainerService) Receive(context actor.Context) + func (lntc *LiteContainerService) RoleManager() p2pcommon.PeerRoleManager + func (lntc *LiteContainerService) SelfMeta() p2pcommon.PeerMeta + func (lntc *LiteContainerService) SelfNodeID() types.PeerID + func (lntc *LiteContainerService) SelfRole() types.PeerRole + func (lntc *LiteContainerService) SendRequest(actor string, msg interface{}) + func (lntc *LiteContainerService) SetHub(hub *component.ComponentHub) + func (lntc *LiteContainerService) Statistics() *map[string]interface{} + func (lntc *LiteContainerService) TellRequest(actor string, msg interface{}) + type PRPCServer struct + func (rs *PRPCServer) AddBLEntry(ctx context.Context, entInfo *types.AddEntryParams) (*types.SingleString, error) + func (rs *PRPCServer) BlackList(ctx context.Context, p1 *types.Paginations) (*types.PolarisPeerList, error) + func (rs *PRPCServer) CurrentList(ctx context.Context, p1 *types.Paginations) (*types.PolarisPeerList, error) + func (rs *PRPCServer) ListBLEntries(ctx context.Context, entInfo *types.Empty) (*types.BLConfEntries, error) + func (rs *PRPCServer) Metric(ctx context.Context, in *types.MetricsRequest) (*types.Metrics, error) + func (rs *PRPCServer) NodeState(ctx context.Context, in *types.NodeReq) (*types.SingleBytes, error) + func (rs *PRPCServer) RemoveBLEntry(ctx context.Context, msg *types.RmEntryParams) (*types.SingleString, error) + func (rs *PRPCServer) WhiteList(ctx context.Context, p1 *types.Paginations) (*types.PolarisPeerList, error) + type PaginationMsg struct + ReferenceHash []byte + Size uint32 + type PeerHealth int + const PeerHealth_BAD + const PeerHealth_GOOD + const PeerHealth_MID + type PeerMapService struct + PrivateNet bool + func NewPolarisService(cfg *config.Config, ntc p2pcommon.NTContainer) *PeerMapService + func (pms *PeerMapService) AfterStart() + func (pms *PeerMapService) BeforeStart() + func (pms *PeerMapService) BeforeStop() + func (pms *PeerMapService) Receive(context actor.Context) + func (pms *PeerMapService) SendGoAwayMsg(message string, wt p2pcommon.MsgReadWriter) error + func (pms *PeerMapService) SetHub(hub *component.ComponentHub) + func (pms *PeerMapService) Statistics() *map[string]interface{} + type PolarisRPC struct + func NewPolarisRPC(cfg *config.Config) *PolarisRPC + func (rpc *PolarisRPC) AfterStart() + func (rpc *PolarisRPC) BeforeStart() + func (rpc *PolarisRPC) BeforeStop() + func (rpc *PolarisRPC) CallRequest(actor string, msg interface{}, timeout time.Duration) (interface{}, error) + func (rpc *PolarisRPC) CallRequestDefaultTimeout(actor string, msg interface{}) (interface{}, error) + func (rpc *PolarisRPC) FutureRequest(actor string, msg interface{}, timeout time.Duration) *actor.Future + func (rpc *PolarisRPC) FutureRequestDefaultTimeout(actor string, msg interface{}) *actor.Future + func (rpc *PolarisRPC) GetChainAccessor() types.ChainAccessor + func (rpc *PolarisRPC) Receive(context actor.Context) + func (rpc *PolarisRPC) SendRequest(actor string, msg interface{}) + func (rpc *PolarisRPC) SetHub(hub *component.ComponentHub) + func (rpc *PolarisRPC) Statistics() *map[string]interface{} + func (rpc *PolarisRPC) TellRequest(actor string, msg interface{}) + type WhiteListMsg PaginationMsg
Go to main page