orders

Documentation

Index

• Variables
• type ArchiveRequest
• type ArchivedInfo
• type DB
• type Info
• type Sender
  • func NewSender(log *zap.Logger, transport transport.Client, orders DB, trust *trust.Pool, ...) *Sender
  • func (sender *Sender) Close() error
  • func (sender *Sender) Run(ctx context.Context) (err error)
  • func (sender *Sender) Settle(ctx context.Context, satelliteID storj.NodeID, orders []*Info, ...)
• type SenderConfig
• type Status

Variables

var (
	// OrderError represents errors with orders
	OrderError = errs.Class("order")
	// OrderNotFoundError is the error returned when an order is not found
	OrderNotFoundError = errs.Class("order not found")
)

Types

type ArchiveRequest

type ArchiveRequest struct {
	Satellite storj.NodeID
	Serial    storj.SerialNumber
	Status    Status
}

ArchiveRequest defines arguments for archiving a single order.

type ArchivedInfo

type ArchivedInfo struct {
	Limit *pb.OrderLimit
	Order *pb.Order

	Status     Status
	ArchivedAt time.Time
}

ArchivedInfo contains full information about an archived order.

type DB

type DB interface {
	// Enqueue inserts order to the list of orders needing to be sent to the satellite.
	Enqueue(ctx context.Context, info *Info) error
	// ListUnsent returns orders that haven't been sent yet.
	ListUnsent(ctx context.Context, limit int) ([]*Info, error)
	// ListUnsentBySatellite returns orders that haven't been sent yet grouped by satellite.
	ListUnsentBySatellite(ctx context.Context) (map[storj.NodeID][]*Info, error)

	// Archive marks order as being handled.
	Archive(ctx context.Context, requests ...ArchiveRequest) error
	// ListArchived returns orders that have been sent.
	ListArchived(ctx context.Context, limit int) ([]*ArchivedInfo, error)
	// CleanArchive deletes all entries older than ttl
	CleanArchive(ctx context.Context, ttl time.Duration) (int, error)
}

DB implements storing orders for sending to the satellite.

type Info

type Info struct {
	Limit *pb.OrderLimit
	Order *pb.Order
}

Info contains full information about an order.

type Sender

type Sender struct {
	Loop sync2.Cycle
	// contains filtered or unexported fields
}

Sender sends every interval unsent orders to the satellite.

func NewSender

func NewSender(log *zap.Logger, transport transport.Client, orders DB, trust *trust.Pool, config SenderConfig) *Sender

NewSender creates an order sender.

func (*Sender) Close

func (sender *Sender) Close() error

Close stops the sending service.

func (*Sender) Run

func (sender *Sender) Run(ctx context.Context) (err error)

Run sends orders on every interval to the appropriate satellites.

func (*Sender) Settle

func (sender *Sender) Settle(ctx context.Context, satelliteID storj.NodeID, orders []*Info, requests chan ArchiveRequest)

Settle uploads orders to the satellite.

type SenderConfig

type SenderConfig struct {
	Interval time.Duration `help:"duration between sending" default:"1h0m0s"`
	Timeout  time.Duration `help:"timeout for sending" default:"1h0m0s"`
}

SenderConfig defines configuration for sending orders.

type Status

type Status byte

Status is the archival status of the order.

const (
	StatusUnsent Status = iota
	StatusAccepted
	StatusRejected
)

Statuses for satellite responses.