blockchain

Documentation

Index

• Constants
• type Processor
  • func NewProcessor(boltDB *bolt.DB) (Processor, error)
  • func (p Processor) CompleteJob(jobAddressBytes, jobSignatureBytes []byte)
  • func (p Processor) GrpcStreamInterceptor() grpc.StreamServerInterceptor
  • func (p Processor) IsValidJobInvocation(jobAddressBytes, jobSignatureBytes []byte) bool
  • func (p Processor) StartLoop()

Constants

const (
	JobAddressHeader   = "snet-job-address"
	JobSignatureHeader = "snet-job-signature"
)

Types

type Processor

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

func NewProcessor

func NewProcessor(boltDB *bolt.DB) (Processor, error)

NewProcessor creates a new blockchain processor

func (Processor) CompleteJob

func (p Processor) CompleteJob(jobAddressBytes, jobSignatureBytes []byte)

func (Processor) GrpcStreamInterceptor

func (p Processor) GrpcStreamInterceptor() grpc.StreamServerInterceptor

func (Processor) IsValidJobInvocation

func (p Processor) IsValidJobInvocation(jobAddressBytes, jobSignatureBytes []byte) bool

func (Processor) StartLoop

func (p Processor) StartLoop()

StartLoops starts background processing for event and job completion routines