nodestats

Documentation

Index

• type Endpoint
  • func NewEndpoint(log *zap.Logger, overlay overlay.DB, reputation *reputation.Service, ...) *Endpoint
  • func (e *Endpoint) DailyStorageUsage(ctx context.Context, req *pb.DailyStorageUsageRequest) (_ *pb.DailyStorageUsageResponse, err error)
  • func (e *Endpoint) GetStats(ctx context.Context, req *pb.GetStatsRequest) (_ *pb.GetStatsResponse, err error)
  • func (e *Endpoint) PricingModel(ctx context.Context, req *pb.PricingModelRequest) (_ *pb.PricingModelResponse, err error)

Types

type Endpoint

type Endpoint struct {
	pb.DRPCNodeStatsUnimplementedServer
	// contains filtered or unexported fields
}

Endpoint for querying node stats for the SNO.

architecture: Endpoint

func NewEndpoint

func NewEndpoint(log *zap.Logger, overlay overlay.DB, reputation *reputation.Service, accounting accounting.StoragenodeAccounting, config paymentsconfig.Config) *Endpoint

NewEndpoint creates new endpoint.

func (*Endpoint) DailyStorageUsage

func (e *Endpoint) DailyStorageUsage(ctx context.Context, req *pb.DailyStorageUsageRequest) (_ *pb.DailyStorageUsageResponse, err error)

DailyStorageUsage returns slice of daily storage usage for given period of time sorted in ASC order by date.

func (*Endpoint) GetStats

func (e *Endpoint) GetStats(ctx context.Context, req *pb.GetStatsRequest) (_ *pb.GetStatsResponse, err error)

GetStats sends node stats for client node.

func (*Endpoint) PricingModel

func (e *Endpoint) PricingModel(ctx context.Context, req *pb.PricingModelRequest) (_ *pb.PricingModelResponse, err error)

PricingModel returns pricing model for storagenode.