servicer

Documentation

Index

• Variables
• func Run(name string, port int, icli *client.Client, g *gorse.Client, ...)
• type DiscoService
  • func (d *DiscoService) GetHeartbeat(_ *http.Request, _ *struct{}, reply *GetHeartbeatReply) error
  • func (d *DiscoService) GetRecommendation(r *http.Request, args *GetRecommendationArgs, reply *GetRecommendationReply) error
  • func (d *DiscoService) GetUnrated(r *http.Request, args *GetUnratedArgs, reply *GetUnratedReply) error
• type GetHeartbeatReply
• type GetRecommendationArgs
• type GetRecommendationReply
• type GetUnratedArgs
• type GetUnratedReply

Variables

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
}