multinode

Documentation

Index

• type BandwidthEndpoint
  • func NewBandwidthEndpoint(log *zap.Logger, apiKeys *apikeys.Service, db bandwidth.DB) *BandwidthEndpoint
  • func (bandwidth *BandwidthEndpoint) MonthSummary(ctx context.Context, req *multinodepb.BandwidthMonthSummaryRequest) (_ *multinodepb.BandwidthMonthSummaryResponse, err error)
• type NodeEndpoint
  • func NewNodeEndpoint(log *zap.Logger, apiKeys *apikeys.Service, version version.Info, ...) *NodeEndpoint
  • func (node *NodeEndpoint) LastContact(ctx context.Context, req *multinodepb.LastContactRequest) (_ *multinodepb.LastContactResponse, err error)
  • func (node *NodeEndpoint) Reputation(ctx context.Context, req *multinodepb.ReputationRequest) (_ *multinodepb.ReputationResponse, err error)
  • func (node *NodeEndpoint) TrustedSatellites(ctx context.Context, req *multinodepb.TrustedSatellitesRequest) (_ *multinodepb.TrustedSatellitesResponse, err error)
  • func (node *NodeEndpoint) Version(ctx context.Context, req *multinodepb.VersionRequest) (_ *multinodepb.VersionResponse, err error)
• type PayoutEndpoint
  • func NewPayoutEndpoint(log *zap.Logger, apiKeys *apikeys.Service, db payouts.DB) *PayoutEndpoint
  • func (payout *PayoutEndpoint) Earned(ctx context.Context, req *multinodepb.EarnedRequest) (_ *multinodepb.EarnedResponse, err error)
• type StorageEndpoint
  • func NewStorageEndpoint(log *zap.Logger, apiKeys *apikeys.Service, monitor *monitor.Service) *StorageEndpoint
  • func (storage *StorageEndpoint) DiskSpace(ctx context.Context, req *multinodepb.DiskSpaceRequest) (_ *multinodepb.DiskSpaceResponse, err error)

Types

type BandwidthEndpoint

type BandwidthEndpoint struct {
	// 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) 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 {
	// contains filtered or unexported fields
}

NodeEndpoint implements multinode node endpoint.

architecture: Endpoint

func NewNodeEndpoint

func NewNodeEndpoint(log *zap.Logger, 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) Reputation

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

Reputation returns reputation for specific satellite.

func (*NodeEndpoint) TrustedSatellites

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

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

PayoutEndpoint implements multinode payouts endpoint.

architecture: Endpoint

func NewPayoutEndpoint

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

NewPayoutEndpoint creates new multinode payouts endpoint.

func (*PayoutEndpoint) Earned

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

Earned returns total earned amount.

type StorageEndpoint

type StorageEndpoint struct {
	// 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) *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.