reader

Documentation

Index

• type CompletionStatus
• type GraphQLReader
  • func NewGraphQLReader(endpoint string) *GraphQLReader
  • func (r *GraphQLReader) AdvanceResult(ctx context.Context, index int) (*eggtypes.AdvanceResult, error)
• type InspectClient
  • func NewInspectClient(endpoint string) *InspectClient
  • func (c *InspectClient) Inspect(ctx context.Context, payload []byte) (*eggtypes.InspectResult, error)
• type NotFound
  • func (e NotFound) Error() string

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 GraphQLReader

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

Read the rollups state by connecting to the rollups node GraphQL API.

func NewGraphQLReader

func NewGraphQLReader(endpoint string) *GraphQLReader

Create a new GraphQL reader given the endpoint.

func (*GraphQLReader) AdvanceResult

func (r *GraphQLReader) AdvanceResult(ctx context.Context, index int) (
	*eggtypes.AdvanceResult, error)

Get an input from the rollups node.

type InspectClient

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

Client for the reader node inspect API.

func NewInspectClient

func NewInspectClient(endpoint string) *InspectClient

Create a new inspect client. The endpoint is for the reader node inspect HTTP API.

func (*InspectClient) Inspect

func (c *InspectClient) Inspect(ctx context.Context, payload []byte) (
	*eggtypes.InspectResult, error)

Send a inspect request with the given payload.

type NotFound

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

Error when an object is not found.

func (NotFound) Error

func (e NotFound) Error() string