multinode

package
v1.96.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2024 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BandwidthEndpoint 

type BandwidthEndpoint struct {
	multinodepb.DRPCBandwidthUnimplementedServer
	// contains filtered or unexported fields
}

BandwidthEndpoint implements multinode bandwidth endpoint.

architecture: Endpoint

func NewBandwidthEndpoint 

func NewBandwidthEndpoint(log *zap.Logger, apiKeys *apikeys.Service, db bandwidth.DB) *BandwidthEndpoint

NewBandwidthEndpoint creates new multinode bandwidth endpoint.

func (*BandwidthEndpoint) BandwidthSummary added in v1.33.1 

func (bandwidth *BandwidthEndpoint) BandwidthSummary(ctx context.Context, req *multinodepb.BandwidthSummaryRequest) (_ *multinodepb.BandwidthSummaryResponse, err error)

BandwidthSummary returns bandwidth summary.

func (*BandwidthEndpoint) BandwidthSummarySatellite added in v1.33.1 

func (bandwidth *BandwidthEndpoint) BandwidthSummarySatellite(ctx context.Context, req *multinodepb.BandwidthSummarySatelliteRequest) (_ *multinodepb.BandwidthSummarySatelliteResponse, err error)

BandwidthSummarySatellite returns bandwidth summary for specific satellite.

func (*BandwidthEndpoint) Daily added in v1.33.1 

func (bandwidth *BandwidthEndpoint) Daily(ctx context.Context, req *multinodepb.DailyRequest) (_ *multinodepb.DailyResponse, err error)

Daily returns bandwidth summary split by days current month.

func (*BandwidthEndpoint) DailySatellite added in v1.33.1 

func (bandwidth *BandwidthEndpoint) DailySatellite(ctx context.Context, req *multinodepb.DailySatelliteRequest) (_ *multinodepb.DailySatelliteResponse, err error)

DailySatellite returns bandwidth summary split by days current month for specific satellite.

func (*BandwidthEndpoint) EgressSummary added in v1.33.1 

func (bandwidth *BandwidthEndpoint) EgressSummary(ctx context.Context, req *multinodepb.EgressSummaryRequest) (_ *multinodepb.EgressSummaryResponse, err error)

EgressSummary returns egress summary.

func (*BandwidthEndpoint) EgressSummarySatellite added in v1.33.1 

func (bandwidth *BandwidthEndpoint) EgressSummarySatellite(ctx context.Context, req *multinodepb.EgressSummarySatelliteRequest) (_ *multinodepb.EgressSummarySatelliteResponse, err error)

EgressSummarySatellite returns egress summary for specific satellite.

func (*BandwidthEndpoint) IngressSummary added in v1.33.1 

func (bandwidth *BandwidthEndpoint) IngressSummary(ctx context.Context, req *multinodepb.IngressSummaryRequest) (_ *multinodepb.IngressSummaryResponse, err error)

IngressSummary returns ingress summary.

func (*BandwidthEndpoint) IngressSummarySatellite added in v1.33.1 

func (bandwidth *BandwidthEndpoint) IngressSummarySatellite(ctx context.Context, req *multinodepb.IngressSummarySatelliteRequest) (_ *multinodepb.IngressSummarySatelliteResponse, err error)

IngressSummarySatellite returns ingress summary for specific satellite.

func (*BandwidthEndpoint) MonthSummary 

func (bandwidth *BandwidthEndpoint) MonthSummary(ctx context.Context, req *multinodepb.BandwidthMonthSummaryRequest) (_ *multinodepb.BandwidthMonthSummaryResponse, err error)

MonthSummary returns bandwidth used current month.

type NodeEndpoint 

type NodeEndpoint struct {
	multinodepb.DRPCNodeUnimplementedServer
	// contains filtered or unexported fields
}

NodeEndpoint implements multinode node endpoint.

architecture: Endpoint

func NewNodeEndpoint 

func NewNodeEndpoint(log *zap.Logger, config operator.Config, apiKeys *apikeys.Service, version version.Info, contact *contact.PingStats, reputation reputation.DB, trust *trust.Pool) *NodeEndpoint

NewNodeEndpoint creates new multinode node endpoint.

func (*NodeEndpoint) LastContact 

func (node *NodeEndpoint) LastContact(ctx context.Context, req *multinodepb.LastContactRequest) (_ *multinodepb.LastContactResponse, err error)

LastContact returns timestamp when node was last in contact with satellite.

func (*NodeEndpoint) Operator added in v1.32.1 

func (node *NodeEndpoint) Operator(ctx context.Context, req *multinodepb.OperatorRequest) (_ *multinodepb.OperatorResponse, err error)

Operator returns operators data.

func (*NodeEndpoint) Reputation 

func (node *NodeEndpoint) Reputation(ctx context.Context, req *multinodepb.ReputationRequest) (_ *multinodepb.ReputationResponse, err error)

Reputation returns reputation for specific satellite.

func (*NodeEndpoint) TrustedSatellites added in v1.21.1 

func (node *NodeEndpoint) TrustedSatellites(ctx context.Context, req *multinodepb.TrustedSatellitesRequest) (_ *multinodepb.TrustedSatellitesResponse, err error)

TrustedSatellites returns list of trusted satellites node urls.

func (*NodeEndpoint) Version 

func (node *NodeEndpoint) Version(ctx context.Context, req *multinodepb.VersionRequest) (_ *multinodepb.VersionResponse, err error)

Version returns node current version.

type PayoutEndpoint added in v1.21.1 

type PayoutEndpoint struct {
	multinodepb.DRPCPayoutUnimplementedServer
	multinodepb.DRPCPayoutsUnimplementedServer
	// contains filtered or unexported fields
}

PayoutEndpoint implements multinode payouts endpoint.

architecture: Endpoint

func NewPayoutEndpoint added in v1.21.1 

func NewPayoutEndpoint(log *zap.Logger, apiKeys *apikeys.Service, db payouts.DB, estimatedPayouts *estimatedpayouts.Service, service *payouts.Service) *PayoutEndpoint

NewPayoutEndpoint creates new multinode payouts endpoint.

func (*PayoutEndpoint) AllSatellitesPeriodSummary added in v1.30.1 

func (payout *PayoutEndpoint) AllSatellitesPeriodSummary(ctx context.Context, req *multinodepb.AllSatellitesPeriodSummaryRequest) (_ *multinodepb.AllSatellitesPeriodSummaryResponse, err error)

AllSatellitesPeriodSummary returns all satellites period payout summary.

func (*PayoutEndpoint) AllSatellitesSummary added in v1.30.1 

func (payout *PayoutEndpoint) AllSatellitesSummary(ctx context.Context, req *multinodepb.AllSatellitesSummaryRequest) (_ *multinodepb.AllSatellitesSummaryResponse, err error)

AllSatellitesSummary returns all satellites all time payout summary.

func (*PayoutEndpoint) Earned added in v1.21.1 

func (payout *PayoutEndpoint) Earned(ctx context.Context, req *multinodepb.EarnedRequest) (_ *multinodepb.EarnedResponse, err error)

Earned returns total earned amount.

func (*PayoutEndpoint) EarnedPerSatellite added in v1.24.2 

func (payout *PayoutEndpoint) EarnedPerSatellite(ctx context.Context, req *multinodepb.EarnedPerSatelliteRequest) (_ *multinodepb.EarnedPerSatelliteResponse, err error)

EarnedPerSatellite returns total earned amount per satellite.

func (*PayoutEndpoint) EarnedSatellite added in v1.32.1 

func (payout *PayoutEndpoint) EarnedSatellite(ctx context.Context, req *multinodepb.EarnedSatelliteRequest) (_ *multinodepb.EarnedSatelliteResponse, err error)

EarnedSatellite returns total earned amount per satellite.

func (*PayoutEndpoint) EstimatedPayout added in v1.32.1 

func (payout *PayoutEndpoint) EstimatedPayout(ctx context.Context, req *multinodepb.EstimatedPayoutRequest) (_ *multinodepb.EstimatedPayoutResponse, err error)

EstimatedPayout returns estimated earnings for current month from all satellites.

func (*PayoutEndpoint) EstimatedPayoutSatellite added in v1.30.1 

func (payout *PayoutEndpoint) EstimatedPayoutSatellite(ctx context.Context, req *multinodepb.EstimatedPayoutSatelliteRequest) (_ *multinodepb.EstimatedPayoutSatelliteResponse, err error)

EstimatedPayoutSatellite returns estimated earnings for current month from specific satellite.

func (*PayoutEndpoint) EstimatedPayoutTotal added in v1.30.1 

func (payout *PayoutEndpoint) EstimatedPayoutTotal(ctx context.Context, req *multinodepb.EstimatedPayoutTotalRequest) (_ *multinodepb.EstimatedPayoutTotalResponse, err error)

EstimatedPayoutTotal returns estimated earnings for current month from all satellites.

func (*PayoutEndpoint) HeldAmountHistory added in v1.32.1 

func (payout *PayoutEndpoint) HeldAmountHistory(ctx context.Context, req *multinodepb.HeldAmountHistoryRequest) (_ *multinodepb.HeldAmountHistoryResponse, err error)

HeldAmountHistory returns held amount history for all satellites.

func (*PayoutEndpoint) Paystub added in v1.31.1 

func (payout *PayoutEndpoint) Paystub(ctx context.Context, req *multinodepb.PaystubRequest) (_ *multinodepb.PaystubResponse, err error)

Paystub returns summed amounts of all values from paystubs from all satellites.

func (*PayoutEndpoint) PaystubPeriod added in v1.32.1 

func (payout *PayoutEndpoint) PaystubPeriod(ctx context.Context, req *multinodepb.PaystubPeriodRequest) (_ *multinodepb.PaystubPeriodResponse, err error)

PaystubPeriod returns summed amounts of all values from paystubs from all satellites for specific period.

func (*PayoutEndpoint) PaystubSatellite added in v1.32.1 

func (payout *PayoutEndpoint) PaystubSatellite(ctx context.Context, req *multinodepb.PaystubSatelliteRequest) (_ *multinodepb.PaystubSatelliteResponse, err error)

PaystubSatellite returns summed amounts of all values from paystubs from all satellites.

func (*PayoutEndpoint) PaystubSatellitePeriod added in v1.33.1 

func (payout *PayoutEndpoint) PaystubSatellitePeriod(ctx context.Context, req *multinodepb.PaystubSatellitePeriodRequest) (_ *multinodepb.PaystubSatellitePeriodResponse, err error)

PaystubSatellitePeriod returns summed amounts of all values from paystubs from all satellites for specific period.

func (*PayoutEndpoint) PeriodPaystub added in v1.31.1 

func (payout *PayoutEndpoint) PeriodPaystub(ctx context.Context, req *multinodepb.PeriodPaystubRequest) (_ *multinodepb.PeriodPaystubResponse, err error)

PeriodPaystub returns summed amounts of all values from paystubs from all satellites for specific period.

func (*PayoutEndpoint) SatellitePaystub added in v1.31.1 

func (payout *PayoutEndpoint) SatellitePaystub(ctx context.Context, req *multinodepb.SatellitePaystubRequest) (_ *multinodepb.SatellitePaystubResponse, err error)

SatellitePaystub returns summed amounts of all values from paystubs from all satellites.

func (*PayoutEndpoint) SatellitePeriodPaystub added in v1.31.1 

func (payout *PayoutEndpoint) SatellitePeriodPaystub(ctx context.Context, req *multinodepb.SatellitePeriodPaystubRequest) (_ *multinodepb.SatellitePeriodPaystubResponse, err error)

SatellitePeriodPaystub returns summed amounts of all values from paystubs from all satellites for specific period.

func (*PayoutEndpoint) SatellitePeriodSummary added in v1.31.1 

func (payout *PayoutEndpoint) SatellitePeriodSummary(ctx context.Context, req *multinodepb.SatellitePeriodSummaryRequest) (_ *multinodepb.SatellitePeriodSummaryResponse, err error)

SatellitePeriodSummary returns satellite period payout summary.

func (*PayoutEndpoint) SatelliteSummary added in v1.31.1 

func (payout *PayoutEndpoint) SatelliteSummary(ctx context.Context, req *multinodepb.SatelliteSummaryRequest) (_ *multinodepb.SatelliteSummaryResponse, err error)

SatelliteSummary returns satellite all time payout summary.

func (*PayoutEndpoint) Summary added in v1.32.1 

func (payout *PayoutEndpoint) Summary(ctx context.Context, req *multinodepb.SummaryRequest) (_ *multinodepb.SummaryResponse, err error)

Summary returns all satellites all time payout summary.

func (*PayoutEndpoint) SummaryPeriod added in v1.32.1 

func (payout *PayoutEndpoint) SummaryPeriod(ctx context.Context, req *multinodepb.SummaryPeriodRequest) (_ *multinodepb.SummaryPeriodResponse, err error)

SummaryPeriod returns all satellites period payout summary.

func (*PayoutEndpoint) SummarySatellite added in v1.32.1 

func (payout *PayoutEndpoint) SummarySatellite(ctx context.Context, req *multinodepb.SummarySatelliteRequest) (_ *multinodepb.SummarySatelliteResponse, err error)

SummarySatellite returns satellite all time payout summary.

func (*PayoutEndpoint) SummarySatellitePeriod added in v1.32.1 

func (payout *PayoutEndpoint) SummarySatellitePeriod(ctx context.Context, req *multinodepb.SummarySatellitePeriodRequest) (_ *multinodepb.SummarySatellitePeriodResponse, err error)

SummarySatellitePeriod returns satellite period payout summary.

func (*PayoutEndpoint) Undistributed added in v1.31.1 

func (payout *PayoutEndpoint) Undistributed(ctx context.Context, req *multinodepb.UndistributedRequest) (_ *multinodepb.UndistributedResponse, err error)

Undistributed returns total undistributed amount.

type StorageEndpoint 

type StorageEndpoint struct {
	multinodepb.DRPCStorageUnimplementedServer
	// contains filtered or unexported fields
}

StorageEndpoint implements multinode storage endpoint.

architecture: Endpoint

func NewStorageEndpoint 

func NewStorageEndpoint(log *zap.Logger, apiKeys *apikeys.Service, monitor *monitor.Service, usage storageusage.DB) *StorageEndpoint

NewStorageEndpoint creates new multinode storage endpoint.

func (*StorageEndpoint) DiskSpace 

func (storage *StorageEndpoint) DiskSpace(ctx context.Context, req *multinodepb.DiskSpaceRequest) (_ *multinodepb.DiskSpaceResponse, err error)

DiskSpace returns disk space state.

func (*StorageEndpoint) Usage added in v1.33.1 

func (storage *StorageEndpoint) Usage(ctx context.Context, req *multinodepb.StorageUsageRequest) (_ *multinodepb.StorageUsageResponse, err error)

Usage returns daily storage usage for a given interval.

func (*StorageEndpoint) UsageSatellite added in v1.33.1 

func (storage *StorageEndpoint) UsageSatellite(ctx context.Context, req *multinodepb.StorageUsageSatelliteRequest) (_ *multinodepb.StorageUsageSatelliteResponse, err error)

UsageSatellite returns daily storage usage for a given interval and satellite.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.