orders

Jan 30, 2024

Changes in this version

type Config

+ DownloadTailToleranceOverrides string

type Service

+ func (service *Service) DownloadNodes(scheme storj.RedundancyScheme) int32

Feb 24, 2023

Changes in this version

+ type Overlay interface

+ CachedGetOnlineNodesForGet func(context.Context, []storj.NodeID) (map[storj.NodeID]*overlay.SelectedNode, error)

+ Get func(ctx context.Context, nodeID storj.NodeID) (*overlay.NodeDossier, error)

+ GetOnlineNodesForAuditRepair func(context.Context, []storj.NodeID) (map[storj.NodeID]*overlay.NodeReputation, error)

+ IsOnline func(node *overlay.NodeDossier) bool

Feb 6, 2023

Changes in this version

type Service

+ func (service *Service) ReplacePutOrderLimits(ctx context.Context, rootPieceID storj.PieceID, ...) (_ []*pb.AddressedOrderLimit, err error)

Jan 23, 2023

Changes in this version

type DB

+ func NewNoopDB() DB

Nov 14, 2022

Changes in this version

type Service

+ func (service *Service) CreateAuditPieceOrderLimit(ctx context.Context, nodeID storj.NodeID, pieceNum uint16, ...) (limit *pb.AddressedOrderLimit, _ storj.PiecePrivateKey, ...)

Jan 10, 2022

Changes in this version

type BucketBandwidthRollup

+ IntervalStart time.Time

type CacheKey

+ IntervalStart int64

type DB

+ UpdateBandwidthBatch func(ctx context.Context, rollups []BucketBandwidthRollup) error

Oct 15, 2021

Changes in this version

type BucketBandwidthRollup

+ Dead int64

type CacheData

+ Dead int64

Dec 15, 2020

Changes in this version

+ var ErrDecryptOrderMetadata = errs.Class("decrytping order metadata")

type Service

+ func (service *Service) DecryptOrderMetadata(ctx context.Context, order *pb.OrderLimit) (_ *pb.OrderLimitMetadata, err error)

Dec 1, 2020

Changes in this version

type EncryptionKeys

+ func NewEncryptionKeys(keys ...EncryptionKey) (*EncryptionKeys, error)

+ func (keys *EncryptionKeys) Add(ekey EncryptionKey) error

+ func (keys *EncryptionKeys) Clear()

+ type SerialDeleteOptions struct

+ BatchSize int

Nov 13, 2020

Changes in this version

type Transaction

+ UpdateStoragenodeBandwidthBatchPhase2 func(ctx context.Context, intervalStart time.Time, ...) error

Oct 9, 2020

Changes in this version

type Config

+ OrdersSemaphoreSize int

Sep 18, 2020

Changes in this version

type Config

+ IncludeEncryptedMetadata bool

type EncryptionKey

+ func (key *EncryptionKey) DecryptMetadata(serial storj.SerialNumber, encrypted []byte) (*pb.OrderLimitMetadata, error)

+ func (key *EncryptionKey) EncryptMetadata(serial storj.SerialNumber, metadata *pb.OrderLimitMetadata) ([]byte, error)

type Signer

+ Bucket metabase.BucketLocation

+ EncryptedMetadata []byte

+ EncryptedMetadataKeyID []byte

Sep 4, 2020

Changes in this version

type Config

+ EncryptionKeys EncryptionKeys

Aug 24, 2020

Changes in this version

+ var ErrSigner = errs.Class("signer")

+ type Signer struct

+ Action pb.PieceAction

+ AddressedLimits []*pb.AddressedOrderLimit

+ Limit int64

+ OrderCreation time.Time

+ OrderExpiration time.Time

+ PieceExpiration time.Time

+ PrivateKey storj.PiecePrivateKey

+ PublicKey storj.PiecePublicKey

+ RootPieceID storj.PieceID

+ Serial storj.SerialNumber

+ Service *Service

+ func NewSigner(service *Service, rootPieceID storj.PieceID, pieceExpiration time.Time, ...) (*Signer, error)

+ func NewSignerAudit(service *Service, rootPieceID storj.PieceID, orderCreation time.Time, ...) (*Signer, error)

+ func NewSignerDelete(service *Service, rootPieceID storj.PieceID, orderCreation time.Time) (*Signer, error)

+ func NewSignerGet(service *Service, rootPieceID storj.PieceID, orderCreation time.Time, ...) (*Signer, error)

+ func NewSignerGracefulExit(service *Service, rootPieceID storj.PieceID, orderCreation time.Time, ...) (*Signer, error)

+ func NewSignerPut(service *Service, pieceExpiration time.Time, orderCreation time.Time, ...) (*Signer, error)

+ func NewSignerRepairGet(service *Service, rootPieceID storj.PieceID, orderCreation time.Time, ...) (*Signer, error)

+ func NewSignerRepairPut(service *Service, rootPieceID storj.PieceID, pieceExpiration time.Time, ...) (*Signer, error)

+ func (signer *Signer) Sign(ctx context.Context, node storj.NodeURL, pieceNum int32) (_ *pb.AddressedOrderLimit, err error)

Aug 10, 2020

Changes in this version

+ type BucketsDB interface

+ GetBucketID func(ctx context.Context, bucketName []byte, projectID uuid.UUID) (id uuid.UUID, err error)

type Config

+ WindowEndpointRolloutPhase WindowEndpointRolloutPhase

type Endpoint

+ func (endpoint *Endpoint) SettlementWithWindowFinal(stream pb.DRPCOrders_SettlementWithWindowStream) (err error)

+ func (endpoint *Endpoint) SettlementWithWindowMigration(stream pb.DRPCOrders_SettlementWithWindowStream) (err error)

+ type WindowEndpointRolloutPhase int

+ const WindowEndpointRolloutPhase1

+ const WindowEndpointRolloutPhase2

+ const WindowEndpointRolloutPhase3

+ func (WindowEndpointRolloutPhase) Type() string

+ func (phase *WindowEndpointRolloutPhase) Set(s string) error

+ func (phase WindowEndpointRolloutPhase) String() string

Jul 14, 2020

Changes in this version

+ var ErrEncryptionKey = errs.Class("order encryption key")

type CacheData

+ Settled int64

type DB

+ GetBucketIDFromSerialNumber func(ctx context.Context, serialNumber storj.SerialNumber) ([]byte, error)

+ UpdateStoragenodeBandwidthSettleWithWindow func(ctx context.Context, storageNodeID storj.NodeID, actionAmounts map[int32]int64, ...) (status pb.SettlementWithWindowResponse_Status, alreadyProcessed bool, ...)

+ type EncryptionKey struct

+ ID EncryptionKeyID

+ Key storj.Key

+ func (EncryptionKey) Type() string

+ func (key *EncryptionKey) Decrypt(ciphertext []byte, nonce storj.SerialNumber) ([]byte, error)

+ func (key *EncryptionKey) Encrypt(plaintext []byte, nonce storj.SerialNumber) []byte

+ func (key *EncryptionKey) IsZero() bool

+ func (key *EncryptionKey) Set(s string) error

+ func (key *EncryptionKey) String() string

+ type EncryptionKeyID [8]byte

+ func (key EncryptionKeyID) IsZero() bool

+ type EncryptionKeys struct

+ Default EncryptionKey

+ KeyByID map[EncryptionKeyID]storj.Key

+ List []EncryptionKey

+ func (EncryptionKeys) Type() string

+ func (keys *EncryptionKeys) Set(s string) error

+ func (keys *EncryptionKeys) String() string

type Endpoint

+ func (endpoint *Endpoint) SettlementWithWindow(stream pb.DRPCOrders_SettlementWithWindowStream) (err error)

type RollupsWriteCache

+ func (cache *RollupsWriteCache) UpdateBucketBandwidthSettle(ctx context.Context, projectID uuid.UUID, bucketName []byte, ...) error

Feb 25, 2020

Changes in this version

+ type ConsumedSerial struct

+ ExpiresAt time.Time

+ NodeID storj.NodeID

+ SerialNumber storj.SerialNumber

type DB

+ DeleteExpiredConsumedSerials func(ctx context.Context, now time.Time) (_ int, err error)

+ WithQueue func(ctx context.Context, cb func(ctx context.Context, queue Queue) error) error

+ type PendingSerial struct

+ Action uint

+ BucketID []byte

+ ExpiresAt time.Time

+ NodeID storj.NodeID

+ SerialNumber storj.SerialNumber

+ Settled uint64

+ type Queue interface

+ GetPendingSerialsBatch func(ctx context.Context, size int) ([]PendingSerial, error)

type Transaction

+ CreateConsumedSerialsBatch func(ctx context.Context, consumedSerials []ConsumedSerial) (err error)

+ HasConsumedSerial func(ctx context.Context, nodeID storj.NodeID, serialNumber storj.SerialNumber) (bool, error)

Feb 12, 2020

Changes in this version

type Service

+ func (service *Service) CreateGetOrderLimitsOld(ctx context.Context, bucketID []byte, pointer *pb.Pointer) (_ []*pb.AddressedOrderLimit, privateKey storj.PiecePrivateKey, err error)

+ func (service *Service) RandomSampleOfOrderLimits(limits []*pb.AddressedOrderLimit, sampleSize int) ([]*pb.AddressedOrderLimit, error)

Jan 25, 2020

Changes in this version

type RollupsWriteCache

+ func (cache *RollupsWriteCache) CloseAndFlush(ctx context.Context) error

+ func (cache *RollupsWriteCache) Flush(ctx context.Context)

Jan 21, 2020

Changes in this version

type Config

+ NodeStatusLogging bool

Jan 17, 2020

Changes in this version

type DB

+ WithTransaction func(ctx context.Context, cb func(ctx context.Context, tx Transaction) error) error

Jan 16, 2020

Changes in this version

+ func SortBucketBandwidthRollups(rollups []BucketBandwidthRollup)

+ func SortStoragenodeBandwidthRollups(rollups []StoragenodeBandwidthRollup)

+ type BucketBandwidthRollup struct

+ Action pb.PieceAction

+ Allocated int64

+ BucketName string

+ Inline int64

+ ProjectID uuid.UUID

+ Settled int64

type Config

+ ReportedRollupsReadBatchSize int

type DB

+ ExecuteInTx func(ctx context.Context, cb func(ctx context.Context, tx Transaction) error) error

+ GetBillableBandwidth func(ctx context.Context, now time.Time) (bucketRollups []BucketBandwidthRollup, ...)

+ type StoragenodeBandwidthRollup struct

+ Action pb.PieceAction

+ Allocated int64

+ NodeID storj.NodeID

+ Settled int64

+ type Transaction interface

+ DeleteExpiredReportedSerials func(ctx context.Context, now time.Time) (err error)

+ UpdateBucketBandwidthBatch func(ctx context.Context, intervalStart time.Time, rollups []BucketBandwidthRollup) error

+ UpdateStoragenodeBandwidthBatch func(ctx context.Context, intervalStart time.Time, ...) error

Jan 13, 2020

Changes in this version

+ func SortRollups(rollups []BandwidthRollup)

+ type BandwidthRollup struct

+ Action pb.PieceAction

+ Allocated int64

+ BucketName string

+ Inline int64

+ ProjectID uuid.UUID

+ type CacheData struct

+ Allocated int64

+ Inline int64

+ type CacheKey struct

+ Action pb.PieceAction

+ BucketName string

+ ProjectID uuid.UUID

+ type Chore struct

+ Loop *sync2.Cycle

+ func NewChore(log *zap.Logger, ordersWriteCache *RollupsWriteCache, config Config) *Chore

+ func (chore *Chore) Close() error

+ func (chore *Chore) Run(ctx context.Context) (err error)

type Config

+ FlushBatchSize int

+ FlushInterval time.Duration

type DB

+ UpdateBucketBandwidthBatch func(ctx context.Context, intervalStart time.Time, rollups []BandwidthRollup) error

+ type RollupData map[CacheKey]CacheData

+ type RollupsWriteCache struct

+ func NewRollupsWriteCache(log *zap.Logger, db DB, batchSize int) *RollupsWriteCache

+ func (cache *RollupsWriteCache) CurrentData() RollupData

+ func (cache *RollupsWriteCache) CurrentSize() int

+ func (cache *RollupsWriteCache) FlushToDB(ctx context.Context)

+ func (cache *RollupsWriteCache) OnNextFlush() <-chan struct{}

+ func (cache *RollupsWriteCache) UpdateBucketBandwidthAllocation(ctx context.Context, projectID uuid.UUID, bucketName []byte, ...) error

+ func (cache *RollupsWriteCache) UpdateBucketBandwidthInline(ctx context.Context, projectID uuid.UUID, bucketName []byte, ...) error

Dec 10, 2019

Changes in this version

+ var ErrDownloadFailedNotEnoughPieces = errs.Class("not enough pieces for download")

Oct 23, 2019

Changes in this version

type Service

+ func (service *Service) CreateGracefulExitPutOrderLimit(ctx context.Context, bucketID []byte, nodeID storj.NodeID, pieceNum int32, ...) (limit *pb.AddressedOrderLimit, _ storj.PiecePrivateKey, err error)

Sep 19, 2019

Changes in this version

type Endpoint

+ func (endpoint *Endpoint) DRPC() pb.DRPCOrdersServer

Aug 28, 2019

Changes in this version

type DB

+ DeleteExpiredSerials func(ctx context.Context, now time.Time) (_ int, err error)

Aug 20, 2019

Changes in this version

type Config

+ SettlementBatchSize int

type DB

+ ProcessOrders func(ctx context.Context, requests []*ProcessOrderRequest) (responses []*ProcessOrderResponse, err error)

+ type ProcessOrderRequest struct

+ Order *pb.Order

+ OrderLimit *pb.OrderLimit

+ type ProcessOrderResponse struct

+ SerialNumber storj.SerialNumber

+ Status pb.SettlementResponse_Status

Jul 16, 2019

Changes in this version

+ func SplitBucketID(bucketID []byte) (projectID *uuid.UUID, bucketName []byte, err error)

Jun 24, 2019

Changes in this version

+ type Config struct

+ Expiration time.Duration

Jun 11, 2019

Changes in this version

type Service

+ func (service *Service) CreateAuditOrderLimit(ctx context.Context, auditor *identity.PeerIdentity, bucketID []byte, ...) (limit *pb.AddressedOrderLimit, err error)

Apr 10, 2019

Changes in this version

type Service

+ func (service *Service) UpdateGetInlineOrder(ctx context.Context, bucketID []byte, amount int64) (err error)

+ func (service *Service) UpdatePutInlineOrder(ctx context.Context, bucketID []byte, amount int64) (err error)

Apr 4, 2019

Changes in this version

+ var ErrUsingSerialNumber = errs.Class("serial number")

Apr 3, 2019

Changes in this version

+ var Error = errs.Class("orders error")

+ type DB interface

+ CreateSerialInfo func(ctx context.Context, serialNumber storj.SerialNumber, bucketID []byte, ...) error

+ GetBucketBandwidth func(ctx context.Context, bucketID []byte, from, to time.Time) (int64, error)

+ GetStorageNodeBandwidth func(ctx context.Context, nodeID storj.NodeID, from, to time.Time) (int64, error)

+ UnuseSerialNumber func(ctx context.Context, serialNumber storj.SerialNumber, ...) error

+ UpdateBucketBandwidthAllocation func(ctx context.Context, bucketID []byte, action pb.PieceAction, amount int64) error

+ UpdateBucketBandwidthInline func(ctx context.Context, bucketID []byte, action pb.PieceAction, amount int64) error

+ UpdateBucketBandwidthSettle func(ctx context.Context, bucketID []byte, action pb.PieceAction, amount int64) error

+ UpdateStoragenodeBandwidthAllocation func(ctx context.Context, storageNode storj.NodeID, action pb.PieceAction, ...) error

+ UpdateStoragenodeBandwidthSettle func(ctx context.Context, storageNode storj.NodeID, action pb.PieceAction, ...) error

+ UseSerialNumber func(ctx context.Context, serialNumber storj.SerialNumber, ...) ([]byte, error)

+ type Endpoint struct

+ DB DB

+ func NewEndpoint(log *zap.Logger, satelliteSignee signing.Signee, db DB, certdb certdb.DB) *Endpoint

+ func (endpoint *Endpoint) Settlement(stream pb.Orders_SettlementServer) (err error)

+ type Service struct

+ func NewService(log *zap.Logger, satellite signing.Signer, cache *overlay.Cache, ...) *Service

+ func (service *Service) CreateAuditOrderLimits(ctx context.Context, auditor *identity.PeerIdentity, bucketID []byte, ...) (_ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) CreateDeleteOrderLimits(ctx context.Context, uplink *identity.PeerIdentity, bucketID []byte, ...) (_ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) CreateGetOrderLimits(ctx context.Context, uplink *identity.PeerIdentity, bucketID []byte, ...) (_ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) CreateGetRepairOrderLimits(ctx context.Context, repairer *identity.PeerIdentity, bucketID []byte, ...) (_ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) CreatePutOrderLimits(ctx context.Context, uplink *identity.PeerIdentity, bucketID []byte, ...) (_ storj.PieceID, _ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) CreatePutRepairOrderLimits(ctx context.Context, repairer *identity.PeerIdentity, bucketID []byte, ...) (_ []*pb.AddressedOrderLimit, err error)

+ func (service *Service) VerifyOrderLimitSignature(signed *pb.OrderLimit2) error