Documentation
¶
Index ¶
- type Config
- type Service
- func (s *Service) Close() error
- func (s *Service) GetAuction(ctx context.Context, id auction.ID) (*core.Auction, error)
- func (s *Service) OnBoostDealProposalAccepted(ctx context.Context, auctionID auction.ID, bidID auction.BidID, dealUID string) error
- func (s *Service) OnDealProposalAccepted(ctx context.Context, auctionID auction.ID, bidID auction.BidID, ...) error
- func (s *Service) OnFinalizedDeal(ctx context.Context, _ mbroker.OperationID, fad broker.FinalizedDeal) error
- func (s *Service) OnReadyToAuction(ctx context.Context, id auction.ID, sdID broker.BatchID, payloadCid cid.Cid, ...) error
- func (s *Service) PeerInfo() (*rpcpeer.Info, error)
- func (s *Service) Start(bootstrap bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Peer rpcpeer.Config
Auction auctioneer.AuctionConfig
PostgresURI string
RecordBidbotEvents bool
}
Config defines params for Service configuration.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service is a gRPC service wrapper around an Auctioneer.
func (*Service) GetAuction ¶
GetAuction gets the state of an auction by id. Mostly for test purpose.
func (*Service) OnBoostDealProposalAccepted ¶
func (s *Service) OnBoostDealProposalAccepted( ctx context.Context, auctionID auction.ID, bidID auction.BidID, dealUID string, ) error
OnBoostDealProposalAccepted receives an accepted boost deal proposal from a storage-provider.
func (*Service) OnDealProposalAccepted ¶
func (s *Service) OnDealProposalAccepted( ctx context.Context, auctionID auction.ID, bidID auction.BidID, proposalCid cid.Cid, ) error
OnDealProposalAccepted receives an accepted deal proposal from a storage-provider.
func (*Service) OnFinalizedDeal ¶
func (s *Service) OnFinalizedDeal(ctx context.Context, _ mbroker.OperationID, fad broker.FinalizedDeal) error
OnFinalizedDeal receives a finalized deal from a storage-provider.
func (*Service) OnReadyToAuction ¶
func (s *Service) OnReadyToAuction( ctx context.Context, id auction.ID, sdID broker.BatchID, payloadCid cid.Cid, dealSize uint64, dealDuration uint64, dealReplication uint32, dealVerified bool, excludedStorageProviders []string, filEpochDeadline uint64, sources auction.Sources, clientAddress string, providers []string, ) error
OnReadyToAuction handles messagse from ready-to-auction topic.
Source Files
Click to show internal directories.
Click to hide internal directories.