near

package module
v0.0.0-...-cc46cae Latest Latest
Warning

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

Go to latest
Published: Oct 9, 2024 License: MIT Imports: 19 Imported by: 0

README

Lotus NEAR Connector

The NEAR protocol is a sharded, proof-of-stake, layer-one blockchain that is simple to use, secure and scalable. The Lotus NEAR Connector makes use of NEAR Lake Framework to parse events in Rust, then passes them to a Lotus connector written in Go using websockets.

Events

As of now, the Lotus NEAR connector indexes:

  • Blocks
  • Transactions
  • Receipts
  • ExecutionOutcomes

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ExecutionOutcome_Outcome_Failure_InvalidTxError_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "INVALID_ACCESS_KEY_ERROR",
		2:  "INVALID_SIGNER_ID",
		3:  "SIGNER_DOES_NOT_EXIST",
		4:  "INVALID_NONCE",
		5:  "NONCE_TOO_LARGE",
		6:  "INVALID_RECEIVER_ID",
		7:  "INVALID_SIGNATURE",
		8:  "NOT_ENOUGH_BALANCE",
		9:  "LACK_BALANCE_FOR_STATE",
		10: "COST_OVERFLOW",
		11: "INVALID_CHAIN",
		12: "EXPIRED",
		13: "ACTIONS_VALIDATION_ERROR",
		14: "TRANSACTION_SIZE_EXCEEDED",
	}
	ExecutionOutcome_Outcome_Failure_InvalidTxError_value = map[string]int32{
		"UNKNOWN":                   0,
		"INVALID_ACCESS_KEY_ERROR":  1,
		"INVALID_SIGNER_ID":         2,
		"SIGNER_DOES_NOT_EXIST":     3,
		"INVALID_NONCE":             4,
		"NONCE_TOO_LARGE":           5,
		"INVALID_RECEIVER_ID":       6,
		"INVALID_SIGNATURE":         7,
		"NOT_ENOUGH_BALANCE":        8,
		"LACK_BALANCE_FOR_STATE":    9,
		"COST_OVERFLOW":             10,
		"INVALID_CHAIN":             11,
		"EXPIRED":                   12,
		"ACTIONS_VALIDATION_ERROR":  13,
		"TRANSACTION_SIZE_EXCEEDED": 14,
	}
)

Enum value maps for ExecutionOutcome_Outcome_Failure_InvalidTxError.

View Source
var (
	ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "ACCOUNT_ALREADY_EXISTS",
		2:  "ACCOUNT_DOES_NOT_EXIST",
		3:  "CREATE_ACCOUNT_ONLY_BY_REGISTRAR",
		4:  "CREATE_ACCOUNT_NOT_ALLOWED",
		5:  "ACTOR_NO_PERMISSION",
		6:  "DELETE_KEY_DOES_NOT_EXIST",
		7:  "ADD_KEY_ALREADY_EXISTS",
		8:  "DELETE_ACCOUNT_STAKING",
		9:  "LACK_BALANCE_FOR_STATE",
		10: "TRIES_TO_UNSTAKE",
		11: "TRIES_TO_STAKE",
		12: "INSUFFICIENT_STAKE",
		13: "FUNCTION_CALL_ERROR",
		14: "NEW_RECEIPT_VALIDATION_ERROR",
		15: "ONLY_IMPLICIT_ACCOUNT_CREATION_ALLOWED",
		16: "DELETE_ACCOUNT_WITH_LARGE_STATE",
	}
	ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind_value = map[string]int32{
		"UNKNOWN":                                0,
		"ACCOUNT_ALREADY_EXISTS":                 1,
		"ACCOUNT_DOES_NOT_EXIST":                 2,
		"CREATE_ACCOUNT_ONLY_BY_REGISTRAR":       3,
		"CREATE_ACCOUNT_NOT_ALLOWED":             4,
		"ACTOR_NO_PERMISSION":                    5,
		"DELETE_KEY_DOES_NOT_EXIST":              6,
		"ADD_KEY_ALREADY_EXISTS":                 7,
		"DELETE_ACCOUNT_STAKING":                 8,
		"LACK_BALANCE_FOR_STATE":                 9,
		"TRIES_TO_UNSTAKE":                       10,
		"TRIES_TO_STAKE":                         11,
		"INSUFFICIENT_STAKE":                     12,
		"FUNCTION_CALL_ERROR":                    13,
		"NEW_RECEIPT_VALIDATION_ERROR":           14,
		"ONLY_IMPLICIT_ACCOUNT_CREATION_ALLOWED": 15,
		"DELETE_ACCOUNT_WITH_LARGE_STATE":        16,
	}
)

Enum value maps for ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind.

View Source
var (
	ExecutionOutcome_MerklePath_Direction_name = map[int32]string{
		0: "INVALID",
		1: "LEFT",
		2: "RIGHT",
	}
	ExecutionOutcome_MerklePath_Direction_value = map[string]int32{
		"INVALID": 0,
		"LEFT":    1,
		"RIGHT":   2,
	}
)

Enum value maps for ExecutionOutcome_MerklePath_Direction.

Functions

This section is empty.

Types

type AccessKey

type AccessKey struct {
	Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// Types that are assignable to Permission:
	//	*AccessKey_FullAccess
	//	*AccessKey_FunctionCall
	Permission isAccessKey_Permission `protobuf_oneof:"permission"`
	// contains filtered or unexported fields
}

func (*AccessKey) Descriptor deprecated

func (*AccessKey) Descriptor() ([]byte, []int)

Deprecated: Use AccessKey.ProtoReflect.Descriptor instead.

func (*AccessKey) GetFullAccess

func (x *AccessKey) GetFullAccess() *AccessKey_FullAccessPermission

func (*AccessKey) GetFunctionCall

func (x *AccessKey) GetFunctionCall() *AccessKey_FunctionCallPermission

func (*AccessKey) GetNonce

func (x *AccessKey) GetNonce() uint64

func (*AccessKey) GetPermission

func (m *AccessKey) GetPermission() isAccessKey_Permission

func (*AccessKey) ProtoMessage

func (*AccessKey) ProtoMessage()

func (*AccessKey) ProtoReflect

func (x *AccessKey) ProtoReflect() protoreflect.Message

func (*AccessKey) Reset

func (x *AccessKey) Reset()

func (*AccessKey) String

func (x *AccessKey) String() string

type AccessKey_FullAccess

type AccessKey_FullAccess struct {
	FullAccess *AccessKey_FullAccessPermission `protobuf:"bytes,2,opt,name=full_access,json=fullAccess,proto3,oneof"`
}

type AccessKey_FullAccessPermission

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

func (*AccessKey_FullAccessPermission) Descriptor deprecated

func (*AccessKey_FullAccessPermission) Descriptor() ([]byte, []int)

Deprecated: Use AccessKey_FullAccessPermission.ProtoReflect.Descriptor instead.

func (*AccessKey_FullAccessPermission) ProtoMessage

func (*AccessKey_FullAccessPermission) ProtoMessage()

func (*AccessKey_FullAccessPermission) ProtoReflect

func (*AccessKey_FullAccessPermission) Reset

func (x *AccessKey_FullAccessPermission) Reset()

func (*AccessKey_FullAccessPermission) String

type AccessKey_FunctionCall

type AccessKey_FunctionCall struct {
	FunctionCall *AccessKey_FunctionCallPermission `protobuf:"bytes,3,opt,name=function_call,json=functionCall,proto3,oneof"`
}

type AccessKey_FunctionCallPermission

type AccessKey_FunctionCallPermission struct {
	Allowance   []byte   `protobuf:"bytes,1,opt,name=allowance,proto3,oneof" json:"allowance,omitempty"` // uint128
	ReceiverId  string   `protobuf:"bytes,2,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
	MethodNames []string `protobuf:"bytes,3,rep,name=method_names,json=methodNames,proto3" json:"method_names,omitempty"`
	// contains filtered or unexported fields
}

func (*AccessKey_FunctionCallPermission) Descriptor deprecated

func (*AccessKey_FunctionCallPermission) Descriptor() ([]byte, []int)

Deprecated: Use AccessKey_FunctionCallPermission.ProtoReflect.Descriptor instead.

func (*AccessKey_FunctionCallPermission) GetAllowance

func (x *AccessKey_FunctionCallPermission) GetAllowance() []byte

func (*AccessKey_FunctionCallPermission) GetMethodNames

func (x *AccessKey_FunctionCallPermission) GetMethodNames() []string

func (*AccessKey_FunctionCallPermission) GetReceiverId

func (x *AccessKey_FunctionCallPermission) GetReceiverId() string

func (*AccessKey_FunctionCallPermission) ProtoMessage

func (*AccessKey_FunctionCallPermission) ProtoMessage()

func (*AccessKey_FunctionCallPermission) ProtoReflect

func (*AccessKey_FunctionCallPermission) Reset

func (*AccessKey_FunctionCallPermission) String

type Action

type Action struct {

	// Types that are assignable to Action:
	//	*Action_CreateAccount_
	//	*Action_DeployContract_
	//	*Action_FunctionCall_
	//	*Action_Transfer_
	//	*Action_Stake_
	//	*Action_AddKey_
	//	*Action_DeleteKey_
	//	*Action_DeleteAccount_
	Action isAction_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated

func (*Action) Descriptor() ([]byte, []int)

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetAction

func (m *Action) GetAction() isAction_Action

func (*Action) GetAddKey

func (x *Action) GetAddKey() *Action_AddKey

func (*Action) GetCreateAccount

func (x *Action) GetCreateAccount() *Action_CreateAccount

func (*Action) GetDeleteAccount

func (x *Action) GetDeleteAccount() *Action_DeleteAccount

func (*Action) GetDeleteKey

func (x *Action) GetDeleteKey() *Action_DeleteKey

func (*Action) GetDeployContract

func (x *Action) GetDeployContract() *Action_DeployContract

func (*Action) GetFunctionCall

func (x *Action) GetFunctionCall() *Action_FunctionCall

func (*Action) GetStake

func (x *Action) GetStake() *Action_Stake

func (*Action) GetTransfer

func (x *Action) GetTransfer() *Action_Transfer

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) ProtoReflect

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset

func (x *Action) Reset()

func (*Action) String

func (x *Action) String() string

type Action_AddKey

type Action_AddKey struct {
	PublicKey string     `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	AccessKey *AccessKey `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_AddKey) Descriptor deprecated

func (*Action_AddKey) Descriptor() ([]byte, []int)

Deprecated: Use Action_AddKey.ProtoReflect.Descriptor instead.

func (*Action_AddKey) GetAccessKey

func (x *Action_AddKey) GetAccessKey() *AccessKey

func (*Action_AddKey) GetPublicKey

func (x *Action_AddKey) GetPublicKey() string

func (*Action_AddKey) ProtoMessage

func (*Action_AddKey) ProtoMessage()

func (*Action_AddKey) ProtoReflect

func (x *Action_AddKey) ProtoReflect() protoreflect.Message

func (*Action_AddKey) Reset

func (x *Action_AddKey) Reset()

func (*Action_AddKey) String

func (x *Action_AddKey) String() string

type Action_AddKey_

type Action_AddKey_ struct {
	AddKey *Action_AddKey `protobuf:"bytes,6,opt,name=add_key,json=addKey,proto3,oneof"`
}

type Action_CreateAccount

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

func (*Action_CreateAccount) Descriptor deprecated

func (*Action_CreateAccount) Descriptor() ([]byte, []int)

Deprecated: Use Action_CreateAccount.ProtoReflect.Descriptor instead.

func (*Action_CreateAccount) ProtoMessage

func (*Action_CreateAccount) ProtoMessage()

func (*Action_CreateAccount) ProtoReflect

func (x *Action_CreateAccount) ProtoReflect() protoreflect.Message

func (*Action_CreateAccount) Reset

func (x *Action_CreateAccount) Reset()

func (*Action_CreateAccount) String

func (x *Action_CreateAccount) String() string

type Action_CreateAccount_

type Action_CreateAccount_ struct {
	CreateAccount *Action_CreateAccount `protobuf:"bytes,1,opt,name=create_account,json=createAccount,proto3,oneof"`
}

type Action_DeleteAccount

type Action_DeleteAccount struct {
	BeneficiaryId string `protobuf:"bytes,1,opt,name=beneficiary_id,json=beneficiaryId,proto3" json:"beneficiary_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_DeleteAccount) Descriptor deprecated

func (*Action_DeleteAccount) Descriptor() ([]byte, []int)

Deprecated: Use Action_DeleteAccount.ProtoReflect.Descriptor instead.

func (*Action_DeleteAccount) GetBeneficiaryId

func (x *Action_DeleteAccount) GetBeneficiaryId() string

func (*Action_DeleteAccount) ProtoMessage

func (*Action_DeleteAccount) ProtoMessage()

func (*Action_DeleteAccount) ProtoReflect

func (x *Action_DeleteAccount) ProtoReflect() protoreflect.Message

func (*Action_DeleteAccount) Reset

func (x *Action_DeleteAccount) Reset()

func (*Action_DeleteAccount) String

func (x *Action_DeleteAccount) String() string

type Action_DeleteAccount_

type Action_DeleteAccount_ struct {
	DeleteAccount *Action_DeleteAccount `protobuf:"bytes,8,opt,name=delete_account,json=deleteAccount,proto3,oneof"`
}

type Action_DeleteKey

type Action_DeleteKey struct {
	PublicKey string `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_DeleteKey) Descriptor deprecated

func (*Action_DeleteKey) Descriptor() ([]byte, []int)

Deprecated: Use Action_DeleteKey.ProtoReflect.Descriptor instead.

func (*Action_DeleteKey) GetPublicKey

func (x *Action_DeleteKey) GetPublicKey() string

func (*Action_DeleteKey) ProtoMessage

func (*Action_DeleteKey) ProtoMessage()

func (*Action_DeleteKey) ProtoReflect

func (x *Action_DeleteKey) ProtoReflect() protoreflect.Message

func (*Action_DeleteKey) Reset

func (x *Action_DeleteKey) Reset()

func (*Action_DeleteKey) String

func (x *Action_DeleteKey) String() string

type Action_DeleteKey_

type Action_DeleteKey_ struct {
	DeleteKey *Action_DeleteKey `protobuf:"bytes,7,opt,name=delete_key,json=deleteKey,proto3,oneof"`
}

type Action_DeployContract

type Action_DeployContract struct {
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_DeployContract) Descriptor deprecated

func (*Action_DeployContract) Descriptor() ([]byte, []int)

Deprecated: Use Action_DeployContract.ProtoReflect.Descriptor instead.

func (*Action_DeployContract) GetCode

func (x *Action_DeployContract) GetCode() string

func (*Action_DeployContract) ProtoMessage

func (*Action_DeployContract) ProtoMessage()

func (*Action_DeployContract) ProtoReflect

func (x *Action_DeployContract) ProtoReflect() protoreflect.Message

func (*Action_DeployContract) Reset

func (x *Action_DeployContract) Reset()

func (*Action_DeployContract) String

func (x *Action_DeployContract) String() string

type Action_DeployContract_

type Action_DeployContract_ struct {
	DeployContract *Action_DeployContract `protobuf:"bytes,2,opt,name=deploy_contract,json=deployContract,proto3,oneof"`
}

type Action_FunctionCall

type Action_FunctionCall struct {
	MethodName string `protobuf:"bytes,1,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	Args       string `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	Gas        uint64 `protobuf:"varint,3,opt,name=gas,proto3" json:"gas,omitempty"`
	Deposit    []byte `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit,omitempty"` // uint128
	// contains filtered or unexported fields
}

func (*Action_FunctionCall) Descriptor deprecated

func (*Action_FunctionCall) Descriptor() ([]byte, []int)

Deprecated: Use Action_FunctionCall.ProtoReflect.Descriptor instead.

func (*Action_FunctionCall) GetArgs

func (x *Action_FunctionCall) GetArgs() string

func (*Action_FunctionCall) GetDeposit

func (x *Action_FunctionCall) GetDeposit() []byte

func (*Action_FunctionCall) GetGas

func (x *Action_FunctionCall) GetGas() uint64

func (*Action_FunctionCall) GetMethodName

func (x *Action_FunctionCall) GetMethodName() string

func (*Action_FunctionCall) ProtoMessage

func (*Action_FunctionCall) ProtoMessage()

func (*Action_FunctionCall) ProtoReflect

func (x *Action_FunctionCall) ProtoReflect() protoreflect.Message

func (*Action_FunctionCall) Reset

func (x *Action_FunctionCall) Reset()

func (*Action_FunctionCall) String

func (x *Action_FunctionCall) String() string

type Action_FunctionCall_

type Action_FunctionCall_ struct {
	FunctionCall *Action_FunctionCall `protobuf:"bytes,3,opt,name=function_call,json=functionCall,proto3,oneof"`
}

type Action_Stake

type Action_Stake struct {
	Stake     []byte `protobuf:"bytes,1,opt,name=stake,proto3" json:"stake,omitempty"` // uint128
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

func (*Action_Stake) Descriptor deprecated

func (*Action_Stake) Descriptor() ([]byte, []int)

Deprecated: Use Action_Stake.ProtoReflect.Descriptor instead.

func (*Action_Stake) GetPublicKey

func (x *Action_Stake) GetPublicKey() string

func (*Action_Stake) GetStake

func (x *Action_Stake) GetStake() []byte

func (*Action_Stake) ProtoMessage

func (*Action_Stake) ProtoMessage()

func (*Action_Stake) ProtoReflect

func (x *Action_Stake) ProtoReflect() protoreflect.Message

func (*Action_Stake) Reset

func (x *Action_Stake) Reset()

func (*Action_Stake) String

func (x *Action_Stake) String() string

type Action_Stake_

type Action_Stake_ struct {
	Stake *Action_Stake `protobuf:"bytes,5,opt,name=stake,proto3,oneof"`
}

type Action_Transfer

type Action_Transfer struct {
	Deposit []byte `protobuf:"bytes,1,opt,name=deposit,proto3" json:"deposit,omitempty"` // uint128
	// contains filtered or unexported fields
}

func (*Action_Transfer) Descriptor deprecated

func (*Action_Transfer) Descriptor() ([]byte, []int)

Deprecated: Use Action_Transfer.ProtoReflect.Descriptor instead.

func (*Action_Transfer) GetDeposit

func (x *Action_Transfer) GetDeposit() []byte

func (*Action_Transfer) ProtoMessage

func (*Action_Transfer) ProtoMessage()

func (*Action_Transfer) ProtoReflect

func (x *Action_Transfer) ProtoReflect() protoreflect.Message

func (*Action_Transfer) Reset

func (x *Action_Transfer) Reset()

func (*Action_Transfer) String

func (x *Action_Transfer) String() string

type Action_Transfer_

type Action_Transfer_ struct {
	Transfer *Action_Transfer `protobuf:"bytes,4,opt,name=transfer,proto3,oneof"`
}

type Block

type Block struct {
	Ts     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Author string                 `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	Header *Block_BlockHeader     `protobuf:"bytes,3,opt,name=header,proto3" json:"header,omitempty"`
	Chunks []*Block_Chunk         `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated

func (*Block) Descriptor() ([]byte, []int)

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetAuthor

func (x *Block) GetAuthor() string

func (*Block) GetChunks

func (x *Block) GetChunks() []*Block_Chunk

func (*Block) GetHeader

func (x *Block) GetHeader() *Block_BlockHeader

func (*Block) GetTs

func (x *Block) GetTs() *timestamppb.Timestamp

func (*Block) ProtoMessage

func (*Block) ProtoMessage()

func (*Block) ProtoReflect

func (x *Block) ProtoReflect() protoreflect.Message

func (*Block) Reset

func (x *Block) Reset()

func (*Block) String

func (x *Block) String() string

type Block_BlockHeader

type Block_BlockHeader struct {
	Height                uint64                                `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	PrevHeight            *uint64                               `protobuf:"varint,2,opt,name=prev_height,json=prevHeight,proto3,oneof" json:"prev_height,omitempty"`
	EpochId               string                                `protobuf:"bytes,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	NextEpochId           string                                `protobuf:"bytes,4,opt,name=next_epoch_id,json=nextEpochId,proto3" json:"next_epoch_id,omitempty"`
	Hash                  string                                `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	PrevHash              string                                `protobuf:"bytes,6,opt,name=prev_hash,json=prevHash,proto3" json:"prev_hash,omitempty"`
	PrevStateRoot         string                                `protobuf:"bytes,7,opt,name=prev_state_root,json=prevStateRoot,proto3" json:"prev_state_root,omitempty"`
	ChunkReceiptsRoot     string                                `protobuf:"bytes,8,opt,name=chunk_receipts_root,json=chunkReceiptsRoot,proto3" json:"chunk_receipts_root,omitempty"`
	ChunkHeadersRoot      string                                `protobuf:"bytes,9,opt,name=chunk_headers_root,json=chunkHeadersRoot,proto3" json:"chunk_headers_root,omitempty"`
	ChunkTxRoot           string                                `protobuf:"bytes,10,opt,name=chunk_tx_root,json=chunkTxRoot,proto3" json:"chunk_tx_root,omitempty"`
	OutcomeRoot           string                                `protobuf:"bytes,11,opt,name=outcome_root,json=outcomeRoot,proto3" json:"outcome_root,omitempty"`
	ChunksIncluded        uint64                                `protobuf:"varint,12,opt,name=chunks_included,json=chunksIncluded,proto3" json:"chunks_included,omitempty"`
	ChallengesRoot        string                                `protobuf:"bytes,13,opt,name=challenges_root,json=challengesRoot,proto3" json:"challenges_root,omitempty"`
	Timestamp             uint64                                `protobuf:"varint,14,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	TimestampNanosec      uint64                                `protobuf:"varint,15,opt,name=timestamp_nanosec,json=timestampNanosec,proto3" json:"timestamp_nanosec,omitempty"`
	RandomValue           string                                `protobuf:"bytes,16,opt,name=random_value,json=randomValue,proto3" json:"random_value,omitempty"`
	ValidatorProposals    []*Block_ValidatorStake               `protobuf:"bytes,17,rep,name=validator_proposals,json=validatorProposals,proto3" json:"validator_proposals,omitempty"`
	ChunkMask             []bool                                `protobuf:"varint,18,rep,packed,name=chunk_mask,json=chunkMask,proto3" json:"chunk_mask,omitempty"`
	GasPrice              []byte                                `protobuf:"bytes,19,opt,name=gas_price,json=gasPrice,proto3" json:"gas_price,omitempty"` // uint128
	BlockOrdinal          *uint64                               `protobuf:"varint,20,opt,name=block_ordinal,json=blockOrdinal,proto3,oneof" json:"block_ordinal,omitempty"`
	TotalSupply           []byte                                `protobuf:"bytes,21,opt,name=total_supply,json=totalSupply,proto3" json:"total_supply,omitempty"` // uint128
	ChallengesResult      []*Block_BlockHeader_SlashedValidator `protobuf:"bytes,22,rep,name=challenges_result,json=challengesResult,proto3" json:"challenges_result,omitempty"`
	LastFinalBlock        string                                `protobuf:"bytes,23,opt,name=last_final_block,json=lastFinalBlock,proto3" json:"last_final_block,omitempty"`
	LastDsFinalBlock      string                                `protobuf:"bytes,24,opt,name=last_ds_final_block,json=lastDsFinalBlock,proto3" json:"last_ds_final_block,omitempty"`
	NextBpHash            string                                `protobuf:"bytes,25,opt,name=next_bp_hash,json=nextBpHash,proto3" json:"next_bp_hash,omitempty"`
	BlockMerkleRoot       string                                `protobuf:"bytes,26,opt,name=block_merkle_root,json=blockMerkleRoot,proto3" json:"block_merkle_root,omitempty"`
	EpochSyncDataHash     *string                               `protobuf:"bytes,27,opt,name=epoch_sync_data_hash,json=epochSyncDataHash,proto3,oneof" json:"epoch_sync_data_hash,omitempty"`
	Approvals             []string                              `protobuf:"bytes,28,rep,name=approvals,proto3" json:"approvals,omitempty"`
	Signature             string                                `protobuf:"bytes,29,opt,name=signature,proto3" json:"signature,omitempty"`
	LatestProtocolVersion uint32                                `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Block_BlockHeader) Descriptor deprecated

func (*Block_BlockHeader) Descriptor() ([]byte, []int)

Deprecated: Use Block_BlockHeader.ProtoReflect.Descriptor instead.

func (*Block_BlockHeader) GetApprovals

func (x *Block_BlockHeader) GetApprovals() []string

func (*Block_BlockHeader) GetBlockMerkleRoot

func (x *Block_BlockHeader) GetBlockMerkleRoot() string

func (*Block_BlockHeader) GetBlockOrdinal

func (x *Block_BlockHeader) GetBlockOrdinal() uint64

func (*Block_BlockHeader) GetChallengesResult

func (x *Block_BlockHeader) GetChallengesResult() []*Block_BlockHeader_SlashedValidator

func (*Block_BlockHeader) GetChallengesRoot

func (x *Block_BlockHeader) GetChallengesRoot() string

func (*Block_BlockHeader) GetChunkHeadersRoot

func (x *Block_BlockHeader) GetChunkHeadersRoot() string

func (*Block_BlockHeader) GetChunkMask

func (x *Block_BlockHeader) GetChunkMask() []bool

func (*Block_BlockHeader) GetChunkReceiptsRoot

func (x *Block_BlockHeader) GetChunkReceiptsRoot() string

func (*Block_BlockHeader) GetChunkTxRoot

func (x *Block_BlockHeader) GetChunkTxRoot() string

func (*Block_BlockHeader) GetChunksIncluded

func (x *Block_BlockHeader) GetChunksIncluded() uint64

func (*Block_BlockHeader) GetEpochId

func (x *Block_BlockHeader) GetEpochId() string

func (*Block_BlockHeader) GetEpochSyncDataHash

func (x *Block_BlockHeader) GetEpochSyncDataHash() string

func (*Block_BlockHeader) GetGasPrice

func (x *Block_BlockHeader) GetGasPrice() []byte

func (*Block_BlockHeader) GetHash

func (x *Block_BlockHeader) GetHash() string

func (*Block_BlockHeader) GetHeight

func (x *Block_BlockHeader) GetHeight() uint64

func (*Block_BlockHeader) GetLastDsFinalBlock

func (x *Block_BlockHeader) GetLastDsFinalBlock() string

func (*Block_BlockHeader) GetLastFinalBlock

func (x *Block_BlockHeader) GetLastFinalBlock() string

func (*Block_BlockHeader) GetLatestProtocolVersion

func (x *Block_BlockHeader) GetLatestProtocolVersion() uint32

func (*Block_BlockHeader) GetNextBpHash

func (x *Block_BlockHeader) GetNextBpHash() string

func (*Block_BlockHeader) GetNextEpochId

func (x *Block_BlockHeader) GetNextEpochId() string

func (*Block_BlockHeader) GetOutcomeRoot

func (x *Block_BlockHeader) GetOutcomeRoot() string

func (*Block_BlockHeader) GetPrevHash

func (x *Block_BlockHeader) GetPrevHash() string

func (*Block_BlockHeader) GetPrevHeight

func (x *Block_BlockHeader) GetPrevHeight() uint64

func (*Block_BlockHeader) GetPrevStateRoot

func (x *Block_BlockHeader) GetPrevStateRoot() string

func (*Block_BlockHeader) GetRandomValue

func (x *Block_BlockHeader) GetRandomValue() string

func (*Block_BlockHeader) GetSignature

func (x *Block_BlockHeader) GetSignature() string

func (*Block_BlockHeader) GetTimestamp

func (x *Block_BlockHeader) GetTimestamp() uint64

func (*Block_BlockHeader) GetTimestampNanosec

func (x *Block_BlockHeader) GetTimestampNanosec() uint64

func (*Block_BlockHeader) GetTotalSupply

func (x *Block_BlockHeader) GetTotalSupply() []byte

func (*Block_BlockHeader) GetValidatorProposals

func (x *Block_BlockHeader) GetValidatorProposals() []*Block_ValidatorStake

func (*Block_BlockHeader) ProtoMessage

func (*Block_BlockHeader) ProtoMessage()

func (*Block_BlockHeader) ProtoReflect

func (x *Block_BlockHeader) ProtoReflect() protoreflect.Message

func (*Block_BlockHeader) Reset

func (x *Block_BlockHeader) Reset()

func (*Block_BlockHeader) String

func (x *Block_BlockHeader) String() string

type Block_BlockHeader_SlashedValidator

type Block_BlockHeader_SlashedValidator struct {
	AccountId    string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	IsDoubleSign bool   `protobuf:"varint,2,opt,name=is_double_sign,json=isDoubleSign,proto3" json:"is_double_sign,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_BlockHeader_SlashedValidator) Descriptor deprecated

func (*Block_BlockHeader_SlashedValidator) Descriptor() ([]byte, []int)

Deprecated: Use Block_BlockHeader_SlashedValidator.ProtoReflect.Descriptor instead.

func (*Block_BlockHeader_SlashedValidator) GetAccountId

func (x *Block_BlockHeader_SlashedValidator) GetAccountId() string

func (*Block_BlockHeader_SlashedValidator) GetIsDoubleSign

func (x *Block_BlockHeader_SlashedValidator) GetIsDoubleSign() bool

func (*Block_BlockHeader_SlashedValidator) ProtoMessage

func (*Block_BlockHeader_SlashedValidator) ProtoMessage()

func (*Block_BlockHeader_SlashedValidator) ProtoReflect

func (*Block_BlockHeader_SlashedValidator) Reset

func (*Block_BlockHeader_SlashedValidator) String

type Block_Chunk

type Block_Chunk struct {
	ChunkHash            string                  `protobuf:"bytes,1,opt,name=chunk_hash,json=chunkHash,proto3" json:"chunk_hash,omitempty"`
	PrevBlockHash        string                  `protobuf:"bytes,2,opt,name=prev_block_hash,json=prevBlockHash,proto3" json:"prev_block_hash,omitempty"`
	OutcomeRoot          string                  `protobuf:"bytes,3,opt,name=outcome_root,json=outcomeRoot,proto3" json:"outcome_root,omitempty"`
	PrevStateRoot        string                  `protobuf:"bytes,4,opt,name=prev_state_root,json=prevStateRoot,proto3" json:"prev_state_root,omitempty"`
	EncodedMerkleRoot    string                  `protobuf:"bytes,5,opt,name=encoded_merkle_root,json=encodedMerkleRoot,proto3" json:"encoded_merkle_root,omitempty"`
	EncodedLength        uint64                  `protobuf:"varint,6,opt,name=encoded_length,json=encodedLength,proto3" json:"encoded_length,omitempty"`
	HeightCreated        uint64                  `protobuf:"varint,7,opt,name=height_created,json=heightCreated,proto3" json:"height_created,omitempty"`
	HeightIncluded       uint64                  `protobuf:"varint,8,opt,name=height_included,json=heightIncluded,proto3" json:"height_included,omitempty"`
	ShardId              uint64                  `protobuf:"varint,9,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	GasUsed              uint64                  `protobuf:"varint,10,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	GasLimit             uint64                  `protobuf:"varint,11,opt,name=gas_limit,json=gasLimit,proto3" json:"gas_limit,omitempty"`
	BalanceBurnt         []byte                  `protobuf:"bytes,12,opt,name=balance_burnt,json=balanceBurnt,proto3" json:"balance_burnt,omitempty"` // uint128
	OutgoingReceiptsRoot string                  `protobuf:"bytes,13,opt,name=outgoing_receipts_root,json=outgoingReceiptsRoot,proto3" json:"outgoing_receipts_root,omitempty"`
	TxRoot               string                  `protobuf:"bytes,14,opt,name=tx_root,json=txRoot,proto3" json:"tx_root,omitempty"`
	ValidatorProposals   []*Block_ValidatorStake `protobuf:"bytes,16,rep,name=validator_proposals,json=validatorProposals,proto3" json:"validator_proposals,omitempty"`
	Signature            string                  `protobuf:"bytes,17,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Block_Chunk) Descriptor deprecated

func (*Block_Chunk) Descriptor() ([]byte, []int)

Deprecated: Use Block_Chunk.ProtoReflect.Descriptor instead.

func (*Block_Chunk) GetBalanceBurnt

func (x *Block_Chunk) GetBalanceBurnt() []byte

func (*Block_Chunk) GetChunkHash

func (x *Block_Chunk) GetChunkHash() string

func (*Block_Chunk) GetEncodedLength

func (x *Block_Chunk) GetEncodedLength() uint64

func (*Block_Chunk) GetEncodedMerkleRoot

func (x *Block_Chunk) GetEncodedMerkleRoot() string

func (*Block_Chunk) GetGasLimit

func (x *Block_Chunk) GetGasLimit() uint64

func (*Block_Chunk) GetGasUsed

func (x *Block_Chunk) GetGasUsed() uint64

func (*Block_Chunk) GetHeightCreated

func (x *Block_Chunk) GetHeightCreated() uint64

func (*Block_Chunk) GetHeightIncluded

func (x *Block_Chunk) GetHeightIncluded() uint64

func (*Block_Chunk) GetOutcomeRoot

func (x *Block_Chunk) GetOutcomeRoot() string

func (*Block_Chunk) GetOutgoingReceiptsRoot

func (x *Block_Chunk) GetOutgoingReceiptsRoot() string

func (*Block_Chunk) GetPrevBlockHash

func (x *Block_Chunk) GetPrevBlockHash() string

func (*Block_Chunk) GetPrevStateRoot

func (x *Block_Chunk) GetPrevStateRoot() string

func (*Block_Chunk) GetShardId

func (x *Block_Chunk) GetShardId() uint64

func (*Block_Chunk) GetSignature

func (x *Block_Chunk) GetSignature() string

func (*Block_Chunk) GetTxRoot

func (x *Block_Chunk) GetTxRoot() string

func (*Block_Chunk) GetValidatorProposals

func (x *Block_Chunk) GetValidatorProposals() []*Block_ValidatorStake

func (*Block_Chunk) ProtoMessage

func (*Block_Chunk) ProtoMessage()

func (*Block_Chunk) ProtoReflect

func (x *Block_Chunk) ProtoReflect() protoreflect.Message

func (*Block_Chunk) Reset

func (x *Block_Chunk) Reset()

func (*Block_Chunk) String

func (x *Block_Chunk) String() string

type Block_ValidatorStake

type Block_ValidatorStake struct {
	AccountId string `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	PublicKey string `protobuf:"bytes,2,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Stake     []byte `protobuf:"bytes,3,opt,name=stake,proto3" json:"stake,omitempty"` // uint128
	// contains filtered or unexported fields
}

func (*Block_ValidatorStake) Descriptor deprecated

func (*Block_ValidatorStake) Descriptor() ([]byte, []int)

Deprecated: Use Block_ValidatorStake.ProtoReflect.Descriptor instead.

func (*Block_ValidatorStake) GetAccountId

func (x *Block_ValidatorStake) GetAccountId() string

func (*Block_ValidatorStake) GetPublicKey

func (x *Block_ValidatorStake) GetPublicKey() string

func (*Block_ValidatorStake) GetStake

func (x *Block_ValidatorStake) GetStake() []byte

func (*Block_ValidatorStake) ProtoMessage

func (*Block_ValidatorStake) ProtoMessage()

func (*Block_ValidatorStake) ProtoReflect

func (x *Block_ValidatorStake) ProtoReflect() protoreflect.Message

func (*Block_ValidatorStake) Reset

func (x *Block_ValidatorStake) Reset()

func (*Block_ValidatorStake) String

func (x *Block_ValidatorStake) String() string

type Config

type Config struct {
	FromBlock    uint64
	NumBlocks    uint64
	Hostname     string
	Port         string
	BackfillPort string
	MaxRetries   int
	FctMsgTypes  []proto.Message
	BfMsgTypes   []proto.Message
	ChannelSize  int
}

type Connector

type Connector struct {
	*connector.Connector
	*Config
}

func New

func New(c *connector.Connector, config *Config) *Connector

func (*Connector) Start

func (c *Connector) Start()

type ExecutionOutcome

type ExecutionOutcome struct {
	Ts        *timestamppb.Timestamp         `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	Id        string                         `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	BlockHash string                         `protobuf:"bytes,3,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	Outcome   *ExecutionOutcome_Outcome      `protobuf:"bytes,4,opt,name=outcome,proto3" json:"outcome,omitempty"`
	Proof     []*ExecutionOutcome_MerklePath `protobuf:"bytes,5,rep,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionOutcome) Descriptor deprecated

func (*ExecutionOutcome) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome) GetBlockHash

func (x *ExecutionOutcome) GetBlockHash() string

func (*ExecutionOutcome) GetId

func (x *ExecutionOutcome) GetId() string

func (*ExecutionOutcome) GetOutcome

func (x *ExecutionOutcome) GetOutcome() *ExecutionOutcome_Outcome

func (*ExecutionOutcome) GetProof

func (*ExecutionOutcome) GetTs

func (*ExecutionOutcome) ProtoMessage

func (*ExecutionOutcome) ProtoMessage()

func (*ExecutionOutcome) ProtoReflect

func (x *ExecutionOutcome) ProtoReflect() protoreflect.Message

func (*ExecutionOutcome) Reset

func (x *ExecutionOutcome) Reset()

func (*ExecutionOutcome) String

func (x *ExecutionOutcome) String() string

type ExecutionOutcome_MerklePath

type ExecutionOutcome_MerklePath struct {
	Hash      string                                `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Direction ExecutionOutcome_MerklePath_Direction `protobuf:"varint,2,opt,name=direction,proto3,enum=near.ExecutionOutcome_MerklePath_Direction" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_MerklePath) Descriptor deprecated

func (*ExecutionOutcome_MerklePath) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_MerklePath.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_MerklePath) GetDirection

func (*ExecutionOutcome_MerklePath) GetHash

func (x *ExecutionOutcome_MerklePath) GetHash() string

func (*ExecutionOutcome_MerklePath) ProtoMessage

func (*ExecutionOutcome_MerklePath) ProtoMessage()

func (*ExecutionOutcome_MerklePath) ProtoReflect

func (*ExecutionOutcome_MerklePath) Reset

func (x *ExecutionOutcome_MerklePath) Reset()

func (*ExecutionOutcome_MerklePath) String

func (x *ExecutionOutcome_MerklePath) String() string

type ExecutionOutcome_MerklePath_Direction

type ExecutionOutcome_MerklePath_Direction int32
const (
	ExecutionOutcome_MerklePath_INVALID ExecutionOutcome_MerklePath_Direction = 0
	ExecutionOutcome_MerklePath_LEFT    ExecutionOutcome_MerklePath_Direction = 1
	ExecutionOutcome_MerklePath_RIGHT   ExecutionOutcome_MerklePath_Direction = 2
)

func (ExecutionOutcome_MerklePath_Direction) Descriptor

func (ExecutionOutcome_MerklePath_Direction) Enum

func (ExecutionOutcome_MerklePath_Direction) EnumDescriptor deprecated

func (ExecutionOutcome_MerklePath_Direction) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_MerklePath_Direction.Descriptor instead.

func (ExecutionOutcome_MerklePath_Direction) Number

func (ExecutionOutcome_MerklePath_Direction) String

func (ExecutionOutcome_MerklePath_Direction) Type

type ExecutionOutcome_Outcome

type ExecutionOutcome_Outcome struct {
	ExecutorId string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	// Types that are assignable to Status:
	//	*ExecutionOutcome_Outcome_Unknown_
	//	*ExecutionOutcome_Outcome_Failure_
	//	*ExecutionOutcome_Outcome_SuccessValue_
	//	*ExecutionOutcome_Outcome_SuccessReceiptId_
	Status      isExecutionOutcome_Outcome_Status `protobuf_oneof:"status"`
	Logs        []string                          `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	ReceiptIds  []string                          `protobuf:"bytes,7,rep,name=receipt_ids,json=receiptIds,proto3" json:"receipt_ids,omitempty"`
	GasBurnt    []byte                            `protobuf:"bytes,8,opt,name=gas_burnt,json=gasBurnt,proto3" json:"gas_burnt,omitempty"`          // uint128
	TokensBurnt []byte                            `protobuf:"bytes,9,opt,name=tokens_burnt,json=tokensBurnt,proto3" json:"tokens_burnt,omitempty"` // uint128
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_Outcome) Descriptor deprecated

func (*ExecutionOutcome_Outcome) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_Outcome.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome) GetExecutorId

func (x *ExecutionOutcome_Outcome) GetExecutorId() string

func (*ExecutionOutcome_Outcome) GetFailure

func (*ExecutionOutcome_Outcome) GetGasBurnt

func (x *ExecutionOutcome_Outcome) GetGasBurnt() []byte

func (*ExecutionOutcome_Outcome) GetLogs

func (x *ExecutionOutcome_Outcome) GetLogs() []string

func (*ExecutionOutcome_Outcome) GetReceiptIds

func (x *ExecutionOutcome_Outcome) GetReceiptIds() []string

func (*ExecutionOutcome_Outcome) GetStatus

func (m *ExecutionOutcome_Outcome) GetStatus() isExecutionOutcome_Outcome_Status

func (*ExecutionOutcome_Outcome) GetSuccessReceiptId

func (*ExecutionOutcome_Outcome) GetSuccessValue

func (*ExecutionOutcome_Outcome) GetTokensBurnt

func (x *ExecutionOutcome_Outcome) GetTokensBurnt() []byte

func (*ExecutionOutcome_Outcome) GetUnknown

func (*ExecutionOutcome_Outcome) ProtoMessage

func (*ExecutionOutcome_Outcome) ProtoMessage()

func (*ExecutionOutcome_Outcome) ProtoReflect

func (x *ExecutionOutcome_Outcome) ProtoReflect() protoreflect.Message

func (*ExecutionOutcome_Outcome) Reset

func (x *ExecutionOutcome_Outcome) Reset()

func (*ExecutionOutcome_Outcome) String

func (x *ExecutionOutcome_Outcome) String() string

type ExecutionOutcome_Outcome_Failure

type ExecutionOutcome_Outcome_Failure struct {

	// Types that are assignable to Error:
	//	*ExecutionOutcome_Outcome_Failure_ActionError_
	//	*ExecutionOutcome_Outcome_Failure_InvalidTxError_
	Error isExecutionOutcome_Outcome_Failure_Error `protobuf_oneof:"error"`
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_Outcome_Failure) Descriptor deprecated

func (*ExecutionOutcome_Outcome_Failure) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_Outcome_Failure.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome_Failure) GetActionError

func (*ExecutionOutcome_Outcome_Failure) GetError

func (m *ExecutionOutcome_Outcome_Failure) GetError() isExecutionOutcome_Outcome_Failure_Error

func (*ExecutionOutcome_Outcome_Failure) GetInvalidTxError

func (*ExecutionOutcome_Outcome_Failure) ProtoMessage

func (*ExecutionOutcome_Outcome_Failure) ProtoMessage()

func (*ExecutionOutcome_Outcome_Failure) ProtoReflect

func (*ExecutionOutcome_Outcome_Failure) Reset

func (*ExecutionOutcome_Outcome_Failure) String

type ExecutionOutcome_Outcome_Failure_

type ExecutionOutcome_Outcome_Failure_ struct {
	Failure *ExecutionOutcome_Outcome_Failure `protobuf:"bytes,3,opt,name=failure,proto3,oneof"`
}

type ExecutionOutcome_Outcome_Failure_ActionError

type ExecutionOutcome_Outcome_Failure_ActionError struct {
	Index *uint64                                                      `protobuf:"varint,1,opt,name=index,proto3,oneof" json:"index,omitempty"`
	Kind  ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_Outcome_Failure_ActionError) Descriptor deprecated

Deprecated: Use ExecutionOutcome_Outcome_Failure_ActionError.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome_Failure_ActionError) GetIndex

func (*ExecutionOutcome_Outcome_Failure_ActionError) GetKind

func (*ExecutionOutcome_Outcome_Failure_ActionError) ProtoMessage

func (*ExecutionOutcome_Outcome_Failure_ActionError) ProtoReflect

func (*ExecutionOutcome_Outcome_Failure_ActionError) Reset

func (*ExecutionOutcome_Outcome_Failure_ActionError) String

type ExecutionOutcome_Outcome_Failure_ActionError_

type ExecutionOutcome_Outcome_Failure_ActionError_ struct {
	ActionError *ExecutionOutcome_Outcome_Failure_ActionError `protobuf:"bytes,1,opt,name=action_error,json=actionError,proto3,oneof"`
}

type ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind

type ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind int32
const (
	ExecutionOutcome_Outcome_Failure_ActionError_UNKNOWN                                ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 0
	ExecutionOutcome_Outcome_Failure_ActionError_ACCOUNT_ALREADY_EXISTS                 ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 1
	ExecutionOutcome_Outcome_Failure_ActionError_ACCOUNT_DOES_NOT_EXIST                 ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 2
	ExecutionOutcome_Outcome_Failure_ActionError_CREATE_ACCOUNT_ONLY_BY_REGISTRAR       ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 3
	ExecutionOutcome_Outcome_Failure_ActionError_CREATE_ACCOUNT_NOT_ALLOWED             ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 4
	ExecutionOutcome_Outcome_Failure_ActionError_ACTOR_NO_PERMISSION                    ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 5
	ExecutionOutcome_Outcome_Failure_ActionError_DELETE_KEY_DOES_NOT_EXIST              ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 6
	ExecutionOutcome_Outcome_Failure_ActionError_ADD_KEY_ALREADY_EXISTS                 ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 7
	ExecutionOutcome_Outcome_Failure_ActionError_DELETE_ACCOUNT_STAKING                 ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 8
	ExecutionOutcome_Outcome_Failure_ActionError_LACK_BALANCE_FOR_STATE                 ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 9
	ExecutionOutcome_Outcome_Failure_ActionError_TRIES_TO_UNSTAKE                       ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 10
	ExecutionOutcome_Outcome_Failure_ActionError_TRIES_TO_STAKE                         ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 11
	ExecutionOutcome_Outcome_Failure_ActionError_INSUFFICIENT_STAKE                     ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 12
	ExecutionOutcome_Outcome_Failure_ActionError_FUNCTION_CALL_ERROR                    ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 13
	ExecutionOutcome_Outcome_Failure_ActionError_NEW_RECEIPT_VALIDATION_ERROR           ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 14
	ExecutionOutcome_Outcome_Failure_ActionError_ONLY_IMPLICIT_ACCOUNT_CREATION_ALLOWED ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 15
	ExecutionOutcome_Outcome_Failure_ActionError_DELETE_ACCOUNT_WITH_LARGE_STATE        ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind = 16
)

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) Descriptor

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) Enum

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) EnumDescriptor deprecated

Deprecated: Use ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind.Descriptor instead.

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) Number

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) String

func (ExecutionOutcome_Outcome_Failure_ActionError_ActionErrorKind) Type

type ExecutionOutcome_Outcome_Failure_InvalidTxError

type ExecutionOutcome_Outcome_Failure_InvalidTxError int32
const (
	ExecutionOutcome_Outcome_Failure_UNKNOWN                   ExecutionOutcome_Outcome_Failure_InvalidTxError = 0
	ExecutionOutcome_Outcome_Failure_INVALID_ACCESS_KEY_ERROR  ExecutionOutcome_Outcome_Failure_InvalidTxError = 1
	ExecutionOutcome_Outcome_Failure_INVALID_SIGNER_ID         ExecutionOutcome_Outcome_Failure_InvalidTxError = 2
	ExecutionOutcome_Outcome_Failure_SIGNER_DOES_NOT_EXIST     ExecutionOutcome_Outcome_Failure_InvalidTxError = 3
	ExecutionOutcome_Outcome_Failure_INVALID_NONCE             ExecutionOutcome_Outcome_Failure_InvalidTxError = 4
	ExecutionOutcome_Outcome_Failure_NONCE_TOO_LARGE           ExecutionOutcome_Outcome_Failure_InvalidTxError = 5
	ExecutionOutcome_Outcome_Failure_INVALID_RECEIVER_ID       ExecutionOutcome_Outcome_Failure_InvalidTxError = 6
	ExecutionOutcome_Outcome_Failure_INVALID_SIGNATURE         ExecutionOutcome_Outcome_Failure_InvalidTxError = 7
	ExecutionOutcome_Outcome_Failure_NOT_ENOUGH_BALANCE        ExecutionOutcome_Outcome_Failure_InvalidTxError = 8
	ExecutionOutcome_Outcome_Failure_LACK_BALANCE_FOR_STATE    ExecutionOutcome_Outcome_Failure_InvalidTxError = 9
	ExecutionOutcome_Outcome_Failure_COST_OVERFLOW             ExecutionOutcome_Outcome_Failure_InvalidTxError = 10
	ExecutionOutcome_Outcome_Failure_INVALID_CHAIN             ExecutionOutcome_Outcome_Failure_InvalidTxError = 11
	ExecutionOutcome_Outcome_Failure_EXPIRED                   ExecutionOutcome_Outcome_Failure_InvalidTxError = 12
	ExecutionOutcome_Outcome_Failure_ACTIONS_VALIDATION_ERROR  ExecutionOutcome_Outcome_Failure_InvalidTxError = 13
	ExecutionOutcome_Outcome_Failure_TRANSACTION_SIZE_EXCEEDED ExecutionOutcome_Outcome_Failure_InvalidTxError = 14
)

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) Descriptor

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) Enum

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) EnumDescriptor deprecated

Deprecated: Use ExecutionOutcome_Outcome_Failure_InvalidTxError.Descriptor instead.

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) Number

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) String

func (ExecutionOutcome_Outcome_Failure_InvalidTxError) Type

type ExecutionOutcome_Outcome_Failure_InvalidTxError_

type ExecutionOutcome_Outcome_Failure_InvalidTxError_ struct {
	InvalidTxError ExecutionOutcome_Outcome_Failure_InvalidTxError `` /* 136-byte string literal not displayed */
}

type ExecutionOutcome_Outcome_SuccessReceiptId

type ExecutionOutcome_Outcome_SuccessReceiptId struct {
	ReceiptId string `protobuf:"bytes,1,opt,name=receipt_id,json=receiptId,proto3" json:"receipt_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_Outcome_SuccessReceiptId) Descriptor deprecated

func (*ExecutionOutcome_Outcome_SuccessReceiptId) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_Outcome_SuccessReceiptId.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome_SuccessReceiptId) GetReceiptId

func (*ExecutionOutcome_Outcome_SuccessReceiptId) ProtoMessage

func (*ExecutionOutcome_Outcome_SuccessReceiptId) ProtoReflect

func (*ExecutionOutcome_Outcome_SuccessReceiptId) Reset

func (*ExecutionOutcome_Outcome_SuccessReceiptId) String

type ExecutionOutcome_Outcome_SuccessReceiptId_

type ExecutionOutcome_Outcome_SuccessReceiptId_ struct {
	SuccessReceiptId *ExecutionOutcome_Outcome_SuccessReceiptId `protobuf:"bytes,5,opt,name=success_receipt_id,json=successReceiptId,proto3,oneof"`
}

type ExecutionOutcome_Outcome_SuccessValue

type ExecutionOutcome_Outcome_SuccessValue struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionOutcome_Outcome_SuccessValue) Descriptor deprecated

func (*ExecutionOutcome_Outcome_SuccessValue) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_Outcome_SuccessValue.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome_SuccessValue) GetValue

func (*ExecutionOutcome_Outcome_SuccessValue) ProtoMessage

func (*ExecutionOutcome_Outcome_SuccessValue) ProtoMessage()

func (*ExecutionOutcome_Outcome_SuccessValue) ProtoReflect

func (*ExecutionOutcome_Outcome_SuccessValue) Reset

func (*ExecutionOutcome_Outcome_SuccessValue) String

type ExecutionOutcome_Outcome_SuccessValue_

type ExecutionOutcome_Outcome_SuccessValue_ struct {
	SuccessValue *ExecutionOutcome_Outcome_SuccessValue `protobuf:"bytes,4,opt,name=success_value,json=successValue,proto3,oneof"`
}

type ExecutionOutcome_Outcome_Unknown

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

func (*ExecutionOutcome_Outcome_Unknown) Descriptor deprecated

func (*ExecutionOutcome_Outcome_Unknown) Descriptor() ([]byte, []int)

Deprecated: Use ExecutionOutcome_Outcome_Unknown.ProtoReflect.Descriptor instead.

func (*ExecutionOutcome_Outcome_Unknown) ProtoMessage

func (*ExecutionOutcome_Outcome_Unknown) ProtoMessage()

func (*ExecutionOutcome_Outcome_Unknown) ProtoReflect

func (*ExecutionOutcome_Outcome_Unknown) Reset

func (*ExecutionOutcome_Outcome_Unknown) String

type ExecutionOutcome_Outcome_Unknown_

type ExecutionOutcome_Outcome_Unknown_ struct {
	Unknown *ExecutionOutcome_Outcome_Unknown `protobuf:"bytes,2,opt,name=unknown,proto3,oneof"`
}

type Receipt

type Receipt struct {
	Ts            *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	PredecessorId string                 `protobuf:"bytes,2,opt,name=predecessor_id,json=predecessorId,proto3" json:"predecessor_id,omitempty"`
	ReceiverId    string                 `protobuf:"bytes,3,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
	ReceiptId     string                 `protobuf:"bytes,4,opt,name=receipt_id,json=receiptId,proto3" json:"receipt_id,omitempty"`
	// Types that are assignable to Receipt:
	//	*Receipt_ActionReceipt_
	//	*Receipt_DataReceipt_
	Receipt isReceipt_Receipt `protobuf_oneof:"receipt"`
	// contains filtered or unexported fields
}

func (*Receipt) Descriptor deprecated

func (*Receipt) Descriptor() ([]byte, []int)

Deprecated: Use Receipt.ProtoReflect.Descriptor instead.

func (*Receipt) GetActionReceipt

func (x *Receipt) GetActionReceipt() *Receipt_ActionReceipt

func (*Receipt) GetDataReceipt

func (x *Receipt) GetDataReceipt() *Receipt_DataReceipt

func (*Receipt) GetPredecessorId

func (x *Receipt) GetPredecessorId() string

func (*Receipt) GetReceipt

func (m *Receipt) GetReceipt() isReceipt_Receipt

func (*Receipt) GetReceiptId

func (x *Receipt) GetReceiptId() string

func (*Receipt) GetReceiverId

func (x *Receipt) GetReceiverId() string

func (*Receipt) GetTs

func (x *Receipt) GetTs() *timestamppb.Timestamp

func (*Receipt) ProtoMessage

func (*Receipt) ProtoMessage()

func (*Receipt) ProtoReflect

func (x *Receipt) ProtoReflect() protoreflect.Message

func (*Receipt) Reset

func (x *Receipt) Reset()

func (*Receipt) String

func (x *Receipt) String() string

type Receipt_ActionReceipt

type Receipt_ActionReceipt struct {
	SignerId            string                                `protobuf:"bytes,1,opt,name=signer_id,json=signerId,proto3" json:"signer_id,omitempty"`
	SignerPublicKey     string                                `protobuf:"bytes,2,opt,name=signer_public_key,json=signerPublicKey,proto3" json:"signer_public_key,omitempty"`
	GasPrice            []byte                                `protobuf:"bytes,3,opt,name=gas_price,json=gasPrice,proto3" json:"gas_price,omitempty"` // uint128
	OutputDataReceivers []*Receipt_ActionReceipt_DataReceiver `protobuf:"bytes,4,rep,name=output_data_receivers,json=outputDataReceivers,proto3" json:"output_data_receivers,omitempty"`
	InputDataIds        []string                              `protobuf:"bytes,5,rep,name=input_data_ids,json=inputDataIds,proto3" json:"input_data_ids,omitempty"`
	Actions             []*Action                             `protobuf:"bytes,6,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*Receipt_ActionReceipt) Descriptor deprecated

func (*Receipt_ActionReceipt) Descriptor() ([]byte, []int)

Deprecated: Use Receipt_ActionReceipt.ProtoReflect.Descriptor instead.

func (*Receipt_ActionReceipt) GetActions

func (x *Receipt_ActionReceipt) GetActions() []*Action

func (*Receipt_ActionReceipt) GetGasPrice

func (x *Receipt_ActionReceipt) GetGasPrice() []byte

func (*Receipt_ActionReceipt) GetInputDataIds

func (x *Receipt_ActionReceipt) GetInputDataIds() []string

func (*Receipt_ActionReceipt) GetOutputDataReceivers

func (x *Receipt_ActionReceipt) GetOutputDataReceivers() []*Receipt_ActionReceipt_DataReceiver

func (*Receipt_ActionReceipt) GetSignerId

func (x *Receipt_ActionReceipt) GetSignerId() string

func (*Receipt_ActionReceipt) GetSignerPublicKey

func (x *Receipt_ActionReceipt) GetSignerPublicKey() string

func (*Receipt_ActionReceipt) ProtoMessage

func (*Receipt_ActionReceipt) ProtoMessage()

func (*Receipt_ActionReceipt) ProtoReflect

func (x *Receipt_ActionReceipt) ProtoReflect() protoreflect.Message

func (*Receipt_ActionReceipt) Reset

func (x *Receipt_ActionReceipt) Reset()

func (*Receipt_ActionReceipt) String

func (x *Receipt_ActionReceipt) String() string

type Receipt_ActionReceipt_

type Receipt_ActionReceipt_ struct {
	ActionReceipt *Receipt_ActionReceipt `protobuf:"bytes,5,opt,name=action_receipt,json=actionReceipt,proto3,oneof"`
}

type Receipt_ActionReceipt_DataReceiver

type Receipt_ActionReceipt_DataReceiver struct {
	DataId     string `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	ReceiverId string `protobuf:"bytes,2,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Receipt_ActionReceipt_DataReceiver) Descriptor deprecated

func (*Receipt_ActionReceipt_DataReceiver) Descriptor() ([]byte, []int)

Deprecated: Use Receipt_ActionReceipt_DataReceiver.ProtoReflect.Descriptor instead.

func (*Receipt_ActionReceipt_DataReceiver) GetDataId

func (*Receipt_ActionReceipt_DataReceiver) GetReceiverId

func (x *Receipt_ActionReceipt_DataReceiver) GetReceiverId() string

func (*Receipt_ActionReceipt_DataReceiver) ProtoMessage

func (*Receipt_ActionReceipt_DataReceiver) ProtoMessage()

func (*Receipt_ActionReceipt_DataReceiver) ProtoReflect

func (*Receipt_ActionReceipt_DataReceiver) Reset

func (*Receipt_ActionReceipt_DataReceiver) String

type Receipt_DataReceipt

type Receipt_DataReceipt struct {
	DataId string `protobuf:"bytes,1,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Receipt_DataReceipt) Descriptor deprecated

func (*Receipt_DataReceipt) Descriptor() ([]byte, []int)

Deprecated: Use Receipt_DataReceipt.ProtoReflect.Descriptor instead.

func (*Receipt_DataReceipt) GetData

func (x *Receipt_DataReceipt) GetData() []byte

func (*Receipt_DataReceipt) GetDataId

func (x *Receipt_DataReceipt) GetDataId() string

func (*Receipt_DataReceipt) ProtoMessage

func (*Receipt_DataReceipt) ProtoMessage()

func (*Receipt_DataReceipt) ProtoReflect

func (x *Receipt_DataReceipt) ProtoReflect() protoreflect.Message

func (*Receipt_DataReceipt) Reset

func (x *Receipt_DataReceipt) Reset()

func (*Receipt_DataReceipt) String

func (x *Receipt_DataReceipt) String() string

type Receipt_DataReceipt_

type Receipt_DataReceipt_ struct {
	DataReceipt *Receipt_DataReceipt `protobuf:"bytes,6,opt,name=data_receipt,json=dataReceipt,proto3,oneof"`
}

type Subscription

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

func NewSubscription

func NewSubscription(ctx context.Context, config *Config, events []string) (*Subscription, error)

func (*Subscription) Blocks

func (s *Subscription) Blocks() <-chan *kafkautils.Message

func (*Subscription) Done

func (s *Subscription) Done() <-chan struct{}

func (*Subscription) Err

func (s *Subscription) Err() <-chan error

func (*Subscription) ExecutionOutcomes

func (s *Subscription) ExecutionOutcomes() <-chan *kafkautils.Message

func (*Subscription) Receipts

func (s *Subscription) Receipts() <-chan *kafkautils.Message

func (*Subscription) Transactions

func (s *Subscription) Transactions() <-chan *kafkautils.Message

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe()

type Transaction

type Transaction struct {
	Ts         *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	SignerId   string                 `protobuf:"bytes,2,opt,name=signer_id,json=signerId,proto3" json:"signer_id,omitempty"`
	PublicKey  string                 `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Nonce      uint64                 `protobuf:"varint,4,opt,name=nonce,proto3" json:"nonce,omitempty"`
	ReceiverId string                 `protobuf:"bytes,5,opt,name=receiver_id,json=receiverId,proto3" json:"receiver_id,omitempty"`
	Hash       string                 `protobuf:"bytes,6,opt,name=hash,proto3" json:"hash,omitempty"`
	Actions    []*Action              `protobuf:"bytes,7,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*Transaction) Descriptor deprecated

func (*Transaction) Descriptor() ([]byte, []int)

Deprecated: Use Transaction.ProtoReflect.Descriptor instead.

func (*Transaction) GetActions

func (x *Transaction) GetActions() []*Action

func (*Transaction) GetHash

func (x *Transaction) GetHash() string

func (*Transaction) GetNonce

func (x *Transaction) GetNonce() uint64

func (*Transaction) GetPublicKey

func (x *Transaction) GetPublicKey() string

func (*Transaction) GetReceiverId

func (x *Transaction) GetReceiverId() string

func (*Transaction) GetSignerId

func (x *Transaction) GetSignerId() string

func (*Transaction) GetTs

func (x *Transaction) GetTs() *timestamppb.Timestamp

func (*Transaction) ProtoMessage

func (*Transaction) ProtoMessage()

func (*Transaction) ProtoReflect

func (x *Transaction) ProtoReflect() protoreflect.Message

func (*Transaction) Reset

func (x *Transaction) Reset()

func (*Transaction) String

func (x *Transaction) String() string

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL