p2p

Documentation

Index

• Variables
• func AttachAPI(sat *satellite.Satellite, router *mux.Router, manager *RatingManager) *mux.Router
• func Bootstrap(cdae *configs.Daemon, csat *config.Satellite, ratingManager *RatingManager, ...)
• type Rating
  • func BuyerRatingFromContract(contract *models.Contract) (rating *Rating, err error)
  • func VendorRatingFromContract(contract *models.Contract) (rating *Rating, err error)
• type RatingManager
  • func InitializeRatingManager(path string) (man *RatingManager, err error)
  • func (rm *RatingManager) Close() error
  • func (rm *RatingManager) IngestCompletionRating(contract *models.Contract) (rating *Rating, err error)
  • func (rm *RatingManager) IngestFulfillmentRating(contract *models.Contract) (rating *Rating, err error)
  • func (rm *RatingManager) InsertRating(rating *Rating) (err error)
• type RatingRequest
• type WriteRequest

Variables

var Sat *satellite.Satellite

Functions

func AttachAPI

func AttachAPI(sat *satellite.Satellite, router *mux.Router, manager *RatingManager) *mux.Router

func Bootstrap

func Bootstrap(cdae *configs.Daemon, csat *config.Satellite, ratingManager *RatingManager, killsig chan int)

Types

type Rating

type Rating struct {
	Type          string             `json:"type"`
	Source        string             `json:"src"`
	SourcePK      models.Pubkeys     `json:"srcpk"`
	Destination   string             `json:"dst"`
	DestinationPK models.Pubkeys     `json:"dstpk"`
	Signatures    []models.Signature `json:"sig"`
	Content       interface{}        `json:"rating"`
}

func BuyerRatingFromContract

func BuyerRatingFromContract(contract *models.Contract) (rating *Rating, err error)

func VendorRatingFromContract

func VendorRatingFromContract(contract *models.Contract) (rating *Rating, err error)

type RatingManager

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

func InitializeRatingManager

func InitializeRatingManager(path string) (man *RatingManager, err error)

func (*RatingManager) Close

func (rm *RatingManager) Close() error

func (*RatingManager) IngestCompletionRating

func (rm *RatingManager) IngestCompletionRating(contract *models.Contract) (rating *Rating, err error)

func (*RatingManager) IngestFulfillmentRating

func (rm *RatingManager) IngestFulfillmentRating(contract *models.Contract) (rating *Rating, err error)

func (*RatingManager) InsertRating

func (rm *RatingManager) InsertRating(rating *Rating) (err error)

type RatingRequest

type RatingRequest struct {
	Identity string `json:"ident"`
}

type WriteRequest

type WriteRequest struct {
	PacketType  string      `json:"type"`
	Destination string      `json:"destination"`
	Namespace   string      `json:"namespace"`
	Content     interface{} `json:"content"`
}