Documentation ¶
Index ¶
- Variables
- func RegisterProcessorServer(s grpc.ServiceRegistrar, srv ProcessorServer)
- type ProcessorClient
- type ProcessorQueueStatus
- func (ProcessorQueueStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ProcessorQueueStatus) Enum() *ProcessorQueueStatus
- func (ProcessorQueueStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProcessorQueueStatus) Number() protoreflect.EnumNumber
- func (x ProcessorQueueStatus) String() string
- func (ProcessorQueueStatus) Type() protoreflect.EnumType
- type ProcessorServer
- type QueueBlockRequest
- func (*QueueBlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueueBlockRequest) GetBlockNumber() uint64
- func (x *QueueBlockRequest) GetChainId() uint64
- func (*QueueBlockRequest) ProtoMessage()
- func (x *QueueBlockRequest) ProtoReflect() protoreflect.Message
- func (x *QueueBlockRequest) Reset()
- func (x *QueueBlockRequest) String() string
- type QueueBlockResponse
- func (*QueueBlockResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueueBlockResponse) GetStatus() *common.Status
- func (*QueueBlockResponse) ProtoMessage()
- func (x *QueueBlockResponse) ProtoReflect() protoreflect.Message
- func (x *QueueBlockResponse) Reset()
- func (x *QueueBlockResponse) String() string
- type UnimplementedProcessorServer
- type UnsafeProcessorServer
Constants ¶
This section is empty.
Variables ¶
var ( ProcessorQueueStatus_name = map[int32]string{ 0: "PQS_NONE", 1: "PQS_QUEUED", 2: "PQS_PROCESSING", 3: "PQS_PROCESSED", 4: "PQS_FAILED", } ProcessorQueueStatus_value = map[string]int32{ "PQS_NONE": 0, "PQS_QUEUED": 1, "PQS_PROCESSING": 2, "PQS_PROCESSED": 3, "PQS_FAILED": 4, } )
Enum value maps for ProcessorQueueStatus.
var File_indexer_processor_proto protoreflect.FileDescriptor
var Processor_ServiceDesc = grpc.ServiceDesc{ ServiceName: "unpack.v1.indexer.processor.Processor", HandlerType: (*ProcessorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueueBlock", Handler: _Processor_QueueBlock_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "indexer/processor.proto", }
Processor_ServiceDesc is the grpc.ServiceDesc for Processor service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProcessorServer ¶
func RegisterProcessorServer(s grpc.ServiceRegistrar, srv ProcessorServer)
Types ¶
type ProcessorClient ¶
type ProcessorClient interface {
QueueBlock(ctx context.Context, in *QueueBlockRequest, opts ...grpc.CallOption) (*QueueBlockResponse, error)
}
ProcessorClient is the client API for Processor 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 NewProcessorClient ¶
func NewProcessorClient(cc grpc.ClientConnInterface) ProcessorClient
type ProcessorQueueStatus ¶
type ProcessorQueueStatus int32
const ( ProcessorQueueStatus_PQS_NONE ProcessorQueueStatus = 0 ProcessorQueueStatus_PQS_QUEUED ProcessorQueueStatus = 1 ProcessorQueueStatus_PQS_PROCESSING ProcessorQueueStatus = 2 ProcessorQueueStatus_PQS_PROCESSED ProcessorQueueStatus = 3 ProcessorQueueStatus_PQS_FAILED ProcessorQueueStatus = 4 )
func (ProcessorQueueStatus) Descriptor ¶
func (ProcessorQueueStatus) Descriptor() protoreflect.EnumDescriptor
func (ProcessorQueueStatus) Enum ¶
func (x ProcessorQueueStatus) Enum() *ProcessorQueueStatus
func (ProcessorQueueStatus) EnumDescriptor
deprecated
func (ProcessorQueueStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProcessorQueueStatus.Descriptor instead.
func (ProcessorQueueStatus) Number ¶
func (x ProcessorQueueStatus) Number() protoreflect.EnumNumber
func (ProcessorQueueStatus) String ¶
func (x ProcessorQueueStatus) String() string
func (ProcessorQueueStatus) Type ¶
func (ProcessorQueueStatus) Type() protoreflect.EnumType
type ProcessorServer ¶
type ProcessorServer interface { QueueBlock(context.Context, *QueueBlockRequest) (*QueueBlockResponse, error) // contains filtered or unexported methods }
ProcessorServer is the server API for Processor service. All implementations must embed UnimplementedProcessorServer for forward compatibility
type QueueBlockRequest ¶
type QueueBlockRequest struct { ChainId uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` BlockNumber uint64 `protobuf:"varint,2,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"` // contains filtered or unexported fields }
func (*QueueBlockRequest) Descriptor
deprecated
func (*QueueBlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueueBlockRequest.ProtoReflect.Descriptor instead.
func (*QueueBlockRequest) GetBlockNumber ¶
func (x *QueueBlockRequest) GetBlockNumber() uint64
func (*QueueBlockRequest) GetChainId ¶
func (x *QueueBlockRequest) GetChainId() uint64
func (*QueueBlockRequest) ProtoMessage ¶
func (*QueueBlockRequest) ProtoMessage()
func (*QueueBlockRequest) ProtoReflect ¶
func (x *QueueBlockRequest) ProtoReflect() protoreflect.Message
func (*QueueBlockRequest) Reset ¶
func (x *QueueBlockRequest) Reset()
func (*QueueBlockRequest) String ¶
func (x *QueueBlockRequest) String() string
type QueueBlockResponse ¶
type QueueBlockResponse struct { Status *common.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*QueueBlockResponse) Descriptor
deprecated
func (*QueueBlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueueBlockResponse.ProtoReflect.Descriptor instead.
func (*QueueBlockResponse) GetStatus ¶
func (x *QueueBlockResponse) GetStatus() *common.Status
func (*QueueBlockResponse) ProtoMessage ¶
func (*QueueBlockResponse) ProtoMessage()
func (*QueueBlockResponse) ProtoReflect ¶
func (x *QueueBlockResponse) ProtoReflect() protoreflect.Message
func (*QueueBlockResponse) Reset ¶
func (x *QueueBlockResponse) Reset()
func (*QueueBlockResponse) String ¶
func (x *QueueBlockResponse) String() string
type UnimplementedProcessorServer ¶
type UnimplementedProcessorServer struct { }
UnimplementedProcessorServer must be embedded to have forward compatible implementations.
func (UnimplementedProcessorServer) QueueBlock ¶
func (UnimplementedProcessorServer) QueueBlock(context.Context, *QueueBlockRequest) (*QueueBlockResponse, error)
type UnsafeProcessorServer ¶
type UnsafeProcessorServer interface {
// contains filtered or unexported methods
}
UnsafeProcessorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProcessorServer will result in compilation errors.