distributor

Documentation

Index

• func AreSliceElementsIdentical(slice1, slice2 []string) bool
• func IntersectUnique(slice1, slice2 []string) []string
• type Distributor
  • func NewDistributor(_ context.Context, database database.Client, cache cache.Client, ...) *Distributor
  • func (d *Distributor) DistributeActivitiesData(ctx context.Context, request dsl.ActivitiesRequest) ([]byte, error)
  • func (d *Distributor) DistributeActivityRequest(ctx context.Context, request dsl.ActivityRequest) ([]byte, error)
  • func (d *Distributor) DistributeRSSHubData(ctx context.Context, path, query string) ([]byte, error)
• type NetworkWorkersMap
• type WorkerNetworksMap
• type WorkerSet

Functions

func AreSliceElementsIdentical

func AreSliceElementsIdentical(slice1, slice2 []string) bool

AreSliceElementsIdentical checks if the elements of two string slices are identical.

func IntersectUnique

func IntersectUnique(slice1, slice2 []string) []string

IntersectUnique returns the unique common elements between two string slices.

Types

type Distributor

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

func NewDistributor

func NewDistributor(_ context.Context, database database.Client, cache cache.Client, httpClient httputil.Client, stakingContract *l2.Staking) *Distributor

NewDistributor creates a new distributor.

func (*Distributor) DistributeActivitiesData

func (d *Distributor) DistributeActivitiesData(ctx context.Context, request dsl.ActivitiesRequest) ([]byte, error)

DistributeActivitiesData distributes Activities requests to qualified Nodes.

func (*Distributor) DistributeActivityRequest

func (d *Distributor) DistributeActivityRequest(ctx context.Context, request dsl.ActivityRequest) ([]byte, error)

DistributeActivityRequest distributes Activity requests to qualified Nodes.

func (*Distributor) DistributeRSSHubData

func (d *Distributor) DistributeRSSHubData(ctx context.Context, path, query string) ([]byte, error)

DistributeRSSHubData distributes RSSHub requests to qualified Nodes.

type NetworkWorkersMap

type NetworkWorkersMap struct {
	Workers map[string][]string
}

type WorkerNetworksMap

type WorkerNetworksMap struct {
	Networks map[string][]string
}

type WorkerSet

type WorkerSet map[string]struct{}