p2p

Documentation

Index

• Constants
• type P2PConfig
• type P2PServer
  • func NewP2PServer(config *P2PConfig) (*P2PServer, error)
  • func (p *P2PServer) GetApproval(ctx context.Context, req *p2ptypes.GetApprovalRequest) (*p2ptypes.GetApprovalResponse, error)
  • func (p *P2PServer) Name() string
  • func (p *P2PServer) Start(ctx context.Context) error
  • func (p *P2PServer) Stop(ctx context.Context) error

Constants

const UpdateSPDuration = 2

Types

type P2PConfig

type P2PConfig struct {
	SpOperatorAddress string
	GRPCAddress       string
	SignerGrpcAddress string
	SpDBConfig        *config.SQLDBConfig
	P2PConfig         *p2p.NodeConfig
}

type P2PServer

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

P2PServer p2p service

func NewP2PServer

func NewP2PServer(config *P2PConfig) (*P2PServer, error)

NewP2PServer return an instance of P2PServer

func (*P2PServer) GetApproval

func (p *P2PServer) GetApproval(ctx context.Context, req *p2ptypes.GetApprovalRequest) (*p2ptypes.GetApprovalResponse, error)

GetApproval asks the approval to other SP.

func (*P2PServer) Name

func (p *P2PServer) Name() string

Name return the p2p server name, for the lifecycle management

func (*P2PServer) Start

func (p *P2PServer) Start(ctx context.Context) error

Start the p2p server background goroutine

func (*P2PServer) Stop

func (p *P2PServer) Stop(ctx context.Context) error

Stop the p2p server gRPC service and recycle the resources