store

package
v2.23.0 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AllowedResourceProvider 

type AllowedResourceProvider struct {
	gorm.Model
	ResourceProvider string `gorm:"index"`
}

type Deal 

type Deal struct {
	gorm.Model       `gorm:"type:timestamp(3) with time zone"`
	CID              string `gorm:"index"`
	JobCreator       string `gorm:"index"`
	ResourceProvider string `gorm:"index"`
	Mediator         string
	State            uint8
	Attributes       datatypes.JSONType[data.DealContainer]
}

type JobOffer 

type JobOffer struct {
	gorm.Model `gorm:"type:timestamp(3) with time zone"`
	CID        string `gorm:"index"`
	JobCreator string `gorm:"index"`
	DealID     string `gorm:"index"`
	State      uint8  `gorm:"index"`
	Attributes datatypes.JSONType[data.JobOfferContainer]
}

type MatchDecision 

type MatchDecision struct {
	gorm.Model    `gorm:"type:timestamp(3) with time zone"`
	ResourceOffer string `gorm:"primaryKey;index:idx_resource_offer_job_offer,priority:1"`
	JobOffer      string `gorm:"primaryKey;index:idx_resource_offer_job_offer,priority:2"`
	Attributes    datatypes.JSONType[data.MatchDecision]
}

type ResourceOffer 

type ResourceOffer struct {
	gorm.Model       `gorm:"type:timestamp(3) with time zone"`
	CID              string `gorm:"index"`
	ResourceProvider string `gorm:"index"`
	DealID           string `gorm:"index"`
	State            uint8
	Attributes       datatypes.JSONType[data.ResourceOfferContainer]
}

type Result 

type Result struct {
	gorm.Model `gorm:"type:timestamp(3) with time zone"`
	DealID     string `gorm:"index"` // We query with deal ID for now
	CID        string
	Attributes datatypes.JSONType[data.Result]
}

type SolverStoreDatabase 

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

func NewSolverStoreDatabase 

func NewSolverStoreDatabase(connStr string, gormLogLevel string) (*SolverStoreDatabase, error)

func (*SolverStoreDatabase) AddAllowedResourceProvider 

func (store *SolverStoreDatabase) AddAllowedResourceProvider(resourceProvider string) (string, error)

func (*SolverStoreDatabase) AddBulkMatchDecisions added in v2.22.0 

func (store *SolverStoreDatabase) AddBulkMatchDecisions(records []data.MatchDecision) error

func (*SolverStoreDatabase) AddDeal 

func (store *SolverStoreDatabase) AddDeal(deal data.DealContainer) (*data.DealContainer, error)

func (*SolverStoreDatabase) AddJobOffer 

func (store *SolverStoreDatabase) AddJobOffer(jobOffer data.JobOfferContainer) (*data.JobOfferContainer, error)

func (*SolverStoreDatabase) AddMatchDecision 

func (store *SolverStoreDatabase) AddMatchDecision(resourceOffer string, jobOffer string, deal string, result bool) (*data.MatchDecision, error)

func (*SolverStoreDatabase) AddResourceOffer 

func (store *SolverStoreDatabase) AddResourceOffer(resourceOffer data.ResourceOfferContainer) (*data.ResourceOfferContainer, error)

func (*SolverStoreDatabase) AddResult 

func (store *SolverStoreDatabase) AddResult(result data.Result) (*data.Result, error)

func (*SolverStoreDatabase) GetAllowedResourceProviders 

func (store *SolverStoreDatabase) GetAllowedResourceProviders() ([]string, error)

func (*SolverStoreDatabase) GetDeal 

func (store *SolverStoreDatabase) GetDeal(id string) (*data.DealContainer, error)

func (*SolverStoreDatabase) GetDeals 

func (store *SolverStoreDatabase) GetDeals(query store.GetDealsQuery) ([]data.DealContainer, error)

func (*SolverStoreDatabase) GetDealsAll 

func (store *SolverStoreDatabase) GetDealsAll() ([]data.DealContainer, error)

func (*SolverStoreDatabase) GetJobOffer 

func (store *SolverStoreDatabase) GetJobOffer(id string) (*data.JobOfferContainer, error)

func (*SolverStoreDatabase) GetJobOffers 

func (store *SolverStoreDatabase) GetJobOffers(query store.GetJobOffersQuery) ([]data.JobOfferContainer, error)

func (*SolverStoreDatabase) GetMatchDecision 

func (store *SolverStoreDatabase) GetMatchDecision(resourceOffer string, jobOffer string) (*data.MatchDecision, error)

func (*SolverStoreDatabase) GetMatchDecisions 

func (store *SolverStoreDatabase) GetMatchDecisions() ([]data.MatchDecision, error)

func (*SolverStoreDatabase) GetResourceOffer 

func (store *SolverStoreDatabase) GetResourceOffer(id string) (*data.ResourceOfferContainer, error)

func (*SolverStoreDatabase) GetResourceOffers 

func (store *SolverStoreDatabase) GetResourceOffers(query store.GetResourceOffersQuery) ([]data.ResourceOfferContainer, error)

func (*SolverStoreDatabase) GetResult 

func (store *SolverStoreDatabase) GetResult(id string) (*data.Result, error)

func (*SolverStoreDatabase) GetResults 

func (store *SolverStoreDatabase) GetResults() ([]data.Result, error)

func (*SolverStoreDatabase) RemoveAllowedResourceProvider 

func (store *SolverStoreDatabase) RemoveAllowedResourceProvider(resourceProvider string) error

func (*SolverStoreDatabase) RemoveDeal 

func (store *SolverStoreDatabase) RemoveDeal(id string) error

func (*SolverStoreDatabase) RemoveJobOffer 

func (store *SolverStoreDatabase) RemoveJobOffer(id string) error

func (*SolverStoreDatabase) RemoveMatchDecision 

func (store *SolverStoreDatabase) RemoveMatchDecision(resourceOffer string, jobOffer string) error

func (*SolverStoreDatabase) RemoveResourceOffer 

func (store *SolverStoreDatabase) RemoveResourceOffer(id string) error

func (*SolverStoreDatabase) RemoveResult 

func (store *SolverStoreDatabase) RemoveResult(id string) error

func (*SolverStoreDatabase) UpdateDealDownloadTime 

func (store *SolverStoreDatabase) UpdateDealDownloadTime(id string, timestamp int) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealMediator 

func (store *SolverStoreDatabase) UpdateDealMediator(id string, mediator string) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealState 

func (store *SolverStoreDatabase) UpdateDealState(id string, state uint8) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealTransactionsJobCreator 

func (store *SolverStoreDatabase) UpdateDealTransactionsJobCreator(id string, data data.DealTransactionsJobCreator) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealTransactionsMediator 

func (store *SolverStoreDatabase) UpdateDealTransactionsMediator(id string, data data.DealTransactionsMediator) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealTransactionsResourceProvider 

func (store *SolverStoreDatabase) UpdateDealTransactionsResourceProvider(id string, data data.DealTransactionsResourceProvider) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateDealUploadTime 

func (store *SolverStoreDatabase) UpdateDealUploadTime(id string, timestamp int) (*data.DealContainer, error)

func (*SolverStoreDatabase) UpdateJobOfferState 

func (store *SolverStoreDatabase) UpdateJobOfferState(id string, dealID string, state uint8) (*data.JobOfferContainer, error)

func (*SolverStoreDatabase) UpdateResourceOfferState 

func (store *SolverStoreDatabase) UpdateResourceOfferState(id string, dealID string, state uint8) (*data.ResourceOfferContainer, error)

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.