lightpeer

Documentation

Index

• Constants
• func InitOtel(otlpBackend, serviceName string) func() error
• type LightNetwork
• type Lightpeer
  • func (lp *Lightpeer) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (lp *Lightpeer) ConnectNewPeer(cReq *pb.ConnectRequest, stream pb.Lightpeer_ConnectNewPeerServer) error
  • func (lp *Lightpeer) GetState() pb.Lightblock
  • func (lp *Lightpeer) JoinNetwork(ctx context.Context, joinReq *pb.JoinRequest) (*pb.JoinResponse, error)
  • func (lp *Lightpeer) NotifyNewBlock(ctx context.Context, newBlock *pb.Lightblock) (*pb.NewBlockResponse, error)
  • func (lp *Lightpeer) Persist(ctx context.Context, tReq *pb.PersistRequest) (*pb.PersistResponse, error)
  • func (lp *Lightpeer) Query(qReq *pb.EmptyQueryRequest, stream pb.Lightpeer_QueryServer) error
• type NetworkHealthChecker
  • func (nhc *NetworkHealthChecker) StartPeerHealthCheck()
  • func (nhc *NetworkHealthChecker) StopPeerHealthCheck()

Constants

const (
	ServiceName = "lightchain"
	OTLPAddress = "localhost:30080"
)

Functions

func InitOtel

func InitOtel(otlpBackend, serviceName string) func() error

Types

type LightNetwork

type LightNetwork struct {
	Peers []pb.PeerInfo `json:peers`
}

type Lightpeer

type Lightpeer struct {
	pb.LightpeerServer
	health.Server
	Tracer      trace.Tracer
	StoragePath string
	Network     []pb.PeerInfo
	Meta        pb.PeerInfo
	// contains filtered or unexported fields
}

func (*Lightpeer) Check

func (lp *Lightpeer) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

Check implements `service Health`.

func (*Lightpeer) ConnectNewPeer

func (lp *Lightpeer) ConnectNewPeer(cReq *pb.ConnectRequest, stream pb.Lightpeer_ConnectNewPeerServer) error

Connect accepts connection from other peers.

func (*Lightpeer) GetState

func (lp *Lightpeer) GetState() pb.Lightblock

GetState returns the current peer state

func (*Lightpeer) JoinNetwork

func (lp *Lightpeer) JoinNetwork(ctx context.Context, joinReq *pb.JoinRequest) (*pb.JoinResponse, error)

JoinNetwork makes a ConnectNewPeer request on the address given, and updates the internal peer state to match the newly joined netwrok.

func (*Lightpeer) NotifyNewBlock

func (lp *Lightpeer) NotifyNewBlock(ctx context.Context, newBlock *pb.Lightblock) (*pb.NewBlockResponse, error)

func (*Lightpeer) Persist

func (lp *Lightpeer) Persist(ctx context.Context, tReq *pb.PersistRequest) (*pb.PersistResponse, error)

Persist creates a new state on the chain, and notifies the network about the new state

func (*Lightpeer) Query

func (lp *Lightpeer) Query(qReq *pb.EmptyQueryRequest, stream pb.Lightpeer_QueryServer) error

type NetworkHealthChecker

type NetworkHealthChecker struct {
	Lp *Lightpeer
	// contains filtered or unexported fields
}

func (*NetworkHealthChecker) StartPeerHealthCheck

func (nhc *NetworkHealthChecker) StartPeerHealthCheck()

func (*NetworkHealthChecker) StopPeerHealthCheck

func (nhc *NetworkHealthChecker) StopPeerHealthCheck()