serverworker

Documentation

Overview

Package serverworker gives additional functionalities to regular CoconutWorker that are required by a server instance.

Index

• type Config
• type IssuerWorker
• type ProviderWorker
• type ServerWorker
  • func New(cfg *Config) (*ServerWorker, error)
  • func (sw *ServerWorker) RegisterAsIssuer(tsk *coconut.ThresholdSecretKey, tvk *coconut.ThresholdVerificationKey) error
  • func (sw *ServerWorker) RegisterAsProvider(avk *coconut.VerificationKey, privateKey *ecdsa.PrivateKey, ...) error
  • func (sw *ServerWorker) RegisterHandler(o interface{}, hfn commandhandler.HandlerFunc, ...)

Types

type Config

type Config struct {
	ID         uint64
	Params     *coconut.Params
	JobQueue   chan<- *jobpacket.JobPacket
	IncomingCh <-chan *commands.CommandRequest
	Log        *logger.Logger
	NymClient  *nymclient.Client
	Store      *storage.Database
}

Config encapsulates arguments passed in New to create new instance of the serverworker.

type IssuerWorker

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

type ProviderWorker

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

type ServerWorker

type ServerWorker struct {
	worker.Worker
	IssuerWorker
	ProviderWorker
	*coconutworker.CoconutWorker // TODO: since CoconutWorker does not have many attributes should we still use reference?
	// contains filtered or unexported fields
}

/ ServerWorker allows writing coconut actions to a shared job queue, so that they could be run concurrently.

func New

func New(cfg *Config) (*ServerWorker, error)

New creates new instance of a serverWorker.

func (*ServerWorker) RegisterAsIssuer

func (sw *ServerWorker) RegisterAsIssuer(tsk *coconut.ThresholdSecretKey, tvk *coconut.ThresholdVerificationKey) error

func (*ServerWorker) RegisterAsProvider

func (sw *ServerWorker) RegisterAsProvider(avk *coconut.VerificationKey,
	privateKey *ecdsa.PrivateKey,
	disableVerification bool,
) error

func (*ServerWorker) RegisterHandler

func (sw *ServerWorker) RegisterHandler(o interface{},
	hfn commandhandler.HandlerFunc,
	dfn func(commands.Command) commandhandler.HandlerData)