resolvers

package
v0.1.0-beta2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 27, 2020 License: Apache-2.0 Imports: 36 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewRoot 

func NewRoot(searchClient pbsearch.RouterClient, dbReader eosdb.DBReader, blockMetaClient *pbblockmeta.Client, abiCodecClient pbabicodec.DecoderClient) (interface{}, error)

func S 

func S(in string) *string

Types

type Action 

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

func (*Action) Account 

func (a *Action) Account() string

func (*Action) Authorization 

func (a *Action) Authorization() (out []*PermissionLevel)

func (*Action) Data 

func (a *Action) Data() *commonTypes.JSON

func (*Action) HexData 

func (a *Action) HexData() string

func (*Action) JSON 

func (a *Action) JSON() *commonTypes.JSON

func (*Action) Name 

func (a *Action) Name() string

type ActionReceipt 

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

func (*ActionReceipt) ABISequence 

func (r *ActionReceipt) ABISequence() types.Uint64

func (*ActionReceipt) CodeSequence 

func (r *ActionReceipt) CodeSequence() types.Uint64

func (*ActionReceipt) Digest 

func (r *ActionReceipt) Digest() string

func (*ActionReceipt) GlobalSequence 

func (r *ActionReceipt) GlobalSequence() types.Uint64

func (*ActionReceipt) Receiver 

func (r *ActionReceipt) Receiver() string

func (*ActionReceipt) RecvSequence 

func (r *ActionReceipt) RecvSequence() types.Uint64

type ActionTrace 

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

func (*ActionTrace) Account 

func (t *ActionTrace) Account() string

func (*ActionTrace) Action 

func (t *ActionTrace) Action() *Action

func (*ActionTrace) Authorization 

func (t *ActionTrace) Authorization() (out []*PermissionLevel)

func (*ActionTrace) ClosestUnnotifiedAncestorAction 

func (t *ActionTrace) ClosestUnnotifiedAncestorAction() (out *ActionTrace)

func (*ActionTrace) Console 

func (t *ActionTrace) Console() string

func (*ActionTrace) ContextFree 

func (t *ActionTrace) ContextFree() bool

func (*ActionTrace) CreatedActions 

func (t *ActionTrace) CreatedActions(args struct{ Sort string }) (out []*ActionTrace)

func (*ActionTrace) CreatorAction 

func (t *ActionTrace) CreatorAction() *ActionTrace

func (*ActionTrace) DBOps 

func (t *ActionTrace) DBOps(args DBOpsArgs) (out []*DBOp)

func (*ActionTrace) DTrxOps 

func (t *ActionTrace) DTrxOps() (out []*DTrxOp)

func (*ActionTrace) Data 

func (t *ActionTrace) Data() *commonTypes.JSON

func (*ActionTrace) Elapsed 

func (t *ActionTrace) Elapsed() types.Int64

func (*ActionTrace) ExceptJSON 

func (t *ActionTrace) ExceptJSON() (*commonTypes.JSON, error)

func (*ActionTrace) ExecutionIndex 

func (t *ActionTrace) ExecutionIndex() commonTypes.Uint32

func (*ActionTrace) HexData 

func (t *ActionTrace) HexData() string

func (*ActionTrace) InlineTraces 

func (t *ActionTrace) InlineTraces() (out []*ActionTrace)

Not exposed right now. Please don't expose it.. because this parenthood is confusing and risks creating

func (*ActionTrace) IsMatchingQuery 

func (t *ActionTrace) IsMatchingQuery() bool

func (*ActionTrace) IsNotify 

func (t *ActionTrace) IsNotify() bool

func (*ActionTrace) JSON 

func (t *ActionTrace) JSON() *commonTypes.JSON

func (*ActionTrace) Name 

func (t *ActionTrace) Name() string

func (*ActionTrace) RAMOps 

func (t *ActionTrace) RAMOps() (out []*RAMOp)

func (*ActionTrace) Receipt 

func (t *ActionTrace) Receipt() *ActionReceipt

func (*ActionTrace) Receiver 

func (t *ActionTrace) Receiver() string

func (*ActionTrace) Seq 

func (t *ActionTrace) Seq() types.Uint64

func (*ActionTrace) TableOps 

func (t *ActionTrace) TableOps() (out []*TableOp)

type Block 

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

--------------------------- Block ----------------------------

func (*Block) DposLIBNum 

func (b *Block) DposLIBNum() commonTypes.Uint32

func (*Block) ExecutedTransactionCount 

func (b *Block) ExecutedTransactionCount() commonTypes.Uint32

func (*Block) Header 

func (b *Block) Header() *BlockHeader

func (*Block) ID 

func (b *Block) ID() string

func (*Block) Irreversible 

func (b *Block) Irreversible() bool

func (*Block) Num 

func (b *Block) Num() commonTypes.Uint32

func (*Block) TransactionTraces 

func (b *Block) TransactionTraces(ctx context.Context, req *TransactionTracesReq) (*TransactionTraceConnection, error)

type BlockHeader 

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

func (BlockHeader) ActionMRoot 

func (t BlockHeader) ActionMRoot() string

func (BlockHeader) Confirmed 

func (t BlockHeader) Confirmed() commonTypes.Uint32

func (BlockHeader) ID 

func (t BlockHeader) ID() string

func (BlockHeader) NewProducers 

func (t BlockHeader) NewProducers() (out *ProducerSchedule, err error)

func (BlockHeader) Num 

func (t BlockHeader) Num() commonTypes.Uint32

func (BlockHeader) Previous 

func (t BlockHeader) Previous() string

func (BlockHeader) Producer 

func (t BlockHeader) Producer() string

func (BlockHeader) ScheduleVersion 

func (t BlockHeader) ScheduleVersion() commonTypes.Uint32

func (BlockHeader) Timestamp 

func (t BlockHeader) Timestamp() graphql.Time

func (BlockHeader) TransactionMRoot 

func (t BlockHeader) TransactionMRoot() string

type BlockIDAtAccountCreationArgs 

type BlockIDAtAccountCreationArgs struct {
	Account string
}

type BlockIDByTimeArgs 

type BlockIDByTimeArgs struct {
	Time       graphql.Time
	Comparator string
}

type BlockIDResponse 

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

func (*BlockIDResponse) ID 

func (r *BlockIDResponse) ID() string

func (*BlockIDResponse) Num 

func (r *BlockIDResponse) Num() commonTypes.Uint32

func (*BlockIDResponse) Time 

func (r *BlockIDResponse) Time() graphql.Time

type DBOp 

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

func (*DBOp) Key 

func (o *DBOp) Key() *DBOpKey

func (*DBOp) NewData 

func (o *DBOp) NewData() *string

func (*DBOp) NewJSON 

func (o *DBOp) NewJSON(ctx context.Context) *DecodedObject

func (*DBOp) NewPayer 

func (o *DBOp) NewPayer() *string

func (*DBOp) OldData 

func (o *DBOp) OldData() *string

func (*DBOp) OldJSON 

func (o *DBOp) OldJSON(ctx context.Context) *DecodedObject

func (*DBOp) OldPayer 

func (o *DBOp) OldPayer() *string

func (*DBOp) Operation 

func (o *DBOp) Operation() string

type DBOpKey 

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

func (*DBOpKey) Code 

func (k *DBOpKey) Code() string

func (*DBOpKey) Key 

func (k *DBOpKey) Key(args struct{ Encoding string }) string

func (*DBOpKey) Scope 

func (k *DBOpKey) Scope(args struct{ Encoding string }) string

func (*DBOpKey) Table 

func (k *DBOpKey) Table() string

type DBOpsArgs 

type DBOpsArgs struct {
	Table *string
	Code  *string
}

type DTrxOp 

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

func (*DTrxOp) DelayUntil 

func (o *DTrxOp) DelayUntil() *graphql.Time

func (*DTrxOp) ExpirationAt 

func (o *DTrxOp) ExpirationAt() *graphql.Time

func (*DTrxOp) Operation 

func (o *DTrxOp) Operation() string

func (*DTrxOp) Payer 

func (o *DTrxOp) Payer() *string

func (*DTrxOp) PublishedAt 

func (o *DTrxOp) PublishedAt() *graphql.Time

func (*DTrxOp) Sender 

func (o *DTrxOp) Sender() *string

func (*DTrxOp) SenderID 

func (o *DTrxOp) SenderID() *string

func (*DTrxOp) Transaction 

func (o *DTrxOp) Transaction() *Transaction

func (*DTrxOp) TrxID 

func (o *DTrxOp) TrxID() *string

type DecodedObject 

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

func (*DecodedObject) Error 

func (t *DecodedObject) Error() *string

func (*DecodedObject) Object 

func (t *DecodedObject) Object() *commonTypes.JSON

type PageInfo 

type PageInfo struct {
	StartCursor     string
	EndCursor       string
	HasNextPage     bool
	HasPreviousPage bool
}

type PagineableTransactionTraceRefs 

type PagineableTransactionTraceRefs [][]byte

--------------------------- Pageneable Resource ----------------------------

func (PagineableTransactionTraceRefs) Append 

func (p PagineableTransactionTraceRefs) Append(slice dgraphql.Pagineable, index int) dgraphql.Pagineable

func (PagineableTransactionTraceRefs) IsEqual 

func (p PagineableTransactionTraceRefs) IsEqual(index int, key string) bool

func (PagineableTransactionTraceRefs) Length 

func (p PagineableTransactionTraceRefs) Length() int

type PermissionLevel 

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

func (*PermissionLevel) Actor 

func (t *PermissionLevel) Actor() string

func (*PermissionLevel) Permission 

func (t *PermissionLevel) Permission() string

type ProducerKey 

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

func (*ProducerKey) BlockSigningKey 

func (k *ProducerKey) BlockSigningKey() string

func (*ProducerKey) ProducerName 

func (k *ProducerKey) ProducerName() string

type ProducerSchedule 

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

func (*ProducerSchedule) Producers 

func (s *ProducerSchedule) Producers() (out []*ProducerKey)

func (*ProducerSchedule) Version 

func (s *ProducerSchedule) Version() commonTypes.Uint32

type QueryBlockRequest 

type QueryBlockRequest struct {
	Num *commonTypes.Uint32
	Id  *string
}

type RAMOp 

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

func (*RAMOp) Delta 

func (o *RAMOp) Delta() types.Int64

func (*RAMOp) Operation 

func (o *RAMOp) Operation() string

func (*RAMOp) Payer 

func (o *RAMOp) Payer() string

func (*RAMOp) Usage 

func (o *RAMOp) Usage() types.Uint64

type Root 

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

Root is the root resolver.

func (*Root) QueryBlock 

func (r *Root) QueryBlock(ctx context.Context, req QueryBlockRequest) (*Block, error)

func (*Root) QueryBlockIDAtAccountCreation 

func (r *Root) QueryBlockIDAtAccountCreation(ctx context.Context, args BlockIDAtAccountCreationArgs) (*BlockIDResponse, error)

func (*Root) QueryBlockIDByTime 

func (r *Root) QueryBlockIDByTime(ctx context.Context, args BlockIDByTimeArgs) (*BlockIDResponse, error)

func (*Root) QuerySearchTransactionsBackward 

func (r *Root) QuerySearchTransactionsBackward(ctx context.Context, args SearchArgs) (*SearchTransactionsBackwardResponse, error)

func (*Root) QuerySearchTransactionsForward 

func (r *Root) QuerySearchTransactionsForward(ctx context.Context, args SearchArgs) (*SearchTransactionsForwardResponse, error)

func (*Root) SubscriptionSearchTransactionsBackward 

func (r *Root) SubscriptionSearchTransactionsBackward(ctx context.Context, args StreamSearchArgs) (<-chan *SearchTransactionForwardResponse, error)

func (*Root) SubscriptionSearchTransactionsForward 

func (r *Root) SubscriptionSearchTransactionsForward(ctx context.Context, args StreamSearchArgs) (<-chan *SearchTransactionForwardResponse, error)

type SearchArgs 

type SearchArgs struct {
	Query            string
	SortDesc         bool
	LowBlockNum      *types.Int64
	HighBlockNum     *types.Int64
	Limit            types.Int64
	Cursor           *string
	IrreversibleOnly bool
}

CAREFUL - this mirrored in the BigQuery schema - if you change this, make sure to be backwards compatible

type SearchTransactionBackwardResponse 

type SearchTransactionBackwardResponse struct {

	//FIXME: shouldn't this be shared betweeen the two Single search responses?
	ResolverError error
	// contains filtered or unexported fields
}

func (*SearchTransactionBackwardResponse) Block 

func (t *SearchTransactionBackwardResponse) Block() *BlockHeader

func (*SearchTransactionBackwardResponse) Cursor 

func (t *SearchTransactionBackwardResponse) Cursor() string

func (*SearchTransactionBackwardResponse) IrreversibleBlockNum 

func (t *SearchTransactionBackwardResponse) IrreversibleBlockNum() commonTypes.Uint32

func (*SearchTransactionBackwardResponse) IsIrreversible 

func (t *SearchTransactionBackwardResponse) IsIrreversible() bool

func (*SearchTransactionBackwardResponse) Trace 

func (t *SearchTransactionBackwardResponse) Trace() *TransactionTrace

type SearchTransactionForwardResponse 

type SearchTransactionForwardResponse struct {
	SearchTransactionBackwardResponse

	Undo bool
	// contains filtered or unexported fields
}

Single response

func (*SearchTransactionForwardResponse) SubscriptionError 

func (r *SearchTransactionForwardResponse) SubscriptionError() error

type SearchTransactionsBackwardResponse 

type SearchTransactionsBackwardResponse struct {
	Results *[]*SearchTransactionBackwardResponse
	// contains filtered or unexported fields
}

func (*SearchTransactionsBackwardResponse) Cursor 

func (t *SearchTransactionsBackwardResponse) Cursor() string

type SearchTransactionsForwardResponse 

type SearchTransactionsForwardResponse struct {
	Results *[]*SearchTransactionForwardResponse
	// contains filtered or unexported fields
}

func (*SearchTransactionsForwardResponse) Cursor 

func (t *SearchTransactionsForwardResponse) Cursor() *string

type StreamSearchArgs 

type StreamSearchArgs struct {
	Query              string
	LowBlockNum        *types.Int64
	HighBlockNum       *types.Int64
	Cursor             *string
	Limit              types.Int64
	IrreversibleOnly   bool
	LiveMarkerInterval commonTypes.Uint32
}

CAREFUL - this mirrored in the BigQuery schema - if you change this, make sure to be backwards compatible

type TableOp 

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

func (*TableOp) Operation 

func (o *TableOp) Operation() string

func (*TableOp) Table 

func (o *TableOp) Table() *TableOpKey

type TableOpKey 

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

func (*TableOpKey) Code 

func (t *TableOpKey) Code() string

func (*TableOpKey) Scope 

func (t *TableOpKey) Scope(args struct{ Encoding string }) string

WARN: because of `args`, there are chances that we spin go-routines for nothing, perhaps we'll want to tweak `graphql-go` so it doesn't spin goroutines just because we have a param here. Same for DBOpKey

func (*TableOpKey) Table 

func (t *TableOpKey) Table() string

type Transaction 

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

func (*Transaction) Actions 

func (t *Transaction) Actions() (out []*Action)

func (*Transaction) ContextFreeActions 

func (t *Transaction) ContextFreeActions() (out []*Action)

func (*Transaction) DelaySec 

func (t *Transaction) DelaySec() commonTypes.Uint32

func (*Transaction) Expiration 

func (t *Transaction) Expiration() graphql.Time

func (*Transaction) MaxCPUUsageMS 

func (t *Transaction) MaxCPUUsageMS() commonTypes.Uint32

func (*Transaction) MaxNetUsageWords 

func (t *Transaction) MaxNetUsageWords() commonTypes.Uint32

func (*Transaction) RefBlockNum 

func (t *Transaction) RefBlockNum() commonTypes.Uint32

func (*Transaction) RefBlockPrefix 

func (t *Transaction) RefBlockPrefix() commonTypes.Uint32

type TransactionReceiptHeader 

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

func (*TransactionReceiptHeader) CPUUsageMicroSeconds 

func (h *TransactionReceiptHeader) CPUUsageMicroSeconds() commonTypes.Uint32

func (*TransactionReceiptHeader) NetUsageWords 

func (h *TransactionReceiptHeader) NetUsageWords() commonTypes.Uint32

func (*TransactionReceiptHeader) Status 

func (h *TransactionReceiptHeader) Status() string

type TransactionTrace 

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

func (*TransactionTrace) Block 

func (t *TransactionTrace) Block() *BlockHeader

func (*TransactionTrace) Elapsed 

func (t *TransactionTrace) Elapsed() types.Int64

func (*TransactionTrace) ExceptJSON 

func (t *TransactionTrace) ExceptJSON() (*commonTypes.JSON, error)

func (*TransactionTrace) ExecutedActions 

func (t *TransactionTrace) ExecutedActions() (out []*ActionTrace)

func (*TransactionTrace) ID 

func (t *TransactionTrace) ID() string

func (*TransactionTrace) MatchingActions 

func (t *TransactionTrace) MatchingActions() (out []*ActionTrace)

func (*TransactionTrace) NetUsage 

func (t *TransactionTrace) NetUsage() types.Uint64

func (*TransactionTrace) Receipt 

func (t *TransactionTrace) Receipt() *TransactionReceiptHeader

func (*TransactionTrace) Scheduled 

func (t *TransactionTrace) Scheduled() bool

func (*TransactionTrace) Status 

func (t *TransactionTrace) Status() string

func (*TransactionTrace) TopLevelActions 

func (t *TransactionTrace) TopLevelActions() (out []*ActionTrace)

type TransactionTraceConnection 

type TransactionTraceConnection struct {
	PageInfo *PageInfo
	Edges    []*TransactionTraceEdge
}

type TransactionTraceEdge 

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

func (*TransactionTraceEdge) Cursor 

func (t *TransactionTraceEdge) Cursor() string

func (*TransactionTraceEdge) Node 

func (t *TransactionTraceEdge) Node() *TransactionTrace

type TransactionTracesReq 

type TransactionTracesReq struct {
	First  *commonTypes.Uint32
	Last   *commonTypes.Uint32
	Before *string
	After  *string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.