identity

Documentation

Index

• Variables
• type IdentityService
  • func NewIdentityService(server networkingServer, logger hclog.Logger, chainID int64, hostID peer.ID) *IdentityService
  • func (i *IdentityService) GetNotifyBundle() *network.NotifyBundle
  • func (i *IdentityService) HasPendingStatus(id peer.ID) bool
  • func (i *IdentityService) Hello(_ context.Context, req *proto.Status) (*proto.Status, error)

Variables

var (
	ErrInvalidChainID   = errors.New("invalid chain ID")
	ErrNoAvailableSlots = errors.New("no available Slots")
	ErrSelfConnection   = errors.New("self connection")
)

Types

type IdentityService

type IdentityService struct {
	proto.UnimplementedIdentityServer
	// contains filtered or unexported fields
}

IdentityService is a networking service used to handle peer handshaking. It acts as a gatekeeper to peer connectivity

func NewIdentityService

func NewIdentityService(
	server networkingServer,
	logger hclog.Logger,
	chainID int64,
	hostID peer.ID,
) *IdentityService

NewIdentityService returns a new instance of the IdentityService

func (*IdentityService) GetNotifyBundle

func (i *IdentityService) GetNotifyBundle() *network.NotifyBundle

func (*IdentityService) HasPendingStatus

func (i *IdentityService) HasPendingStatus(id peer.ID) bool

HasPendingStatus checks if a peer is pending handshake [Thread safe]

func (*IdentityService) Hello

func (i *IdentityService) Hello(_ context.Context, req *proto.Status) (*proto.Status, error)

Hello is the initial message that bundles peer information on first contact