dps

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2021 License: Apache-2.0 Imports: 14 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: "GetTransaction",
			Handler:    _API_GetTransaction_Handler,
		},
		{
			MethodName: "ListTransactionsForHeight",
			Handler:    _API_ListTransactionsForHeight_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)

View Source 
var File_api_proto protoreflect.FileDescriptor

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)
	GetTransaction(ctx context.Context, in *GetTransactionRequest, opts ...grpc.CallOption) (*GetTransactionResponse, error)
	ListTransactionsForHeight(ctx context.Context, in *ListTransactionsForHeightRequest, opts ...grpc.CallOption) (*ListTransactionsForHeightResponse, 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 

type APIServer interface {
	GetFirst(context.Context, *GetFirstRequest) (*GetFirstResponse, error)
	GetLast(context.Context, *GetLastRequest) (*GetLastResponse, error)
	GetHeightForBlock(context.Context, *GetHeightForBlockRequest) (*GetHeightForBlockResponse, error)
	GetCommit(context.Context, *GetCommitRequest) (*GetCommitResponse, error)
	GetHeader(context.Context, *GetHeaderRequest) (*GetHeaderResponse, error)
	GetEvents(context.Context, *GetEventsRequest) (*GetEventsResponse, error)
	GetRegisterValues(context.Context, *GetRegisterValuesRequest) (*GetRegisterValuesResponse, error)
	GetTransaction(context.Context, *GetTransactionRequest) (*GetTransactionResponse, error)
	ListTransactionsForHeight(context.Context, *ListTransactionsForHeightRequest) (*ListTransactionsForHeightResponse, error)
}

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

type GetCommitRequest 

type GetCommitRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// 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"`
	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"`
	// 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 GetHeaderRequest 

type GetHeaderRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// 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"`
	// 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 (x *GetHeightForBlockResponse) ProtoReflect() protoreflect.Message

func (*GetHeightForBlockResponse) Reset 

func (x *GetHeightForBlockResponse) Reset()

func (*GetHeightForBlockResponse) String 

func (x *GetHeightForBlockResponse) String() 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"`
	Paths  [][]byte `protobuf:"bytes,2,rep,name=paths,proto3" json:"paths,omitempty"`
	// 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 (x *GetRegisterValuesResponse) ProtoReflect() protoreflect.Message

func (*GetRegisterValuesResponse) Reset 

func (x *GetRegisterValuesResponse) Reset()

func (*GetRegisterValuesResponse) String 

func (x *GetRegisterValuesResponse) String() string

type GetTransactionRequest 

type GetTransactionRequest struct {
	TransactionID []byte `protobuf:"bytes,1,opt,name=transactionID,proto3" json:"transactionID,omitempty"`
	// 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) 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) 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) Last 

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

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

func (*Index) Transaction 

func (i *Index) Transaction(transactionID 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 ListTransactionsForHeightRequest 

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

func (*ListTransactionsForHeightRequest) Descriptor deprecated 

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

Deprecated: Use ListTransactionsForHeightRequest.ProtoReflect.Descriptor instead.

func (*ListTransactionsForHeightRequest) GetHeight 

func (x *ListTransactionsForHeightRequest) GetHeight() uint64

func (*ListTransactionsForHeightRequest) ProtoMessage 

func (*ListTransactionsForHeightRequest) ProtoMessage()

func (*ListTransactionsForHeightRequest) ProtoReflect 

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

func (*ListTransactionsForHeightRequest) Reset 

func (x *ListTransactionsForHeightRequest) Reset()

func (*ListTransactionsForHeightRequest) String 

func (x *ListTransactionsForHeightRequest) String() 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 (x *ListTransactionsForHeightResponse) GetHeight() uint64

func (*ListTransactionsForHeightResponse) GetTransactionIDs 

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

func (*ListTransactionsForHeightResponse) ProtoMessage 

func (*ListTransactionsForHeightResponse) ProtoMessage()

func (*ListTransactionsForHeightResponse) ProtoReflect 

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

func (*ListTransactionsForHeightResponse) Reset 

func (x *ListTransactionsForHeightResponse) Reset()

func (*ListTransactionsForHeightResponse) String 

func (x *ListTransactionsForHeightResponse) String() 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) 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 

func (s *Server) GetFirst(_ context.Context, _ *GetFirstRequest) (*GetFirstResponse, error)

GetFirst implements the `GetFirst` 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 

func (s *Server) GetHeightForBlock(_ context.Context, req *GetHeightForBlockRequest) (*GetHeightForBlockResponse, error)

GetHeight implements the `GetHeight` 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 

func (s *Server) GetRegisterValues(_ context.Context, req *GetRegisterValuesRequest) (*GetRegisterValuesResponse, error)

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

func (*Server) GetTransaction 

func (s *Server) GetTransaction(_ context.Context, req *GetTransactionRequest) (*GetTransactionResponse, error)

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

func (*Server) ListTransactionsForHeight 

func (s *Server) ListTransactionsForHeight(_ context.Context, req *ListTransactionsForHeightRequest) (*ListTransactionsForHeightResponse, error)

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) GetCommit 

func (UnimplementedAPIServer) GetCommit(context.Context, *GetCommitRequest) (*GetCommitResponse, error)

func (UnimplementedAPIServer) GetEvents 

func (UnimplementedAPIServer) GetEvents(context.Context, *GetEventsRequest) (*GetEventsResponse, error)

func (UnimplementedAPIServer) GetFirst 

func (UnimplementedAPIServer) GetFirst(context.Context, *GetFirstRequest) (*GetFirstResponse, error)

func (UnimplementedAPIServer) GetHeader 

func (UnimplementedAPIServer) GetHeader(context.Context, *GetHeaderRequest) (*GetHeaderResponse, error)

func (UnimplementedAPIServer) GetHeightForBlock 

func (UnimplementedAPIServer) GetHeightForBlock(context.Context, *GetHeightForBlockRequest) (*GetHeightForBlockResponse, error)

func (UnimplementedAPIServer) GetLast 

func (UnimplementedAPIServer) GetLast(context.Context, *GetLastRequest) (*GetLastResponse, error)

func (UnimplementedAPIServer) GetRegisterValues 

func (UnimplementedAPIServer) GetRegisterValues(context.Context, *GetRegisterValuesRequest) (*GetRegisterValuesResponse, error)

func (UnimplementedAPIServer) GetTransaction 

func (UnimplementedAPIServer) GetTransaction(context.Context, *GetTransactionRequest) (*GetTransactionResponse, error)

func (UnimplementedAPIServer) ListTransactionsForHeight 

func (UnimplementedAPIServer) ListTransactionsForHeight(context.Context, *ListTransactionsForHeightRequest) (*ListTransactionsForHeightResponse, error)

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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