enforcer

Documentation

Index

• type ComponentInfo
• type DecentralizedWorkerInfo
• type Enforcer
• type FederatedInfo
• type RSSWorkerInfo
• type ScoreMaintainer
• type SimpleEnforcer
  • func NewSimpleEnforcer(ctx context.Context, databaseClient database.Client, cacheClient cache.Client, ...) (*SimpleEnforcer, error)
  • func (e *SimpleEnforcer) ChallengeStates(_ context.Context) error
  • func (e *SimpleEnforcer) MaintainEpochData(ctx context.Context, epoch int64) error
  • func (e *SimpleEnforcer) MaintainReliabilityScore(ctx context.Context) error
  • func (e *SimpleEnforcer) RetrieveQualifiedNodes(ctx context.Context, key string) ([]*model.NodeEndpointCache, error)
  • func (e *SimpleEnforcer) VerifyPartialResponses(ctx context.Context, epochID uint64, responses []*model.DataResponse)
  • func (e *SimpleEnforcer) VerifyResponses(ctx context.Context, responses []*model.DataResponse) error
• type WorkerInfo
• type WorkerResponse

Types

type ComponentInfo

type ComponentInfo struct {
	Decentralized []*DecentralizedWorkerInfo `json:"decentralized"`
	RSS           []*RSSWorkerInfo           `json:"rss"`
	Federated     []*FederatedInfo           `json:"federated"`
}

type DecentralizedWorkerInfo

type DecentralizedWorkerInfo struct {
	WorkerInfo
	Worker   decentralized.Worker   `json:"worker"`
	Platform decentralized.Platform `json:"platform"`
}

type Enforcer

type Enforcer interface {
	VerifyResponses(ctx context.Context, responses []*model.DataResponse) error
	VerifyPartialResponses(ctx context.Context, epochID uint64, responses []*model.DataResponse)
	MaintainReliabilityScore(ctx context.Context) error
	MaintainEpochData(ctx context.Context, epoch int64) error
	ChallengeStates(ctx context.Context) error
	RetrieveQualifiedNodes(ctx context.Context, key string) ([]*model.NodeEndpointCache, error)
}

type FederatedInfo

type FederatedInfo struct {
	WorkerInfo
}

type RSSWorkerInfo

type RSSWorkerInfo struct {
	WorkerInfo
	Worker rss.Worker `json:"worker"`
}

type ScoreMaintainer

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

ScoreMaintainer is a structure used to maintain a sorted set and a quick lookup map. It uses Redis to keep a sorted set based on node scores, and a map in memory for fast access to each node endpoint's cached data. This structure helps in quickly and efficiently updating and retrieving scores and statuses of nodes in distributed systems.

type SimpleEnforcer

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

func NewSimpleEnforcer

func NewSimpleEnforcer(ctx context.Context, databaseClient database.Client, cacheClient cache.Client, stakingContract *l2.Staking, httpClient httputil.Client, initCacheData bool) (*SimpleEnforcer, error)

func (*SimpleEnforcer) ChallengeStates

func (e *SimpleEnforcer) ChallengeStates(_ context.Context) error

func (*SimpleEnforcer) MaintainEpochData

func (e *SimpleEnforcer) MaintainEpochData(ctx context.Context, epoch int64) error

MaintainEpochData maintains the data for the new epoch. The data includes the range of data that all nodes can support in a new epoch.

func (*SimpleEnforcer) MaintainReliabilityScore

func (e *SimpleEnforcer) MaintainReliabilityScore(ctx context.Context) error

MaintainReliabilityScore maintains the Reliability Score σ for all Nodes. σ is used to determine the probability of a Node receiving a request on DSL.

func (*SimpleEnforcer) RetrieveQualifiedNodes

func (e *SimpleEnforcer) RetrieveQualifiedNodes(ctx context.Context, key string) ([]*model.NodeEndpointCache, error)

RetrieveQualifiedNodes retrieves the qualified Nodes from the sorted set.

func (*SimpleEnforcer) VerifyPartialResponses

func (e *SimpleEnforcer) VerifyPartialResponses(ctx context.Context, epochID uint64, responses []*model.DataResponse)

VerifyPartialResponses performs a partial verification of the responses from the Nodes.

func (*SimpleEnforcer) VerifyResponses

func (e *SimpleEnforcer) VerifyResponses(ctx context.Context, responses []*model.DataResponse) error

VerifyResponses verifies the responses from the Nodes.

type WorkerInfo

type WorkerInfo struct {
	Network network.Network `json:"network"`
	Tags    []tag.Tag       `json:"tags"`
	Status  worker.Status   `json:"status"`
}

type WorkerResponse

type WorkerResponse struct {
	Data *ComponentInfo `json:"data"`
}