dps

package
v1.4.8 Latest Latest
Warning

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

Go to latest
Published: Oct 28, 2021 License: Apache-2.0 Imports: 15 Imported by: 3

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 added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetCollectionRequest.ProtoReflect.Descriptor instead.

func (*GetCollectionRequest) GetCollectionID added in v1.1.0

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

func (*GetCollectionRequest) ProtoMessage added in v1.1.0

func (*GetCollectionRequest) ProtoMessage()

func (*GetCollectionRequest) ProtoReflect added in v1.1.0

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

func (*GetCollectionRequest) Reset added in v1.1.0

func (x *GetCollectionRequest) Reset()

func (*GetCollectionRequest) String added in v1.1.0

func (x *GetCollectionRequest) String() string

type GetCollectionResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetCollectionResponse.ProtoReflect.Descriptor instead.

func (*GetCollectionResponse) GetCollectionID added in v1.1.0

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

func (*GetCollectionResponse) GetData added in v1.1.0

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

func (*GetCollectionResponse) ProtoMessage added in v1.1.0

func (*GetCollectionResponse) ProtoMessage()

func (*GetCollectionResponse) ProtoReflect added in v1.1.0

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

func (*GetCollectionResponse) Reset added in v1.1.0

func (x *GetCollectionResponse) Reset()

func (*GetCollectionResponse) String added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetGuaranteeRequest.ProtoReflect.Descriptor instead.

func (*GetGuaranteeRequest) GetCollectionID added in v1.1.0

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

func (*GetGuaranteeRequest) ProtoMessage added in v1.1.0

func (*GetGuaranteeRequest) ProtoMessage()

func (*GetGuaranteeRequest) ProtoReflect added in v1.1.0

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

func (*GetGuaranteeRequest) Reset added in v1.1.0

func (x *GetGuaranteeRequest) Reset()

func (*GetGuaranteeRequest) String added in v1.1.0

func (x *GetGuaranteeRequest) String() string

type GetGuaranteeResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetGuaranteeResponse.ProtoReflect.Descriptor instead.

func (*GetGuaranteeResponse) GetCollectionID added in v1.1.0

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

func (*GetGuaranteeResponse) GetData added in v1.1.0

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

func (*GetGuaranteeResponse) ProtoMessage added in v1.1.0

func (*GetGuaranteeResponse) ProtoMessage()

func (*GetGuaranteeResponse) ProtoReflect added in v1.1.0

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

func (*GetGuaranteeResponse) Reset added in v1.1.0

func (x *GetGuaranteeResponse) Reset()

func (*GetGuaranteeResponse) String added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetHeightForTransactionRequest.ProtoReflect.Descriptor instead.

func (*GetHeightForTransactionRequest) GetTransactionID added in v1.1.0

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

func (*GetHeightForTransactionRequest) ProtoMessage added in v1.1.0

func (*GetHeightForTransactionRequest) ProtoMessage()

func (*GetHeightForTransactionRequest) ProtoReflect added in v1.1.0

func (*GetHeightForTransactionRequest) Reset added in v1.1.0

func (x *GetHeightForTransactionRequest) Reset()

func (*GetHeightForTransactionRequest) String added in v1.1.0

type GetHeightForTransactionResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetHeightForTransactionResponse.ProtoReflect.Descriptor instead.

func (*GetHeightForTransactionResponse) GetHeight added in v1.1.0

func (x *GetHeightForTransactionResponse) GetHeight() uint64

func (*GetHeightForTransactionResponse) GetTransactionID added in v1.1.0

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

func (*GetHeightForTransactionResponse) ProtoMessage added in v1.1.0

func (*GetHeightForTransactionResponse) ProtoMessage()

func (*GetHeightForTransactionResponse) ProtoReflect added in v1.1.0

func (*GetHeightForTransactionResponse) Reset added in v1.1.0

func (*GetHeightForTransactionResponse) String added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetResultRequest.ProtoReflect.Descriptor instead.

func (*GetResultRequest) GetTransactionID added in v1.1.0

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

func (*GetResultRequest) ProtoMessage added in v1.1.0

func (*GetResultRequest) ProtoMessage()

func (*GetResultRequest) ProtoReflect added in v1.1.0

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

func (*GetResultRequest) Reset added in v1.1.0

func (x *GetResultRequest) Reset()

func (*GetResultRequest) String added in v1.1.0

func (x *GetResultRequest) String() string

type GetResultResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetResultResponse.ProtoReflect.Descriptor instead.

func (*GetResultResponse) GetData added in v1.1.0

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

func (*GetResultResponse) GetTransactionID added in v1.1.0

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

func (*GetResultResponse) ProtoMessage added in v1.1.0

func (*GetResultResponse) ProtoMessage()

func (*GetResultResponse) ProtoReflect added in v1.1.0

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

func (*GetResultResponse) Reset added in v1.1.0

func (x *GetResultResponse) Reset()

func (*GetResultResponse) String added in v1.1.0

func (x *GetResultResponse) String() string

type GetSealRequest added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetSealRequest.ProtoReflect.Descriptor instead.

func (*GetSealRequest) GetSealID added in v1.1.0

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

func (*GetSealRequest) ProtoMessage added in v1.1.0

func (*GetSealRequest) ProtoMessage()

func (*GetSealRequest) ProtoReflect added in v1.1.0

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

func (*GetSealRequest) Reset added in v1.1.0

func (x *GetSealRequest) Reset()

func (*GetSealRequest) String added in v1.1.0

func (x *GetSealRequest) String() string

type GetSealResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use GetSealResponse.ProtoReflect.Descriptor instead.

func (*GetSealResponse) GetData added in v1.1.0

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

func (*GetSealResponse) GetSealID added in v1.1.0

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

func (*GetSealResponse) ProtoMessage added in v1.1.0

func (*GetSealResponse) ProtoMessage()

func (*GetSealResponse) ProtoReflect added in v1.1.0

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

func (*GetSealResponse) Reset added in v1.1.0

func (x *GetSealResponse) Reset()

func (*GetSealResponse) String added in v1.1.0

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 added in v1.1.0

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

Collection returns the collection with the given ID.

func (*Index) CollectionsByHeight added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

Result returns the result for a given transaction ID.

func (*Index) Seal added in v1.1.0

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

Seal returns the seal with the given ID.

func (*Index) SealsByHeight added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use ListCollectionsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListCollectionsForHeightRequest) GetHeight added in v1.1.0

func (x *ListCollectionsForHeightRequest) GetHeight() uint64

func (*ListCollectionsForHeightRequest) ProtoMessage added in v1.1.0

func (*ListCollectionsForHeightRequest) ProtoMessage()

func (*ListCollectionsForHeightRequest) ProtoReflect added in v1.1.0

func (*ListCollectionsForHeightRequest) Reset added in v1.1.0

func (*ListCollectionsForHeightRequest) String added in v1.1.0

type ListCollectionsForHeightResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use ListCollectionsForHeightResponse.ProtoReflect.Descriptor instead.

func (*ListCollectionsForHeightResponse) GetCollectionIDs added in v1.1.0

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

func (*ListCollectionsForHeightResponse) GetHeight added in v1.1.0

func (*ListCollectionsForHeightResponse) ProtoMessage added in v1.1.0

func (*ListCollectionsForHeightResponse) ProtoMessage()

func (*ListCollectionsForHeightResponse) ProtoReflect added in v1.1.0

func (*ListCollectionsForHeightResponse) Reset added in v1.1.0

func (*ListCollectionsForHeightResponse) String added in v1.1.0

type ListSealsForHeightRequest added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use ListSealsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListSealsForHeightRequest) GetHeight added in v1.1.0

func (x *ListSealsForHeightRequest) GetHeight() uint64

func (*ListSealsForHeightRequest) ProtoMessage added in v1.1.0

func (*ListSealsForHeightRequest) ProtoMessage()

func (*ListSealsForHeightRequest) ProtoReflect added in v1.1.0

func (*ListSealsForHeightRequest) Reset added in v1.1.0

func (x *ListSealsForHeightRequest) Reset()

func (*ListSealsForHeightRequest) String added in v1.1.0

func (x *ListSealsForHeightRequest) String() string

type ListSealsForHeightResponse added in v1.1.0

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 added in v1.1.0

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

Deprecated: Use ListSealsForHeightResponse.ProtoReflect.Descriptor instead.

func (*ListSealsForHeightResponse) GetHeight added in v1.1.0

func (x *ListSealsForHeightResponse) GetHeight() uint64

func (*ListSealsForHeightResponse) GetSealIDs added in v1.1.0

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

func (*ListSealsForHeightResponse) ProtoMessage added in v1.1.0

func (*ListSealsForHeightResponse) ProtoMessage()

func (*ListSealsForHeightResponse) ProtoReflect added in v1.1.0

func (*ListSealsForHeightResponse) Reset added in v1.1.0

func (x *ListSealsForHeightResponse) Reset()

func (*ListSealsForHeightResponse) String added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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 added in v1.1.0

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

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

func (*Server) GetSeal added in v1.1.0

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 added in v1.1.0

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

func (*Server) ListSealsForHeight added in v1.1.0

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 added in v1.1.0

func (UnimplementedAPIServer) GetCommit

func (UnimplementedAPIServer) GetEvents

func (UnimplementedAPIServer) GetFirst

func (UnimplementedAPIServer) GetGuarantee added in v1.1.0

func (UnimplementedAPIServer) GetHeader

func (UnimplementedAPIServer) GetHeightForTransaction added in v1.1.0

func (UnimplementedAPIServer) GetLast

func (UnimplementedAPIServer) GetResult added in v1.1.0

func (UnimplementedAPIServer) GetSeal added in v1.1.0

func (UnimplementedAPIServer) GetTransaction

func (UnimplementedAPIServer) ListCollectionsForHeight added in v1.1.0

func (UnimplementedAPIServer) ListSealsForHeight added in v1.1.0

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