node_reader

Documentation

Index

• Variables
• type CompletionStatus
• type NodeReader
  • func NewNodeReader(client genqlient.Client) *NodeReader
  • func (r *NodeReader) GetOutputsByInputIndex(ctx context.Context, index int) ([][]byte, error)
• type NodeReaderRepository

Variables

var (
	ErrNoNoticesFound  = errors.New("no notices found")
	ErrNoVouchersFound = errors.New("no vouchers found")
)

Types

type CompletionStatus

type CompletionStatus string

const (
	CompletionStatusUnprocessed                CompletionStatus = "UNPROCESSED"
	CompletionStatusAccepted                   CompletionStatus = "ACCEPTED"
	CompletionStatusRejected                   CompletionStatus = "REJECTED"
	CompletionStatusException                  CompletionStatus = "EXCEPTION"
	CompletionStatusMachineHalted              CompletionStatus = "MACHINE_HALTED"
	CompletionStatusCycleLimitExceeded         CompletionStatus = "CYCLE_LIMIT_EXCEEDED"
	CompletionStatusTimeLimitExceeded          CompletionStatus = "TIME_LIMIT_EXCEEDED"
	CompletionStatusPayloadLengthLimitExceeded CompletionStatus = "PAYLOAD_LENGTH_LIMIT_EXCEEDED"
)

type NodeReader

type NodeReader struct {
	Client genqlient.Client
}

func NewNodeReader

func NewNodeReader(client genqlient.Client) *NodeReader

func (*NodeReader) GetOutputsByInputIndex

func (r *NodeReader) GetOutputsByInputIndex(ctx context.Context, index int) ([][]byte, error)

type NodeReaderRepository

type NodeReaderRepository interface {
	GetOutputsByInputIndex(ctx context.Context, index int) ([][]byte, error)
}