dps

package
v1.3.4-0...-e9e0f57 Latest Latest
Warning

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

Go to latest
Published: Aug 31, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFirst",
			Handler:    _API_GetFirst_Handler,
		},
		{
			MethodName: "GetLast",
			Handler:    _API_GetLast_Handler,
		},
		{
			MethodName: "GetHeightForBlock",
			Handler:    _API_GetHeightForBlock_Handler,
		},
		{
			MethodName: "GetCommit",
			Handler:    _API_GetCommit_Handler,
		},
		{
			MethodName: "GetHeader",
			Handler:    _API_GetHeader_Handler,
		},
		{
			MethodName: "GetEvents",
			Handler:    _API_GetEvents_Handler,
		},
		{
			MethodName: "GetRegisterValues",
			Handler:    _API_GetRegisterValues_Handler,
		},
		{
			MethodName: "GetCollection",
			Handler:    _API_GetCollection_Handler,
		},
		{
			MethodName: "ListCollectionsForHeight",
			Handler:    _API_ListCollectionsForHeight_Handler,
		},
		{
			MethodName: "GetGuarantee",
			Handler:    _API_GetGuarantee_Handler,
		},
		{
			MethodName: "GetTransaction",
			Handler:    _API_GetTransaction_Handler,
		},
		{
			MethodName: "GetHeightForTransaction",
			Handler:    _API_GetHeightForTransaction_Handler,
		},
		{
			MethodName: "ListTransactionsForHeight",
			Handler:    _API_ListTransactionsForHeight_Handler,
		},
		{
			MethodName: "GetResult",
			Handler:    _API_GetResult_Handler,
		},
		{
			MethodName: "GetSeal",
			Handler:    _API_GetSeal_Handler,
		},
		{
			MethodName: "ListSealsForHeight",
			Handler:    _API_ListSealsForHeight_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAPIServer

func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

Types

type APIClient

type APIClient interface {
	GetFirst(ctx context.Context, in *GetFirstRequest, opts ...grpc.CallOption) (*GetFirstResponse, error)
	GetLast(ctx context.Context, in *GetLastRequest, opts ...grpc.CallOption) (*GetLastResponse, error)
	GetHeightForBlock(ctx context.Context, in *GetHeightForBlockRequest, opts ...grpc.CallOption) (*GetHeightForBlockResponse, error)
	GetCommit(ctx context.Context, in *GetCommitRequest, opts ...grpc.CallOption) (*GetCommitResponse, error)
	GetHeader(ctx context.Context, in *GetHeaderRequest, opts ...grpc.CallOption) (*GetHeaderResponse, error)
	GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (*GetEventsResponse, error)
	GetRegisterValues(ctx context.Context, in *GetRegisterValuesRequest, opts ...grpc.CallOption) (*GetRegisterValuesResponse, error)
	GetCollection(ctx context.Context, in *GetCollectionRequest, opts ...grpc.CallOption) (*GetCollectionResponse, error)
	ListCollectionsForHeight(ctx context.Context, in *ListCollectionsForHeightRequest, opts ...grpc.CallOption) (*ListCollectionsForHeightResponse, error)
	GetGuarantee(ctx context.Context, in *GetGuaranteeRequest, opts ...grpc.CallOption) (*GetGuaranteeResponse, error)
	GetTransaction(ctx context.Context, in *GetTransactionRequest, opts ...grpc.CallOption) (*GetTransactionResponse, error)
	GetHeightForTransaction(ctx context.Context, in *GetHeightForTransactionRequest, opts ...grpc.CallOption) (*GetHeightForTransactionResponse, error)
	ListTransactionsForHeight(ctx context.Context, in *ListTransactionsForHeightRequest, opts ...grpc.CallOption) (*ListTransactionsForHeightResponse, error)
	GetResult(ctx context.Context, in *GetResultRequest, opts ...grpc.CallOption) (*GetResultResponse, error)
	GetSeal(ctx context.Context, in *GetSealRequest, opts ...grpc.CallOption) (*GetSealResponse, error)
	ListSealsForHeight(ctx context.Context, in *ListSealsForHeightRequest, opts ...grpc.CallOption) (*ListSealsForHeightResponse, error)
}

APIClient is the client API for API service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAPIClient

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer

APIServer is the server API for API service. All implementations should embed UnimplementedAPIServer for forward compatibility

type GetCollectionRequest

type GetCollectionRequest struct {
	CollectionID []byte `protobuf:"bytes,1,opt,name=collectionID,proto3" json:"collectionID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetCollectionRequest) Descriptor deprecated

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

Deprecated: Use GetCollectionRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionRequest) GetCollectionID

func (x *GetCollectionRequest) GetCollectionID() []byte

func (*GetCollectionRequest) ProtoMessage

func (*GetCollectionRequest) ProtoMessage()

func (*GetCollectionRequest) ProtoReflect

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

func (*GetCollectionRequest) Reset

func (x *GetCollectionRequest) Reset()

func (*GetCollectionRequest) String

func (x *GetCollectionRequest) String() string

type GetCollectionResponse

type GetCollectionResponse struct {
	CollectionID []byte `protobuf:"bytes,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Data         []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCollectionResponse) Descriptor deprecated

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

Deprecated: Use GetCollectionResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionResponse) GetCollectionID

func (x *GetCollectionResponse) GetCollectionID() []byte

func (*GetCollectionResponse) GetData

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

func (*GetCollectionResponse) ProtoMessage

func (*GetCollectionResponse) ProtoMessage()

func (*GetCollectionResponse) ProtoReflect

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

func (*GetCollectionResponse) Reset

func (x *GetCollectionResponse) Reset()

func (*GetCollectionResponse) String

func (x *GetCollectionResponse) String() string

type GetCommitRequest

type GetCommitRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*GetCommitRequest) Descriptor deprecated

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

Deprecated: Use GetCommitRequest.ProtoReflect.Descriptor instead.

func (*GetCommitRequest) GetHeight

func (x *GetCommitRequest) GetHeight() uint64

func (*GetCommitRequest) ProtoMessage

func (*GetCommitRequest) ProtoMessage()

func (*GetCommitRequest) ProtoReflect

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

func (*GetCommitRequest) Reset

func (x *GetCommitRequest) Reset()

func (*GetCommitRequest) String

func (x *GetCommitRequest) String() string

type GetCommitResponse

type GetCommitResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Commit []byte `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCommitResponse) Descriptor deprecated

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

Deprecated: Use GetCommitResponse.ProtoReflect.Descriptor instead.

func (*GetCommitResponse) GetCommit

func (x *GetCommitResponse) GetCommit() []byte

func (*GetCommitResponse) GetHeight

func (x *GetCommitResponse) GetHeight() uint64

func (*GetCommitResponse) ProtoMessage

func (*GetCommitResponse) ProtoMessage()

func (*GetCommitResponse) ProtoReflect

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

func (*GetCommitResponse) Reset

func (x *GetCommitResponse) Reset()

func (*GetCommitResponse) String

func (x *GetCommitResponse) String() string

type GetEventsRequest

type GetEventsRequest struct {
	Height uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	Types  []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsRequest) Descriptor deprecated

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

Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsRequest) GetHeight

func (x *GetEventsRequest) GetHeight() uint64

func (*GetEventsRequest) GetTypes

func (x *GetEventsRequest) GetTypes() []string

func (*GetEventsRequest) ProtoMessage

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) ProtoReflect

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

func (*GetEventsRequest) Reset

func (x *GetEventsRequest) Reset()

func (*GetEventsRequest) String

func (x *GetEventsRequest) String() string

type GetEventsResponse

type GetEventsResponse struct {
	Height uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Types  []string `protobuf:"bytes,2,rep,name=types,proto3" json:"types,omitempty"`
	Data   []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsResponse) Descriptor deprecated

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

Deprecated: Use GetEventsResponse.ProtoReflect.Descriptor instead.

func (*GetEventsResponse) GetData

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

func (*GetEventsResponse) GetHeight

func (x *GetEventsResponse) GetHeight() uint64

func (*GetEventsResponse) GetTypes

func (x *GetEventsResponse) GetTypes() []string

func (*GetEventsResponse) ProtoMessage

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) ProtoReflect

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

func (*GetEventsResponse) Reset

func (x *GetEventsResponse) Reset()

func (*GetEventsResponse) String

func (x *GetEventsResponse) String() string

type GetFirstRequest

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

func (*GetFirstRequest) Descriptor deprecated

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

Deprecated: Use GetFirstRequest.ProtoReflect.Descriptor instead.

func (*GetFirstRequest) ProtoMessage

func (*GetFirstRequest) ProtoMessage()

func (*GetFirstRequest) ProtoReflect

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

func (*GetFirstRequest) Reset

func (x *GetFirstRequest) Reset()

func (*GetFirstRequest) String

func (x *GetFirstRequest) String() string

type GetFirstResponse

type GetFirstResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*GetFirstResponse) Descriptor deprecated

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

Deprecated: Use GetFirstResponse.ProtoReflect.Descriptor instead.

func (*GetFirstResponse) GetHeight

func (x *GetFirstResponse) GetHeight() uint64

func (*GetFirstResponse) ProtoMessage

func (*GetFirstResponse) ProtoMessage()

func (*GetFirstResponse) ProtoReflect

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

func (*GetFirstResponse) Reset

func (x *GetFirstResponse) Reset()

func (*GetFirstResponse) String

func (x *GetFirstResponse) String() string

type GetGuaranteeRequest

type GetGuaranteeRequest struct {
	CollectionID []byte `protobuf:"bytes,1,opt,name=collectionID,proto3" json:"collectionID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetGuaranteeRequest) Descriptor deprecated

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

Deprecated: Use GetGuaranteeRequest.ProtoReflect.Descriptor instead.

func (*GetGuaranteeRequest) GetCollectionID

func (x *GetGuaranteeRequest) GetCollectionID() []byte

func (*GetGuaranteeRequest) ProtoMessage

func (*GetGuaranteeRequest) ProtoMessage()

func (*GetGuaranteeRequest) ProtoReflect

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

func (*GetGuaranteeRequest) Reset

func (x *GetGuaranteeRequest) Reset()

func (*GetGuaranteeRequest) String

func (x *GetGuaranteeRequest) String() string

type GetGuaranteeResponse

type GetGuaranteeResponse struct {
	CollectionID []byte `protobuf:"bytes,1,opt,name=collectionID,proto3" json:"collectionID,omitempty"`
	Data         []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetGuaranteeResponse) Descriptor deprecated

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

Deprecated: Use GetGuaranteeResponse.ProtoReflect.Descriptor instead.

func (*GetGuaranteeResponse) GetCollectionID

func (x *GetGuaranteeResponse) GetCollectionID() []byte

func (*GetGuaranteeResponse) GetData

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

func (*GetGuaranteeResponse) ProtoMessage

func (*GetGuaranteeResponse) ProtoMessage()

func (*GetGuaranteeResponse) ProtoReflect

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

func (*GetGuaranteeResponse) Reset

func (x *GetGuaranteeResponse) Reset()

func (*GetGuaranteeResponse) String

func (x *GetGuaranteeResponse) String() string

type GetHeaderRequest

type GetHeaderRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*GetHeaderRequest) Descriptor deprecated

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

Deprecated: Use GetHeaderRequest.ProtoReflect.Descriptor instead.

func (*GetHeaderRequest) GetHeight

func (x *GetHeaderRequest) GetHeight() uint64

func (*GetHeaderRequest) ProtoMessage

func (*GetHeaderRequest) ProtoMessage()

func (*GetHeaderRequest) ProtoReflect

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

func (*GetHeaderRequest) Reset

func (x *GetHeaderRequest) Reset()

func (*GetHeaderRequest) String

func (x *GetHeaderRequest) String() string

type GetHeaderResponse

type GetHeaderResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeaderResponse) Descriptor deprecated

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

Deprecated: Use GetHeaderResponse.ProtoReflect.Descriptor instead.

func (*GetHeaderResponse) GetData

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

func (*GetHeaderResponse) GetHeight

func (x *GetHeaderResponse) GetHeight() uint64

func (*GetHeaderResponse) ProtoMessage

func (*GetHeaderResponse) ProtoMessage()

func (*GetHeaderResponse) ProtoReflect

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

func (*GetHeaderResponse) Reset

func (x *GetHeaderResponse) Reset()

func (*GetHeaderResponse) String

func (x *GetHeaderResponse) String() string

type GetHeightForBlockRequest

type GetHeightForBlockRequest struct {
	BlockID []byte `protobuf:"bytes,1,opt,name=blockID,proto3" json:"blockID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetHeightForBlockRequest) Descriptor deprecated

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

Deprecated: Use GetHeightForBlockRequest.ProtoReflect.Descriptor instead.

func (*GetHeightForBlockRequest) GetBlockID

func (x *GetHeightForBlockRequest) GetBlockID() []byte

func (*GetHeightForBlockRequest) ProtoMessage

func (*GetHeightForBlockRequest) ProtoMessage()

func (*GetHeightForBlockRequest) ProtoReflect

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

func (*GetHeightForBlockRequest) Reset

func (x *GetHeightForBlockRequest) Reset()

func (*GetHeightForBlockRequest) String

func (x *GetHeightForBlockRequest) String() string

type GetHeightForBlockResponse

type GetHeightForBlockResponse struct {
	BlockID []byte `protobuf:"bytes,1,opt,name=blockID,proto3" json:"blockID,omitempty"`
	Height  uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeightForBlockResponse) Descriptor deprecated

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

Deprecated: Use GetHeightForBlockResponse.ProtoReflect.Descriptor instead.

func (*GetHeightForBlockResponse) GetBlockID

func (x *GetHeightForBlockResponse) GetBlockID() []byte

func (*GetHeightForBlockResponse) GetHeight

func (x *GetHeightForBlockResponse) GetHeight() uint64

func (*GetHeightForBlockResponse) ProtoMessage

func (*GetHeightForBlockResponse) ProtoMessage()

func (*GetHeightForBlockResponse) ProtoReflect

func (*GetHeightForBlockResponse) Reset

func (x *GetHeightForBlockResponse) Reset()

func (*GetHeightForBlockResponse) String

func (x *GetHeightForBlockResponse) String() string

type GetHeightForTransactionRequest

type GetHeightForTransactionRequest struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetHeightForTransactionRequest) Descriptor deprecated

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

Deprecated: Use GetHeightForTransactionRequest.ProtoReflect.Descriptor instead.

func (*GetHeightForTransactionRequest) GetTransactionID

func (x *GetHeightForTransactionRequest) GetTransactionID() []byte

func (*GetHeightForTransactionRequest) ProtoMessage

func (*GetHeightForTransactionRequest) ProtoMessage()

func (*GetHeightForTransactionRequest) ProtoReflect

func (*GetHeightForTransactionRequest) Reset

func (x *GetHeightForTransactionRequest) Reset()

func (*GetHeightForTransactionRequest) String

type GetHeightForTransactionResponse

type GetHeightForTransactionResponse struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty"`
	Height        uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHeightForTransactionResponse) Descriptor deprecated

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

Deprecated: Use GetHeightForTransactionResponse.ProtoReflect.Descriptor instead.

func (*GetHeightForTransactionResponse) GetHeight

func (x *GetHeightForTransactionResponse) GetHeight() uint64

func (*GetHeightForTransactionResponse) GetTransactionID

func (x *GetHeightForTransactionResponse) GetTransactionID() []byte

func (*GetHeightForTransactionResponse) ProtoMessage

func (*GetHeightForTransactionResponse) ProtoMessage()

func (*GetHeightForTransactionResponse) ProtoReflect

func (*GetHeightForTransactionResponse) Reset

func (*GetHeightForTransactionResponse) String

type GetLastRequest

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

func (*GetLastRequest) Descriptor deprecated

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

Deprecated: Use GetLastRequest.ProtoReflect.Descriptor instead.

func (*GetLastRequest) ProtoMessage

func (*GetLastRequest) ProtoMessage()

func (*GetLastRequest) ProtoReflect

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

func (*GetLastRequest) Reset

func (x *GetLastRequest) Reset()

func (*GetLastRequest) String

func (x *GetLastRequest) String() string

type GetLastResponse

type GetLastResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLastResponse) Descriptor deprecated

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

Deprecated: Use GetLastResponse.ProtoReflect.Descriptor instead.

func (*GetLastResponse) GetHeight

func (x *GetLastResponse) GetHeight() uint64

func (*GetLastResponse) ProtoMessage

func (*GetLastResponse) ProtoMessage()

func (*GetLastResponse) ProtoReflect

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

func (*GetLastResponse) Reset

func (x *GetLastResponse) Reset()

func (*GetLastResponse) String

func (x *GetLastResponse) String() string

type GetRegisterValuesRequest

type GetRegisterValuesRequest struct {
	Height uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	Paths  [][]byte `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty" validate:"required,dive,len=32"`
	// contains filtered or unexported fields
}

func (*GetRegisterValuesRequest) Descriptor deprecated

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

Deprecated: Use GetRegisterValuesRequest.ProtoReflect.Descriptor instead.

func (*GetRegisterValuesRequest) GetHeight

func (x *GetRegisterValuesRequest) GetHeight() uint64

func (*GetRegisterValuesRequest) GetPaths

func (x *GetRegisterValuesRequest) GetPaths() [][]byte

func (*GetRegisterValuesRequest) ProtoMessage

func (*GetRegisterValuesRequest) ProtoMessage()

func (*GetRegisterValuesRequest) ProtoReflect

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

func (*GetRegisterValuesRequest) Reset

func (x *GetRegisterValuesRequest) Reset()

func (*GetRegisterValuesRequest) String

func (x *GetRegisterValuesRequest) String() string

type GetRegisterValuesResponse

type GetRegisterValuesResponse struct {
	Height uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Paths  [][]byte `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	Values [][]byte `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRegisterValuesResponse) Descriptor deprecated

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

Deprecated: Use GetRegisterValuesResponse.ProtoReflect.Descriptor instead.

func (*GetRegisterValuesResponse) GetHeight

func (x *GetRegisterValuesResponse) GetHeight() uint64

func (*GetRegisterValuesResponse) GetPaths

func (x *GetRegisterValuesResponse) GetPaths() [][]byte

func (*GetRegisterValuesResponse) GetValues

func (x *GetRegisterValuesResponse) GetValues() [][]byte

func (*GetRegisterValuesResponse) ProtoMessage

func (*GetRegisterValuesResponse) ProtoMessage()

func (*GetRegisterValuesResponse) ProtoReflect

func (*GetRegisterValuesResponse) Reset

func (x *GetRegisterValuesResponse) Reset()

func (*GetRegisterValuesResponse) String

func (x *GetRegisterValuesResponse) String() string

type GetResultRequest

type GetResultRequest struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetResultRequest) Descriptor deprecated

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

Deprecated: Use GetResultRequest.ProtoReflect.Descriptor instead.

func (*GetResultRequest) GetTransactionID

func (x *GetResultRequest) GetTransactionID() []byte

func (*GetResultRequest) ProtoMessage

func (*GetResultRequest) ProtoMessage()

func (*GetResultRequest) ProtoReflect

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

func (*GetResultRequest) Reset

func (x *GetResultRequest) Reset()

func (*GetResultRequest) String

func (x *GetResultRequest) String() string

type GetResultResponse

type GetResultResponse struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty"`
	Data          []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResultResponse) Descriptor deprecated

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

Deprecated: Use GetResultResponse.ProtoReflect.Descriptor instead.

func (*GetResultResponse) GetData

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

func (*GetResultResponse) GetTransactionID

func (x *GetResultResponse) GetTransactionID() []byte

func (*GetResultResponse) ProtoMessage

func (*GetResultResponse) ProtoMessage()

func (*GetResultResponse) ProtoReflect

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

func (*GetResultResponse) Reset

func (x *GetResultResponse) Reset()

func (*GetResultResponse) String

func (x *GetResultResponse) String() string

type GetSealRequest

type GetSealRequest struct {
	SealID []byte `protobuf:"bytes,1,opt,name=sealID,proto3" json:"sealID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetSealRequest) Descriptor deprecated

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

Deprecated: Use GetSealRequest.ProtoReflect.Descriptor instead.

func (*GetSealRequest) GetSealID

func (x *GetSealRequest) GetSealID() []byte

func (*GetSealRequest) ProtoMessage

func (*GetSealRequest) ProtoMessage()

func (*GetSealRequest) ProtoReflect

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

func (*GetSealRequest) Reset

func (x *GetSealRequest) Reset()

func (*GetSealRequest) String

func (x *GetSealRequest) String() string

type GetSealResponse

type GetSealResponse struct {
	SealID []byte `protobuf:"bytes,1,opt,name=sealID,proto3" json:"sealID,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSealResponse) Descriptor deprecated

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

Deprecated: Use GetSealResponse.ProtoReflect.Descriptor instead.

func (*GetSealResponse) GetData

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

func (*GetSealResponse) GetSealID

func (x *GetSealResponse) GetSealID() []byte

func (*GetSealResponse) ProtoMessage

func (*GetSealResponse) ProtoMessage()

func (*GetSealResponse) ProtoReflect

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

func (*GetSealResponse) Reset

func (x *GetSealResponse) Reset()

func (*GetSealResponse) String

func (x *GetSealResponse) String() string

type GetTransactionRequest

type GetTransactionRequest struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty" validate:"required,len=32"`
	// contains filtered or unexported fields
}

func (*GetTransactionRequest) Descriptor deprecated

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

Deprecated: Use GetTransactionRequest.ProtoReflect.Descriptor instead.

func (*GetTransactionRequest) GetTransactionID

func (x *GetTransactionRequest) GetTransactionID() []byte

func (*GetTransactionRequest) ProtoMessage

func (*GetTransactionRequest) ProtoMessage()

func (*GetTransactionRequest) ProtoReflect

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

func (*GetTransactionRequest) Reset

func (x *GetTransactionRequest) Reset()

func (*GetTransactionRequest) String

func (x *GetTransactionRequest) String() string

type GetTransactionResponse

type GetTransactionResponse struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty"`
	Data          []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTransactionResponse) Descriptor deprecated

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

Deprecated: Use GetTransactionResponse.ProtoReflect.Descriptor instead.

func (*GetTransactionResponse) GetData

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

func (*GetTransactionResponse) GetTransactionID

func (x *GetTransactionResponse) GetTransactionID() []byte

func (*GetTransactionResponse) ProtoMessage

func (*GetTransactionResponse) ProtoMessage()

func (*GetTransactionResponse) ProtoReflect

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

func (*GetTransactionResponse) Reset

func (x *GetTransactionResponse) Reset()

func (*GetTransactionResponse) String

func (x *GetTransactionResponse) String() string

type Index

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

Index implements the `index.Reader` interface on top of the DPS server's GRPC API. It can substitute for the on-disk index reader when executing scripts, such that script invoker and execution state are on two different machines across a network.

func IndexFromAPI

func IndexFromAPI(client APIClient, codec dps.Codec) *Index

IndexFromAPI creates a new instance of an index reader that uses the provided GRPC API client to retrieve state from the index.

func (*Index) Collection

func (i *Index) Collection(collID flow.Identifier) (*flow.LightCollection, error)

Collection returns the collection with the given ID.

func (*Index) CollectionsByHeight

func (i *Index) CollectionsByHeight(height uint64) ([]flow.Identifier, error)

CollectionsByHeight returns the transaction IDs within the given block.

func (*Index) Commit

func (i *Index) Commit(height uint64) (flow.StateCommitment, error)

Commit returns the commitment of the execution state as it was after the execution of the finalized block at the given height.

func (*Index) Events

func (i *Index) Events(height uint64, types ...flow.EventType) ([]flow.Event, error)

Events returns the events of all transactions that were part of the finalized block at the given height. It can optionally filter them by event type; if no event types are given, all events are returned.

func (*Index) First

func (i *Index) First() (uint64, error)

First returns the height of the first finalized block that was indexed.

func (*Index) Guarantee

func (i *Index) Guarantee(collID flow.Identifier) (*flow.CollectionGuarantee, error)

Guarantee returns the collection guarantee for the given collection ID.

func (*Index) Header

func (i *Index) Header(height uint64) (*flow.Header, error)

Header returns the header for the finalized block at the given height.

func (*Index) HeightForBlock

func (i *Index) HeightForBlock(blockID flow.Identifier) (uint64, error)

HeightForBlock returns the height of the given blockID.

func (*Index) HeightForTransaction

func (i *Index) HeightForTransaction(txID flow.Identifier) (uint64, error)

HeightForTransaction returns the height of the given transaction ID.

func (*Index) Last

func (i *Index) Last() (uint64, error)

Last returns the height of the last finalized block that was indexed.

func (*Index) Result

func (i *Index) Result(txID flow.Identifier) (*flow.TransactionResult, error)

Result returns the result for a given transaction ID.

func (*Index) Seal

func (i *Index) Seal(sealID flow.Identifier) (*flow.Seal, error)

Seal returns the seal with the given ID.

func (*Index) SealsByHeight

func (i *Index) SealsByHeight(height uint64) ([]flow.Identifier, error)

SealsByHeight returns the seal IDs at the given height.

func (*Index) Transaction

func (i *Index) Transaction(txID flow.Identifier) (*flow.TransactionBody, error)

Transaction returns the transaction with the given ID.

func (*Index) TransactionsByHeight

func (i *Index) TransactionsByHeight(height uint64) ([]flow.Identifier, error)

TransactionsByHeight returns the transaction IDs within the given block.

func (*Index) Values

func (i *Index) Values(height uint64, paths []ledger.Path) ([]ledger.Value, error)

Values returns the Ledger values of the execution state at the given paths as they were after the execution of the finalized block at the given height. For compatibility with existing Flow execution node code, a path that is not found within the indexed execution state returns a nil value without error.

type ListCollectionsForHeightRequest

type ListCollectionsForHeightRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*ListCollectionsForHeightRequest) Descriptor deprecated

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

Deprecated: Use ListCollectionsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListCollectionsForHeightRequest) GetHeight

func (x *ListCollectionsForHeightRequest) GetHeight() uint64

func (*ListCollectionsForHeightRequest) ProtoMessage

func (*ListCollectionsForHeightRequest) ProtoMessage()

func (*ListCollectionsForHeightRequest) ProtoReflect

func (*ListCollectionsForHeightRequest) Reset

func (*ListCollectionsForHeightRequest) String

type ListCollectionsForHeightResponse

type ListCollectionsForHeightResponse struct {
	Height        uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	CollectionIDs [][]byte `protobuf:"bytes,2,rep,name=collectionIDs,proto3" json:"collectionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCollectionsForHeightResponse) Descriptor deprecated

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

Deprecated: Use ListCollectionsForHeightResponse.ProtoReflect.Descriptor instead.

func (*ListCollectionsForHeightResponse) GetCollectionIDs

func (x *ListCollectionsForHeightResponse) GetCollectionIDs() [][]byte

func (*ListCollectionsForHeightResponse) GetHeight

func (*ListCollectionsForHeightResponse) ProtoMessage

func (*ListCollectionsForHeightResponse) ProtoMessage()

func (*ListCollectionsForHeightResponse) ProtoReflect

func (*ListCollectionsForHeightResponse) Reset

func (*ListCollectionsForHeightResponse) String

type ListSealsForHeightRequest

type ListSealsForHeightRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*ListSealsForHeightRequest) Descriptor deprecated

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

Deprecated: Use ListSealsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListSealsForHeightRequest) GetHeight

func (x *ListSealsForHeightRequest) GetHeight() uint64

func (*ListSealsForHeightRequest) ProtoMessage

func (*ListSealsForHeightRequest) ProtoMessage()

func (*ListSealsForHeightRequest) ProtoReflect

func (*ListSealsForHeightRequest) Reset

func (x *ListSealsForHeightRequest) Reset()

func (*ListSealsForHeightRequest) String

func (x *ListSealsForHeightRequest) String() string

type ListSealsForHeightResponse

type ListSealsForHeightResponse struct {
	Height  uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	SealIDs [][]byte `protobuf:"bytes,2,rep,name=sealIDs,proto3" json:"sealIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSealsForHeightResponse) Descriptor deprecated

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

Deprecated: Use ListSealsForHeightResponse.ProtoReflect.Descriptor instead.

func (*ListSealsForHeightResponse) GetHeight

func (x *ListSealsForHeightResponse) GetHeight() uint64

func (*ListSealsForHeightResponse) GetSealIDs

func (x *ListSealsForHeightResponse) GetSealIDs() [][]byte

func (*ListSealsForHeightResponse) ProtoMessage

func (*ListSealsForHeightResponse) ProtoMessage()

func (*ListSealsForHeightResponse) ProtoReflect

func (*ListSealsForHeightResponse) Reset

func (x *ListSealsForHeightResponse) Reset()

func (*ListSealsForHeightResponse) String

func (x *ListSealsForHeightResponse) String() string

type ListTransactionsForHeightRequest

type ListTransactionsForHeightRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" validate:"required"`
	// contains filtered or unexported fields
}

func (*ListTransactionsForHeightRequest) Descriptor deprecated

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

Deprecated: Use ListTransactionsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListTransactionsForHeightRequest) GetHeight

func (*ListTransactionsForHeightRequest) ProtoMessage

func (*ListTransactionsForHeightRequest) ProtoMessage()

func (*ListTransactionsForHeightRequest) ProtoReflect

func (*ListTransactionsForHeightRequest) Reset

func (*ListTransactionsForHeightRequest) String

type ListTransactionsForHeightResponse

type ListTransactionsForHeightResponse struct {
	Height         uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	TransactionIDs [][]byte `protobuf:"bytes,2,rep,name=transactionIDs,proto3" json:"transactionIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTransactionsForHeightResponse) Descriptor deprecated

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

Deprecated: Use ListTransactionsForHeightResponse.ProtoReflect.Descriptor instead.

func (*ListTransactionsForHeightResponse) GetHeight

func (*ListTransactionsForHeightResponse) GetTransactionIDs

func (x *ListTransactionsForHeightResponse) GetTransactionIDs() [][]byte

func (*ListTransactionsForHeightResponse) ProtoMessage

func (*ListTransactionsForHeightResponse) ProtoMessage()

func (*ListTransactionsForHeightResponse) ProtoReflect

func (*ListTransactionsForHeightResponse) Reset

func (*ListTransactionsForHeightResponse) String

type Server

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

Server is a simple implementation of the generated APIServer interface. It uses an index reader interface as the backend to retrieve the desired data. This is generally an on-disk interface, but could be a GRPC-based index as well, in which case there is a double redirection.

func NewServer

func NewServer(index dps.Reader, codec dps.Codec) *Server

NewServer creates a new server, using the provided index reader as a backend for data retrieval.

func (*Server) GetCollection

func (s *Server) GetCollection(_ context.Context, req *GetCollectionRequest) (*GetCollectionResponse, error)

GetCollection implements the `GetCollection` method of the generated GRPC server.

func (*Server) GetCommit

func (s *Server) GetCommit(_ context.Context, req *GetCommitRequest) (*GetCommitResponse, error)

GetCommit implements the `GetCommit` method of the generated GRPC server.

func (*Server) GetEvents

func (s *Server) GetEvents(_ context.Context, req *GetEventsRequest) (*GetEventsResponse, error)

GetEvents implements the `GetEvents` method of the generated GRPC server.

func (*Server) GetFirst

GetFirst implements the `GetFirst` method of the generated GRPC server.

func (*Server) GetGuarantee

func (s *Server) GetGuarantee(_ context.Context, req *GetGuaranteeRequest) (*GetGuaranteeResponse, error)

GetGuarantee implements the `GetGuarantee` method of the generated GRPC server.

func (*Server) GetHeader

func (s *Server) GetHeader(_ context.Context, req *GetHeaderRequest) (*GetHeaderResponse, error)

GetHeader implements the `GetHeader` method of the generated GRPC server.

func (*Server) GetHeightForBlock

GetHeightForBlock implements the `GetHeightForBlock` method of the generated GRPC server.

func (*Server) GetHeightForTransaction

GetHeightForTransaction implements the `GetHeightForTransaction` method of the generated GRPC server.

func (*Server) GetLast

func (s *Server) GetLast(_ context.Context, _ *GetLastRequest) (*GetLastResponse, error)

GetLast implements the `GetLast` method of the generated GRPC server.

func (*Server) GetRegisterValues

GetRegisterValues implements the `GetRegisterValues` method of the generated GRPC server.

func (*Server) GetResult

func (s *Server) GetResult(_ context.Context, req *GetResultRequest) (*GetResultResponse, error)

GetResult implements the `GetResult` method of the generated GRPC server.

func (*Server) GetSeal

func (s *Server) GetSeal(_ context.Context, req *GetSealRequest) (*GetSealResponse, error)

GetSeal implements the `GetSeal` method of the generated GRPC server.

func (*Server) GetTransaction

GetTransaction implements the `GetTransaction` method of the generated GRPC server.

func (*Server) ListCollectionsForHeight

ListCollectionsForHeight implements the `ListCollectionsForHeight` method of the generated GRPC server.

func (*Server) ListSealsForHeight

ListSealsForHeight implements the `ListSealsForHeight` method of the generated GRPC server.

func (*Server) ListTransactionsForHeight

ListTransactionsForHeight implements the `ListTransactionsForHeight` method of the generated GRPC server.

type UnimplementedAPIServer

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer should be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) GetCollection

func (UnimplementedAPIServer) GetCommit

func (UnimplementedAPIServer) GetEvents

func (UnimplementedAPIServer) GetFirst

func (UnimplementedAPIServer) GetGuarantee

func (UnimplementedAPIServer) GetHeader

func (UnimplementedAPIServer) GetLast

func (UnimplementedAPIServer) GetResult

func (UnimplementedAPIServer) GetSeal

func (UnimplementedAPIServer) GetTransaction

type UnsafeAPIServer

type UnsafeAPIServer interface {
	// contains filtered or unexported methods
}

UnsafeAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServer will result in compilation errors.

Jump to

Keyboard shortcuts

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