processor

Documentation

Index

• type Processor
  • func NewProcessor(vmHandler VMHandler, project Project, proverPrivateKey *ecdsa.PrivateKey, ...) *Processor
  • func (r *Processor) HandleP2PData(d *p2p.Data, topic *pubsub.Topic)
  • func (r *Processor) HandleProjectProvers(projectID uint64, proverIDs []uint64)
• type Project
• type VMHandler

Types

type Processor

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

func NewProcessor

func NewProcessor(vmHandler VMHandler, project Project, proverPrivateKey *ecdsa.PrivateKey, seqPubkey []byte, proverID uint64) *Processor

func (*Processor) HandleP2PData

func (r *Processor) HandleP2PData(d *p2p.Data, topic *pubsub.Topic)

func (*Processor) HandleProjectProvers

func (r *Processor) HandleProjectProvers(projectID uint64, proverIDs []uint64)

type Project

type Project func(projectID uint64) (*project.Project, error)

type VMHandler

type VMHandler interface {
	Handle(task *task.Task, vmtype vm.Type, code string, expParam string) ([]byte, error)
}