servicer

package
v0.0.0-...-3f52ee8 Latest Latest
Warning

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

Go to latest
Published: Feb 24, 2023 License: BSD-3-Clause Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrMissingHeartbeat = errors.New("missing heartbeat")
	ErrInvalidRating    = errors.New("invalid rating")
)

Functions

func Run

func Run(
	name string,
	port int,
	icli *client.Client,
	g *gorse.Client,
	servicer crypto.PublicKey,
	commission uint64,
	pending int,
)

Types

type DiscoService

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

func (*DiscoService) GetHeartbeat

func (d *DiscoService) GetHeartbeat(
	_ *http.Request,
	_ *struct{},
	reply *GetHeartbeatReply,
) error

func (*DiscoService) GetRecommendation

func (d *DiscoService) GetRecommendation(
	r *http.Request,
	args *GetRecommendationArgs,
	reply *GetRecommendationReply,
) error

func (*DiscoService) GetUnrated

func (d *DiscoService) GetUnrated(
	r *http.Request,
	args *GetUnratedArgs,
	reply *GetUnratedReply,
) error

type GetHeartbeatReply

type GetHeartbeatReply struct {
	Heartbeat uint64
}

type GetRecommendationArgs

type GetRecommendationArgs struct {
	Heartbeat uint64
	Actor     crypto.PublicKey
	Signature crypto.Signature

	Schema ids.ID
}

type GetRecommendationReply

type GetRecommendationReply struct {
	ID      string
	Content string

	Servicer   crypto.PublicKey
	Commission uint64
}

type GetUnratedArgs

type GetUnratedArgs struct {
	Heartbeat uint64
	Actor     crypto.PublicKey
	Signature crypto.Signature
}

type GetUnratedReply

type GetUnratedReply struct {
	Unrated []*GetRecommendationReply
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL