Documentation ¶
Index ¶
- Constants
- Variables
- func GetStateRootFromProof(logger *log.Logger, proof string) (common.Hash, error)
- func RegisterAggregatorServiceServer(s grpc.ServiceRegistrar, srv AggregatorServiceServer)
- type AggregatorMessage
- func (*AggregatorMessage) Descriptor() ([]byte, []int)deprecated
- func (x *AggregatorMessage) GetCancelRequest() *CancelRequest
- func (x *AggregatorMessage) GetGenAggregatedProofRequest() *GenAggregatedProofRequest
- func (x *AggregatorMessage) GetGenBatchProofRequest() *GenBatchProofRequest
- func (x *AggregatorMessage) GetGenFinalProofRequest() *GenFinalProofRequest
- func (x *AggregatorMessage) GetGenStatelessBatchProofRequest() *GenStatelessBatchProofRequest
- func (x *AggregatorMessage) GetGetProofRequest() *GetProofRequest
- func (x *AggregatorMessage) GetGetStatusRequest() *GetStatusRequest
- func (x *AggregatorMessage) GetId() string
- func (m *AggregatorMessage) GetRequest() isAggregatorMessage_Request
- func (*AggregatorMessage) ProtoMessage()
- func (x *AggregatorMessage) ProtoReflect() protoreflect.Message
- func (x *AggregatorMessage) Reset()
- func (x *AggregatorMessage) String() string
- type AggregatorMessage_CancelRequest
- type AggregatorMessage_GenAggregatedProofRequest
- type AggregatorMessage_GenBatchProofRequest
- type AggregatorMessage_GenFinalProofRequest
- type AggregatorMessage_GenStatelessBatchProofRequest
- type AggregatorMessage_GetProofRequest
- type AggregatorMessage_GetStatusRequest
- type AggregatorServiceClient
- type AggregatorServiceServer
- type AggregatorService_ChannelClient
- type AggregatorService_ChannelServer
- type CancelRequest
- type CancelResponse
- type FinalProof
- func (*FinalProof) Descriptor() ([]byte, []int)deprecated
- func (x *FinalProof) GetProof() string
- func (x *FinalProof) GetPublic() *PublicInputsExtended
- func (*FinalProof) ProtoMessage()
- func (x *FinalProof) ProtoReflect() protoreflect.Message
- func (x *FinalProof) Reset()
- func (x *FinalProof) String() string
- type GenAggregatedProofRequest
- func (*GenAggregatedProofRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenAggregatedProofRequest) GetRecursiveProof_1() string
- func (x *GenAggregatedProofRequest) GetRecursiveProof_2() string
- func (*GenAggregatedProofRequest) ProtoMessage()
- func (x *GenAggregatedProofRequest) ProtoReflect() protoreflect.Message
- func (x *GenAggregatedProofRequest) Reset()
- func (x *GenAggregatedProofRequest) String() string
- type GenAggregatedProofResponse
- func (*GenAggregatedProofResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenAggregatedProofResponse) GetId() string
- func (x *GenAggregatedProofResponse) GetResult() Result
- func (*GenAggregatedProofResponse) ProtoMessage()
- func (x *GenAggregatedProofResponse) ProtoReflect() protoreflect.Message
- func (x *GenAggregatedProofResponse) Reset()
- func (x *GenAggregatedProofResponse) String() string
- type GenBatchProofRequest
- func (*GenBatchProofRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenBatchProofRequest) GetInput() *InputProver
- func (*GenBatchProofRequest) ProtoMessage()
- func (x *GenBatchProofRequest) ProtoReflect() protoreflect.Message
- func (x *GenBatchProofRequest) Reset()
- func (x *GenBatchProofRequest) String() string
- type GenBatchProofResponse
- func (*GenBatchProofResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenBatchProofResponse) GetId() string
- func (x *GenBatchProofResponse) GetResult() Result
- func (*GenBatchProofResponse) ProtoMessage()
- func (x *GenBatchProofResponse) ProtoReflect() protoreflect.Message
- func (x *GenBatchProofResponse) Reset()
- func (x *GenBatchProofResponse) String() string
- type GenFinalProofRequest
- func (*GenFinalProofRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenFinalProofRequest) GetAggregatorAddr() string
- func (x *GenFinalProofRequest) GetRecursiveProof() string
- func (*GenFinalProofRequest) ProtoMessage()
- func (x *GenFinalProofRequest) ProtoReflect() protoreflect.Message
- func (x *GenFinalProofRequest) Reset()
- func (x *GenFinalProofRequest) String() string
- type GenFinalProofResponse
- func (*GenFinalProofResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GenFinalProofResponse) GetId() string
- func (x *GenFinalProofResponse) GetResult() Result
- func (*GenFinalProofResponse) ProtoMessage()
- func (x *GenFinalProofResponse) ProtoReflect() protoreflect.Message
- func (x *GenFinalProofResponse) Reset()
- func (x *GenFinalProofResponse) String() string
- type GenStatelessBatchProofRequest
- func (*GenStatelessBatchProofRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GenStatelessBatchProofRequest) GetInput() *StatelessInputProver
- func (*GenStatelessBatchProofRequest) ProtoMessage()
- func (x *GenStatelessBatchProofRequest) ProtoReflect() protoreflect.Message
- func (x *GenStatelessBatchProofRequest) Reset()
- func (x *GenStatelessBatchProofRequest) String() string
- type GetProofRequest
- func (*GetProofRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetProofRequest) GetId() string
- func (x *GetProofRequest) GetTimeout() uint64
- func (*GetProofRequest) ProtoMessage()
- func (x *GetProofRequest) ProtoReflect() protoreflect.Message
- func (x *GetProofRequest) Reset()
- func (x *GetProofRequest) String() string
- type GetProofResponse
- func (*GetProofResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetProofResponse) GetFinalProof() *FinalProof
- func (x *GetProofResponse) GetId() string
- func (m *GetProofResponse) GetProof() isGetProofResponse_Proof
- func (x *GetProofResponse) GetRecursiveProof() string
- func (x *GetProofResponse) GetResult() GetProofResponse_Result
- func (x *GetProofResponse) GetResultString() string
- func (*GetProofResponse) ProtoMessage()
- func (x *GetProofResponse) ProtoReflect() protoreflect.Message
- func (x *GetProofResponse) Reset()
- func (x *GetProofResponse) String() string
- type GetProofResponse_FinalProof
- type GetProofResponse_RecursiveProof
- type GetProofResponse_Result
- func (GetProofResponse_Result) Descriptor() protoreflect.EnumDescriptor
- func (x GetProofResponse_Result) Enum() *GetProofResponse_Result
- func (GetProofResponse_Result) EnumDescriptor() ([]byte, []int)deprecated
- func (x GetProofResponse_Result) Number() protoreflect.EnumNumber
- func (x GetProofResponse_Result) String() string
- func (GetProofResponse_Result) Type() protoreflect.EnumType
- type GetStatusRequest
- type GetStatusResponse
- func (*GetStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusResponse) GetCurrentComputingRequestId() string
- func (x *GetStatusResponse) GetCurrentComputingStartTime() uint64
- func (x *GetStatusResponse) GetForkId() uint64
- func (x *GetStatusResponse) GetFreeMemory() uint64
- func (x *GetStatusResponse) GetLastComputedEndTime() uint64
- func (x *GetStatusResponse) GetLastComputedRequestId() string
- func (x *GetStatusResponse) GetNumberOfCores() uint64
- func (x *GetStatusResponse) GetPendingRequestQueueIds() []string
- func (x *GetStatusResponse) GetProverId() string
- func (x *GetStatusResponse) GetProverName() string
- func (x *GetStatusResponse) GetStatus() GetStatusResponse_Status
- func (x *GetStatusResponse) GetTotalMemory() uint64
- func (x *GetStatusResponse) GetVersionProto() string
- func (x *GetStatusResponse) GetVersionServer() string
- func (*GetStatusResponse) ProtoMessage()
- func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusResponse) Reset()
- func (x *GetStatusResponse) String() string
- type GetStatusResponse_Status
- func (GetStatusResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x GetStatusResponse_Status) Enum() *GetStatusResponse_Status
- func (GetStatusResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x GetStatusResponse_Status) Number() protoreflect.EnumNumber
- func (x GetStatusResponse_Status) String() string
- func (GetStatusResponse_Status) Type() protoreflect.EnumType
- type InputProver
- func (*InputProver) Descriptor() ([]byte, []int)deprecated
- func (x *InputProver) GetContractsBytecode() map[string]string
- func (x *InputProver) GetDb() map[string]string
- func (x *InputProver) GetPublicInputs() *PublicInputs
- func (*InputProver) ProtoMessage()
- func (x *InputProver) ProtoReflect() protoreflect.Message
- func (x *InputProver) Reset()
- func (x *InputProver) String() string
- type L1Data
- func (*L1Data) Descriptor() ([]byte, []int)deprecated
- func (x *L1Data) GetBlockhashL1() []byte
- func (x *L1Data) GetGlobalExitRoot() []byte
- func (x *L1Data) GetMinTimestamp() uint32
- func (x *L1Data) GetSmtProof() [][]byte
- func (*L1Data) ProtoMessage()
- func (x *L1Data) ProtoReflect() protoreflect.Message
- func (x *L1Data) Reset()
- func (x *L1Data) String() string
- type Prover
- func (p *Prover) Addr() string
- func (p *Prover) AggregatedProof(inputProof1, inputProof2 string) (*string, error)
- func (p *Prover) BatchProof(input *StatelessInputProver) (*string, error)
- func (p *Prover) CancelProofRequest(proofID string) error
- func (p *Prover) FinalProof(inputProof string, aggregatorAddr string) (*string, error)
- func (p *Prover) ID() string
- func (p *Prover) IsIdle() (bool, error)
- func (p *Prover) Name() string
- func (p *Prover) Status() (*GetStatusResponse, error)
- func (p *Prover) SupportsForkID(forkID uint64) bool
- func (p *Prover) WaitFinalProof(ctx context.Context, proofID string) (*FinalProof, error)
- func (p *Prover) WaitRecursiveProof(ctx context.Context, proofID string) (string, common.Hash, error)
- type ProverMessage
- func (*ProverMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ProverMessage) GetCancelResponse() *CancelResponse
- func (x *ProverMessage) GetGenAggregatedProofResponse() *GenAggregatedProofResponse
- func (x *ProverMessage) GetGenBatchProofResponse() *GenBatchProofResponse
- func (x *ProverMessage) GetGenFinalProofResponse() *GenFinalProofResponse
- func (x *ProverMessage) GetGetProofResponse() *GetProofResponse
- func (x *ProverMessage) GetGetStatusResponse() *GetStatusResponse
- func (x *ProverMessage) GetId() string
- func (m *ProverMessage) GetResponse() isProverMessage_Response
- func (*ProverMessage) ProtoMessage()
- func (x *ProverMessage) ProtoReflect() protoreflect.Message
- func (x *ProverMessage) Reset()
- func (x *ProverMessage) String() string
- type ProverMessage_CancelResponse
- type ProverMessage_GenAggregatedProofResponse
- type ProverMessage_GenBatchProofResponse
- type ProverMessage_GenFinalProofResponse
- type ProverMessage_GetProofResponse
- type ProverMessage_GetStatusResponse
- type PublicInputs
- func (*PublicInputs) Descriptor() ([]byte, []int)deprecated
- func (x *PublicInputs) GetAggregatorAddr() string
- func (x *PublicInputs) GetBatchL2Data() []byte
- func (x *PublicInputs) GetChainId() uint64
- func (x *PublicInputs) GetForcedBlockhashL1() []byte
- func (x *PublicInputs) GetForkId() uint64
- func (x *PublicInputs) GetL1InfoRoot() []byte
- func (x *PublicInputs) GetL1InfoTreeData() map[uint32]*L1Data
- func (x *PublicInputs) GetOldAccInputHash() []byte
- func (x *PublicInputs) GetOldBatchNum() uint64
- func (x *PublicInputs) GetOldStateRoot() []byte
- func (x *PublicInputs) GetSequencerAddr() string
- func (x *PublicInputs) GetTimestampLimit() uint64
- func (*PublicInputs) ProtoMessage()
- func (x *PublicInputs) ProtoReflect() protoreflect.Message
- func (x *PublicInputs) Reset()
- func (x *PublicInputs) String() string
- type PublicInputsExtended
- func (*PublicInputsExtended) Descriptor() ([]byte, []int)deprecated
- func (x *PublicInputsExtended) GetNewAccInputHash() []byte
- func (x *PublicInputsExtended) GetNewBatchNum() uint64
- func (x *PublicInputsExtended) GetNewLocalExitRoot() []byte
- func (x *PublicInputsExtended) GetNewStateRoot() []byte
- func (x *PublicInputsExtended) GetPublicInputs() *PublicInputs
- func (*PublicInputsExtended) ProtoMessage()
- func (x *PublicInputsExtended) ProtoReflect() protoreflect.Message
- func (x *PublicInputsExtended) Reset()
- func (x *PublicInputsExtended) String() string
- type Result
- type StatelessInputProver
- func (*StatelessInputProver) Descriptor() ([]byte, []int)deprecated
- func (x *StatelessInputProver) GetPublicInputs() *StatelessPublicInputs
- func (*StatelessInputProver) ProtoMessage()
- func (x *StatelessInputProver) ProtoReflect() protoreflect.Message
- func (x *StatelessInputProver) Reset()
- func (x *StatelessInputProver) String() string
- type StatelessPublicInputs
- func (*StatelessPublicInputs) Descriptor() ([]byte, []int)deprecated
- func (x *StatelessPublicInputs) GetAggregatorAddr() string
- func (x *StatelessPublicInputs) GetBatchL2Data() []byte
- func (x *StatelessPublicInputs) GetChainId() uint64
- func (x *StatelessPublicInputs) GetForcedBlockhashL1() []byte
- func (x *StatelessPublicInputs) GetForkId() uint64
- func (x *StatelessPublicInputs) GetL1InfoRoot() []byte
- func (x *StatelessPublicInputs) GetL1InfoTreeData() map[uint32]*L1Data
- func (x *StatelessPublicInputs) GetOldAccInputHash() []byte
- func (x *StatelessPublicInputs) GetOldBatchNum() uint64
- func (x *StatelessPublicInputs) GetSequencerAddr() string
- func (x *StatelessPublicInputs) GetTimestampLimit() uint64
- func (x *StatelessPublicInputs) GetWitness() []byte
- func (*StatelessPublicInputs) ProtoMessage()
- func (x *StatelessPublicInputs) ProtoReflect() protoreflect.Message
- func (x *StatelessPublicInputs) Reset()
- func (x *StatelessPublicInputs) String() string
- type UnimplementedAggregatorServiceServer
- type UnsafeAggregatorServiceServer
- type Version
Constants ¶
const (
AggregatorService_Channel_FullMethodName = "/aggregator.v1.AggregatorService/Channel"
)
Variables ¶
var ( Result_name = map[int32]string{ 0: "RESULT_UNSPECIFIED", 1: "RESULT_OK", 2: "RESULT_ERROR", 3: "RESULT_INTERNAL_ERROR", } Result_value = map[string]int32{ "RESULT_UNSPECIFIED": 0, "RESULT_OK": 1, "RESULT_ERROR": 2, "RESULT_INTERNAL_ERROR": 3, } )
Enum value maps for Result.
var ( GetStatusResponse_Status_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "STATUS_BOOTING", 2: "STATUS_COMPUTING", 3: "STATUS_IDLE", 4: "STATUS_HALT", } GetStatusResponse_Status_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "STATUS_BOOTING": 1, "STATUS_COMPUTING": 2, "STATUS_IDLE": 3, "STATUS_HALT": 4, } )
Enum value maps for GetStatusResponse_Status.
var ( GetProofResponse_Result_name = map[int32]string{ 0: "RESULT_UNSPECIFIED", 1: "RESULT_COMPLETED_OK", 2: "RESULT_ERROR", 3: "RESULT_COMPLETED_ERROR", 4: "RESULT_PENDING", 5: "RESULT_INTERNAL_ERROR", 6: "RESULT_CANCEL", } GetProofResponse_Result_value = map[string]int32{ "RESULT_UNSPECIFIED": 0, "RESULT_COMPLETED_OK": 1, "RESULT_ERROR": 2, "RESULT_COMPLETED_ERROR": 3, "RESULT_PENDING": 4, "RESULT_INTERNAL_ERROR": 5, "RESULT_CANCEL": 6, } )
Enum value maps for GetProofResponse_Result.
var ( ErrBadProverResponse = errors.New("prover returned wrong type for response") //nolint:revive ErrProverInternalError = errors.New("prover returned INTERNAL_ERROR response") //nolint:revive ErrProverCompletedError = errors.New("prover returned COMPLETED_ERROR response") //nolint:revive ErrBadRequest = errors.New("prover returned ERROR for a bad request") //nolint:revive ErrUnspecified = errors.New("prover returned an UNSPECIFIED response") //nolint:revive ErrUnknown = errors.New("prover returned an unknown response") //nolint:revive ErrProofCanceled = errors.New("proof has been canceled") //nolint:revive )
var AggregatorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aggregator.v1.AggregatorService", HandlerType: (*AggregatorServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Channel", Handler: _AggregatorService_Channel_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "aggregator.proto", }
AggregatorService_ServiceDesc is the grpc.ServiceDesc for AggregatorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_aggregator_proto protoreflect.FileDescriptor
Functions ¶
func GetStateRootFromProof ¶
GetStateRootFromProof returns the state root from the proof.
func RegisterAggregatorServiceServer ¶
func RegisterAggregatorServiceServer(s grpc.ServiceRegistrar, srv AggregatorServiceServer)
Types ¶
type AggregatorMessage ¶
type AggregatorMessage struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Request: // // *AggregatorMessage_GetStatusRequest // *AggregatorMessage_GenBatchProofRequest // *AggregatorMessage_GenAggregatedProofRequest // *AggregatorMessage_GenFinalProofRequest // *AggregatorMessage_CancelRequest // *AggregatorMessage_GetProofRequest // *AggregatorMessage_GenStatelessBatchProofRequest Request isAggregatorMessage_Request `protobuf_oneof:"request"` // contains filtered or unexported fields }
func (*AggregatorMessage) Descriptor
deprecated
func (*AggregatorMessage) Descriptor() ([]byte, []int)
Deprecated: Use AggregatorMessage.ProtoReflect.Descriptor instead.
func (*AggregatorMessage) GetCancelRequest ¶
func (x *AggregatorMessage) GetCancelRequest() *CancelRequest
func (*AggregatorMessage) GetGenAggregatedProofRequest ¶
func (x *AggregatorMessage) GetGenAggregatedProofRequest() *GenAggregatedProofRequest
func (*AggregatorMessage) GetGenBatchProofRequest ¶
func (x *AggregatorMessage) GetGenBatchProofRequest() *GenBatchProofRequest
func (*AggregatorMessage) GetGenFinalProofRequest ¶
func (x *AggregatorMessage) GetGenFinalProofRequest() *GenFinalProofRequest
func (*AggregatorMessage) GetGenStatelessBatchProofRequest ¶
func (x *AggregatorMessage) GetGenStatelessBatchProofRequest() *GenStatelessBatchProofRequest
func (*AggregatorMessage) GetGetProofRequest ¶
func (x *AggregatorMessage) GetGetProofRequest() *GetProofRequest
func (*AggregatorMessage) GetGetStatusRequest ¶
func (x *AggregatorMessage) GetGetStatusRequest() *GetStatusRequest
func (*AggregatorMessage) GetId ¶
func (x *AggregatorMessage) GetId() string
func (*AggregatorMessage) GetRequest ¶
func (m *AggregatorMessage) GetRequest() isAggregatorMessage_Request
func (*AggregatorMessage) ProtoMessage ¶
func (*AggregatorMessage) ProtoMessage()
func (*AggregatorMessage) ProtoReflect ¶
func (x *AggregatorMessage) ProtoReflect() protoreflect.Message
func (*AggregatorMessage) Reset ¶
func (x *AggregatorMessage) Reset()
func (*AggregatorMessage) String ¶
func (x *AggregatorMessage) String() string
type AggregatorMessage_CancelRequest ¶
type AggregatorMessage_CancelRequest struct {
CancelRequest *CancelRequest `protobuf:"bytes,6,opt,name=cancel_request,json=cancelRequest,proto3,oneof"`
}
type AggregatorMessage_GenAggregatedProofRequest ¶
type AggregatorMessage_GenAggregatedProofRequest struct {
GenAggregatedProofRequest *GenAggregatedProofRequest `protobuf:"bytes,4,opt,name=gen_aggregated_proof_request,json=genAggregatedProofRequest,proto3,oneof"`
}
type AggregatorMessage_GenBatchProofRequest ¶
type AggregatorMessage_GenBatchProofRequest struct {
GenBatchProofRequest *GenBatchProofRequest `protobuf:"bytes,3,opt,name=gen_batch_proof_request,json=genBatchProofRequest,proto3,oneof"`
}
type AggregatorMessage_GenFinalProofRequest ¶
type AggregatorMessage_GenFinalProofRequest struct {
GenFinalProofRequest *GenFinalProofRequest `protobuf:"bytes,5,opt,name=gen_final_proof_request,json=genFinalProofRequest,proto3,oneof"`
}
type AggregatorMessage_GenStatelessBatchProofRequest ¶
type AggregatorMessage_GenStatelessBatchProofRequest struct {
GenStatelessBatchProofRequest *GenStatelessBatchProofRequest `protobuf:"bytes,8,opt,name=gen_stateless_batch_proof_request,json=genStatelessBatchProofRequest,proto3,oneof"`
}
type AggregatorMessage_GetProofRequest ¶
type AggregatorMessage_GetProofRequest struct {
GetProofRequest *GetProofRequest `protobuf:"bytes,7,opt,name=get_proof_request,json=getProofRequest,proto3,oneof"`
}
type AggregatorMessage_GetStatusRequest ¶
type AggregatorMessage_GetStatusRequest struct {
GetStatusRequest *GetStatusRequest `protobuf:"bytes,2,opt,name=get_status_request,json=getStatusRequest,proto3,oneof"`
}
type AggregatorServiceClient ¶
type AggregatorServiceClient interface {
Channel(ctx context.Context, opts ...grpc.CallOption) (AggregatorService_ChannelClient, error)
}
AggregatorServiceClient is the client API for AggregatorService 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.
* Define all methods implementes by the gRPC Channel: prover receives aggregator messages and returns prover messages with the same id
func NewAggregatorServiceClient ¶
func NewAggregatorServiceClient(cc grpc.ClientConnInterface) AggregatorServiceClient
type AggregatorServiceServer ¶
type AggregatorServiceServer interface { Channel(AggregatorService_ChannelServer) error // contains filtered or unexported methods }
AggregatorServiceServer is the server API for AggregatorService service. All implementations must embed UnimplementedAggregatorServiceServer for forward compatibility
* Define all methods implementes by the gRPC Channel: prover receives aggregator messages and returns prover messages with the same id
type AggregatorService_ChannelClient ¶
type AggregatorService_ChannelClient interface { Send(*ProverMessage) error Recv() (*AggregatorMessage, error) grpc.ClientStream }
type AggregatorService_ChannelServer ¶
type AggregatorService_ChannelServer interface { Send(*AggregatorMessage) error Recv() (*ProverMessage, error) grpc.ServerStream }
type CancelRequest ¶
type CancelRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
* @dev CancelRequest @param {id} - identifier of the proof request to cancel
func (*CancelRequest) Descriptor
deprecated
func (*CancelRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelRequest.ProtoReflect.Descriptor instead.
func (*CancelRequest) GetId ¶
func (x *CancelRequest) GetId() string
func (*CancelRequest) ProtoMessage ¶
func (*CancelRequest) ProtoMessage()
func (*CancelRequest) ProtoReflect ¶
func (x *CancelRequest) ProtoReflect() protoreflect.Message
func (*CancelRequest) Reset ¶
func (x *CancelRequest) Reset()
func (*CancelRequest) String ¶
func (x *CancelRequest) String() string
type CancelResponse ¶
type CancelResponse struct { Result Result `protobuf:"varint,1,opt,name=result,proto3,enum=aggregator.v1.Result" json:"result,omitempty"` // contains filtered or unexported fields }
* @dev CancelResponse @param {result} - request result
func (*CancelResponse) Descriptor
deprecated
func (*CancelResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelResponse.ProtoReflect.Descriptor instead.
func (*CancelResponse) GetResult ¶
func (x *CancelResponse) GetResult() Result
func (*CancelResponse) ProtoMessage ¶
func (*CancelResponse) ProtoMessage()
func (*CancelResponse) ProtoReflect ¶
func (x *CancelResponse) ProtoReflect() protoreflect.Message
func (*CancelResponse) Reset ¶
func (x *CancelResponse) Reset()
func (*CancelResponse) String ¶
func (x *CancelResponse) String() string
type FinalProof ¶
type FinalProof struct { Proof string `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"` Public *PublicInputsExtended `protobuf:"bytes,2,opt,name=public,proto3" json:"public,omitempty"` // contains filtered or unexported fields }
@dev FinalProof @param {proof} - groth16 proof @param {public} - public circuit inputs
func (*FinalProof) Descriptor
deprecated
func (*FinalProof) Descriptor() ([]byte, []int)
Deprecated: Use FinalProof.ProtoReflect.Descriptor instead.
func (*FinalProof) GetProof ¶
func (x *FinalProof) GetProof() string
func (*FinalProof) GetPublic ¶
func (x *FinalProof) GetPublic() *PublicInputsExtended
func (*FinalProof) ProtoMessage ¶
func (*FinalProof) ProtoMessage()
func (*FinalProof) ProtoReflect ¶
func (x *FinalProof) ProtoReflect() protoreflect.Message
func (*FinalProof) Reset ¶
func (x *FinalProof) Reset()
func (*FinalProof) String ¶
func (x *FinalProof) String() string
type GenAggregatedProofRequest ¶
type GenAggregatedProofRequest struct { RecursiveProof_1 string `protobuf:"bytes,1,opt,name=recursive_proof_1,json=recursiveProof1,proto3" json:"recursive_proof_1,omitempty"` RecursiveProof_2 string `protobuf:"bytes,2,opt,name=recursive_proof_2,json=recursiveProof2,proto3" json:"recursive_proof_2,omitempty"` // contains filtered or unexported fields }
* @dev GenAggregatedProofRequest @param {recursive_proof_1} - proof json of the first batch to aggregate @param {recursive_proof_2} - proof json of the second batch to aggregate
func (*GenAggregatedProofRequest) Descriptor
deprecated
func (*GenAggregatedProofRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenAggregatedProofRequest.ProtoReflect.Descriptor instead.
func (*GenAggregatedProofRequest) GetRecursiveProof_1 ¶
func (x *GenAggregatedProofRequest) GetRecursiveProof_1() string
func (*GenAggregatedProofRequest) GetRecursiveProof_2 ¶
func (x *GenAggregatedProofRequest) GetRecursiveProof_2() string
func (*GenAggregatedProofRequest) ProtoMessage ¶
func (*GenAggregatedProofRequest) ProtoMessage()
func (*GenAggregatedProofRequest) ProtoReflect ¶
func (x *GenAggregatedProofRequest) ProtoReflect() protoreflect.Message
func (*GenAggregatedProofRequest) Reset ¶
func (x *GenAggregatedProofRequest) Reset()
func (*GenAggregatedProofRequest) String ¶
func (x *GenAggregatedProofRequest) String() string
type GenAggregatedProofResponse ¶
type GenAggregatedProofResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=aggregator.v1.Result" json:"result,omitempty"` // contains filtered or unexported fields }
* @dev GenAggregatedProofResponse @param {id} - proof identifier, to be used in GetProofRequest() @param {result} - request result
func (*GenAggregatedProofResponse) Descriptor
deprecated
func (*GenAggregatedProofResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenAggregatedProofResponse.ProtoReflect.Descriptor instead.
func (*GenAggregatedProofResponse) GetId ¶
func (x *GenAggregatedProofResponse) GetId() string
func (*GenAggregatedProofResponse) GetResult ¶
func (x *GenAggregatedProofResponse) GetResult() Result
func (*GenAggregatedProofResponse) ProtoMessage ¶
func (*GenAggregatedProofResponse) ProtoMessage()
func (*GenAggregatedProofResponse) ProtoReflect ¶
func (x *GenAggregatedProofResponse) ProtoReflect() protoreflect.Message
func (*GenAggregatedProofResponse) Reset ¶
func (x *GenAggregatedProofResponse) Reset()
func (*GenAggregatedProofResponse) String ¶
func (x *GenAggregatedProofResponse) String() string
type GenBatchProofRequest ¶
type GenBatchProofRequest struct { Input *InputProver `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"` // contains filtered or unexported fields }
* @dev GenBatchProofRequest @param {input} - input prover
func (*GenBatchProofRequest) Descriptor
deprecated
func (*GenBatchProofRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenBatchProofRequest.ProtoReflect.Descriptor instead.
func (*GenBatchProofRequest) GetInput ¶
func (x *GenBatchProofRequest) GetInput() *InputProver
func (*GenBatchProofRequest) ProtoMessage ¶
func (*GenBatchProofRequest) ProtoMessage()
func (*GenBatchProofRequest) ProtoReflect ¶
func (x *GenBatchProofRequest) ProtoReflect() protoreflect.Message
func (*GenBatchProofRequest) Reset ¶
func (x *GenBatchProofRequest) Reset()
func (*GenBatchProofRequest) String ¶
func (x *GenBatchProofRequest) String() string
type GenBatchProofResponse ¶
type GenBatchProofResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=aggregator.v1.Result" json:"result,omitempty"` // contains filtered or unexported fields }
* @dev GenBatchProofResponse @param {id} - proof identifier, to be used in GetProofRequest() @param {result} - request result
func (*GenBatchProofResponse) Descriptor
deprecated
func (*GenBatchProofResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenBatchProofResponse.ProtoReflect.Descriptor instead.
func (*GenBatchProofResponse) GetId ¶
func (x *GenBatchProofResponse) GetId() string
func (*GenBatchProofResponse) GetResult ¶
func (x *GenBatchProofResponse) GetResult() Result
func (*GenBatchProofResponse) ProtoMessage ¶
func (*GenBatchProofResponse) ProtoMessage()
func (*GenBatchProofResponse) ProtoReflect ¶
func (x *GenBatchProofResponse) ProtoReflect() protoreflect.Message
func (*GenBatchProofResponse) Reset ¶
func (x *GenBatchProofResponse) Reset()
func (*GenBatchProofResponse) String ¶
func (x *GenBatchProofResponse) String() string
type GenFinalProofRequest ¶
type GenFinalProofRequest struct { RecursiveProof string `protobuf:"bytes,1,opt,name=recursive_proof,json=recursiveProof,proto3" json:"recursive_proof,omitempty"` AggregatorAddr string `protobuf:"bytes,2,opt,name=aggregator_addr,json=aggregatorAddr,proto3" json:"aggregator_addr,omitempty"` // contains filtered or unexported fields }
* @dev GenFinalProofRequest @param {recursive_proof} - proof json of the batch or aggregated proof to finalise @param {aggregator_addr} - address of the aggregator
func (*GenFinalProofRequest) Descriptor
deprecated
func (*GenFinalProofRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenFinalProofRequest.ProtoReflect.Descriptor instead.
func (*GenFinalProofRequest) GetAggregatorAddr ¶
func (x *GenFinalProofRequest) GetAggregatorAddr() string
func (*GenFinalProofRequest) GetRecursiveProof ¶
func (x *GenFinalProofRequest) GetRecursiveProof() string
func (*GenFinalProofRequest) ProtoMessage ¶
func (*GenFinalProofRequest) ProtoMessage()
func (*GenFinalProofRequest) ProtoReflect ¶
func (x *GenFinalProofRequest) ProtoReflect() protoreflect.Message
func (*GenFinalProofRequest) Reset ¶
func (x *GenFinalProofRequest) Reset()
func (*GenFinalProofRequest) String ¶
func (x *GenFinalProofRequest) String() string
type GenFinalProofResponse ¶
type GenFinalProofResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Result Result `protobuf:"varint,2,opt,name=result,proto3,enum=aggregator.v1.Result" json:"result,omitempty"` // contains filtered or unexported fields }
* @dev Response GenFinalProof @param {id} - proof identifier, to be used in GetProofRequest() @param {result} - request result
func (*GenFinalProofResponse) Descriptor
deprecated
func (*GenFinalProofResponse) Descriptor() ([]byte, []int)
Deprecated: Use GenFinalProofResponse.ProtoReflect.Descriptor instead.
func (*GenFinalProofResponse) GetId ¶
func (x *GenFinalProofResponse) GetId() string
func (*GenFinalProofResponse) GetResult ¶
func (x *GenFinalProofResponse) GetResult() Result
func (*GenFinalProofResponse) ProtoMessage ¶
func (*GenFinalProofResponse) ProtoMessage()
func (*GenFinalProofResponse) ProtoReflect ¶
func (x *GenFinalProofResponse) ProtoReflect() protoreflect.Message
func (*GenFinalProofResponse) Reset ¶
func (x *GenFinalProofResponse) Reset()
func (*GenFinalProofResponse) String ¶
func (x *GenFinalProofResponse) String() string
type GenStatelessBatchProofRequest ¶
type GenStatelessBatchProofRequest struct { Input *StatelessInputProver `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"` // contains filtered or unexported fields }
func (*GenStatelessBatchProofRequest) Descriptor
deprecated
func (*GenStatelessBatchProofRequest) Descriptor() ([]byte, []int)
Deprecated: Use GenStatelessBatchProofRequest.ProtoReflect.Descriptor instead.
func (*GenStatelessBatchProofRequest) GetInput ¶
func (x *GenStatelessBatchProofRequest) GetInput() *StatelessInputProver
func (*GenStatelessBatchProofRequest) ProtoMessage ¶
func (*GenStatelessBatchProofRequest) ProtoMessage()
func (*GenStatelessBatchProofRequest) ProtoReflect ¶
func (x *GenStatelessBatchProofRequest) ProtoReflect() protoreflect.Message
func (*GenStatelessBatchProofRequest) Reset ¶
func (x *GenStatelessBatchProofRequest) Reset()
func (*GenStatelessBatchProofRequest) String ¶
func (x *GenStatelessBatchProofRequest) String() string
type GetProofRequest ¶
type GetProofRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Timeout uint64 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
* @dev Request GetProof @param {id} - proof identifier of the proof request @param {timeout} - time to wait until the service responds
func (*GetProofRequest) Descriptor
deprecated
func (*GetProofRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetProofRequest.ProtoReflect.Descriptor instead.
func (*GetProofRequest) GetId ¶
func (x *GetProofRequest) GetId() string
func (*GetProofRequest) GetTimeout ¶
func (x *GetProofRequest) GetTimeout() uint64
func (*GetProofRequest) ProtoMessage ¶
func (*GetProofRequest) ProtoMessage()
func (*GetProofRequest) ProtoReflect ¶
func (x *GetProofRequest) ProtoReflect() protoreflect.Message
func (*GetProofRequest) Reset ¶
func (x *GetProofRequest) Reset()
func (*GetProofRequest) String ¶
func (x *GetProofRequest) String() string
type GetProofResponse ¶
type GetProofResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Proof: // // *GetProofResponse_FinalProof // *GetProofResponse_RecursiveProof Proof isGetProofResponse_Proof `protobuf_oneof:"proof"` Result GetProofResponse_Result `protobuf:"varint,4,opt,name=result,proto3,enum=aggregator.v1.GetProofResponse_Result" json:"result,omitempty"` ResultString string `protobuf:"bytes,5,opt,name=result_string,json=resultString,proto3" json:"result_string,omitempty"` // contains filtered or unexported fields }
* @dev GetProofResponse @param {id} - proof identifier @param {final_proof} - groth16 proof + public circuit inputs @param {recursive_proof} - recursive proof json @param {result} - proof result
- COMPLETED_OK: proof has been computed successfully and it is valid
- ERROR: request error
- COMPLETED_ERROR: proof has been computed successfully and it is not valid
- PENDING: proof is being computed
- INTERNAL_ERROR: server error during proof computation
- CANCEL: proof has been cancelled
@param {result_string} - extends result information
func (*GetProofResponse) Descriptor
deprecated
func (*GetProofResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetProofResponse.ProtoReflect.Descriptor instead.
func (*GetProofResponse) GetFinalProof ¶
func (x *GetProofResponse) GetFinalProof() *FinalProof
func (*GetProofResponse) GetId ¶
func (x *GetProofResponse) GetId() string
func (*GetProofResponse) GetProof ¶
func (m *GetProofResponse) GetProof() isGetProofResponse_Proof
func (*GetProofResponse) GetRecursiveProof ¶
func (x *GetProofResponse) GetRecursiveProof() string
func (*GetProofResponse) GetResult ¶
func (x *GetProofResponse) GetResult() GetProofResponse_Result
func (*GetProofResponse) GetResultString ¶
func (x *GetProofResponse) GetResultString() string
func (*GetProofResponse) ProtoMessage ¶
func (*GetProofResponse) ProtoMessage()
func (*GetProofResponse) ProtoReflect ¶
func (x *GetProofResponse) ProtoReflect() protoreflect.Message
func (*GetProofResponse) Reset ¶
func (x *GetProofResponse) Reset()
func (*GetProofResponse) String ¶
func (x *GetProofResponse) String() string
type GetProofResponse_FinalProof ¶
type GetProofResponse_FinalProof struct {
FinalProof *FinalProof `protobuf:"bytes,2,opt,name=final_proof,json=finalProof,proto3,oneof"`
}
type GetProofResponse_RecursiveProof ¶
type GetProofResponse_RecursiveProof struct {
RecursiveProof string `protobuf:"bytes,3,opt,name=recursive_proof,json=recursiveProof,proto3,oneof"`
}
type GetProofResponse_Result ¶
type GetProofResponse_Result int32
const ( GetProofResponse_RESULT_UNSPECIFIED GetProofResponse_Result = 0 GetProofResponse_RESULT_COMPLETED_OK GetProofResponse_Result = 1 GetProofResponse_RESULT_ERROR GetProofResponse_Result = 2 GetProofResponse_RESULT_COMPLETED_ERROR GetProofResponse_Result = 3 GetProofResponse_RESULT_PENDING GetProofResponse_Result = 4 GetProofResponse_RESULT_INTERNAL_ERROR GetProofResponse_Result = 5 GetProofResponse_RESULT_CANCEL GetProofResponse_Result = 6 )
func (GetProofResponse_Result) Descriptor ¶
func (GetProofResponse_Result) Descriptor() protoreflect.EnumDescriptor
func (GetProofResponse_Result) Enum ¶
func (x GetProofResponse_Result) Enum() *GetProofResponse_Result
func (GetProofResponse_Result) EnumDescriptor
deprecated
func (GetProofResponse_Result) EnumDescriptor() ([]byte, []int)
Deprecated: Use GetProofResponse_Result.Descriptor instead.
func (GetProofResponse_Result) Number ¶
func (x GetProofResponse_Result) Number() protoreflect.EnumNumber
func (GetProofResponse_Result) String ¶
func (x GetProofResponse_Result) String() string
func (GetProofResponse_Result) Type ¶
func (GetProofResponse_Result) Type() protoreflect.EnumType
type GetStatusRequest ¶
type GetStatusRequest struct {
// contains filtered or unexported fields
}
* @dev GetStatusRequest
func (*GetStatusRequest) Descriptor
deprecated
func (*GetStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.
func (*GetStatusRequest) ProtoMessage ¶
func (*GetStatusRequest) ProtoMessage()
func (*GetStatusRequest) ProtoReflect ¶
func (x *GetStatusRequest) ProtoReflect() protoreflect.Message
func (*GetStatusRequest) Reset ¶
func (x *GetStatusRequest) Reset()
func (*GetStatusRequest) String ¶
func (x *GetStatusRequest) String() string
type GetStatusResponse ¶
type GetStatusResponse struct { Status GetStatusResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=aggregator.v1.GetStatusResponse_Status" json:"status,omitempty"` LastComputedRequestId string `` /* 128-byte string literal not displayed */ LastComputedEndTime uint64 `protobuf:"varint,3,opt,name=last_computed_end_time,json=lastComputedEndTime,proto3" json:"last_computed_end_time,omitempty"` CurrentComputingRequestId string `` /* 140-byte string literal not displayed */ CurrentComputingStartTime uint64 `` /* 141-byte string literal not displayed */ VersionProto string `protobuf:"bytes,6,opt,name=version_proto,json=versionProto,proto3" json:"version_proto,omitempty"` VersionServer string `protobuf:"bytes,7,opt,name=version_server,json=versionServer,proto3" json:"version_server,omitempty"` PendingRequestQueueIds []string `` /* 131-byte string literal not displayed */ ProverName string `protobuf:"bytes,9,opt,name=prover_name,json=proverName,proto3" json:"prover_name,omitempty"` ProverId string `protobuf:"bytes,10,opt,name=prover_id,json=proverId,proto3" json:"prover_id,omitempty"` NumberOfCores uint64 `protobuf:"varint,11,opt,name=number_of_cores,json=numberOfCores,proto3" json:"number_of_cores,omitempty"` TotalMemory uint64 `protobuf:"varint,12,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"` FreeMemory uint64 `protobuf:"varint,13,opt,name=free_memory,json=freeMemory,proto3" json:"free_memory,omitempty"` ForkId uint64 `protobuf:"varint,14,opt,name=fork_id,json=forkId,proto3" json:"fork_id,omitempty"` // contains filtered or unexported fields }
* @dev Response GetStatus @param {status} - server status - BOOTING: being ready to compute proofs - COMPUTING: busy computing a proof - IDLE: waiting for a proof to compute - HALT: stop @param {last_computed_request_id} - last proof identifier that has been computed @param {last_computed_end_time} - last proof timestamp when it was finished @param {current_computing_request_id} - id of the proof that is being computed @param {current_computing_start_time} - timestamp when the proof that is being computed started @param {version_proto} - .proto verion @param {version_server} - server version @param {pending_request_queue_ids} - list of identifierss of proof requests that are in the pending queue @param {prover_name} - id of this prover server, normally specified via config.json, or UNSPECIFIED otherwise; it does not change if prover reboots @param {prover_id} - id of this prover instance or reboot; it changes if prover reboots; it is a UUID, automatically generated during the initialization @param {number_of_cores} - number of cores in the system where the prover is running @param {total_memory} - total memory in the system where the prover is running @param {free_memory} - free memory in the system where the prover is running
func (*GetStatusResponse) Descriptor
deprecated
func (*GetStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.
func (*GetStatusResponse) GetCurrentComputingRequestId ¶
func (x *GetStatusResponse) GetCurrentComputingRequestId() string
func (*GetStatusResponse) GetCurrentComputingStartTime ¶
func (x *GetStatusResponse) GetCurrentComputingStartTime() uint64
func (*GetStatusResponse) GetForkId ¶
func (x *GetStatusResponse) GetForkId() uint64
func (*GetStatusResponse) GetFreeMemory ¶
func (x *GetStatusResponse) GetFreeMemory() uint64
func (*GetStatusResponse) GetLastComputedEndTime ¶
func (x *GetStatusResponse) GetLastComputedEndTime() uint64
func (*GetStatusResponse) GetLastComputedRequestId ¶
func (x *GetStatusResponse) GetLastComputedRequestId() string
func (*GetStatusResponse) GetNumberOfCores ¶
func (x *GetStatusResponse) GetNumberOfCores() uint64
func (*GetStatusResponse) GetPendingRequestQueueIds ¶
func (x *GetStatusResponse) GetPendingRequestQueueIds() []string
func (*GetStatusResponse) GetProverId ¶
func (x *GetStatusResponse) GetProverId() string
func (*GetStatusResponse) GetProverName ¶
func (x *GetStatusResponse) GetProverName() string
func (*GetStatusResponse) GetStatus ¶
func (x *GetStatusResponse) GetStatus() GetStatusResponse_Status
func (*GetStatusResponse) GetTotalMemory ¶
func (x *GetStatusResponse) GetTotalMemory() uint64
func (*GetStatusResponse) GetVersionProto ¶
func (x *GetStatusResponse) GetVersionProto() string
func (*GetStatusResponse) GetVersionServer ¶
func (x *GetStatusResponse) GetVersionServer() string
func (*GetStatusResponse) ProtoMessage ¶
func (*GetStatusResponse) ProtoMessage()
func (*GetStatusResponse) ProtoReflect ¶
func (x *GetStatusResponse) ProtoReflect() protoreflect.Message
func (*GetStatusResponse) Reset ¶
func (x *GetStatusResponse) Reset()
func (*GetStatusResponse) String ¶
func (x *GetStatusResponse) String() string
type GetStatusResponse_Status ¶
type GetStatusResponse_Status int32
const ( GetStatusResponse_STATUS_UNSPECIFIED GetStatusResponse_Status = 0 GetStatusResponse_STATUS_BOOTING GetStatusResponse_Status = 1 GetStatusResponse_STATUS_COMPUTING GetStatusResponse_Status = 2 GetStatusResponse_STATUS_IDLE GetStatusResponse_Status = 3 GetStatusResponse_STATUS_HALT GetStatusResponse_Status = 4 )
func (GetStatusResponse_Status) Descriptor ¶
func (GetStatusResponse_Status) Descriptor() protoreflect.EnumDescriptor
func (GetStatusResponse_Status) Enum ¶
func (x GetStatusResponse_Status) Enum() *GetStatusResponse_Status
func (GetStatusResponse_Status) EnumDescriptor
deprecated
func (GetStatusResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use GetStatusResponse_Status.Descriptor instead.
func (GetStatusResponse_Status) Number ¶
func (x GetStatusResponse_Status) Number() protoreflect.EnumNumber
func (GetStatusResponse_Status) String ¶
func (x GetStatusResponse_Status) String() string
func (GetStatusResponse_Status) Type ¶
func (GetStatusResponse_Status) Type() protoreflect.EnumType
type InputProver ¶
type InputProver struct { PublicInputs *PublicInputs `protobuf:"bytes,1,opt,name=public_inputs,json=publicInputs,proto3" json:"public_inputs,omitempty"` Db map[string]string `` // For debug/testing purpposes only. Don't fill this on production /* 145-byte string literal not displayed */ ContractsBytecode map[string]string `` // For debug/testing purpposes only. Don't fill this on production /* 200-byte string literal not displayed */ // contains filtered or unexported fields }
* @dev InputProver @param {public_inputs} - public inputs @param {db} - database containing all key-values in smt matching the old state root @param {contracts_bytecode} - key is the hash(contractBytecode), value is the bytecode itself
func (*InputProver) Descriptor
deprecated
func (*InputProver) Descriptor() ([]byte, []int)
Deprecated: Use InputProver.ProtoReflect.Descriptor instead.
func (*InputProver) GetContractsBytecode ¶
func (x *InputProver) GetContractsBytecode() map[string]string
func (*InputProver) GetDb ¶
func (x *InputProver) GetDb() map[string]string
func (*InputProver) GetPublicInputs ¶
func (x *InputProver) GetPublicInputs() *PublicInputs
func (*InputProver) ProtoMessage ¶
func (*InputProver) ProtoMessage()
func (*InputProver) ProtoReflect ¶
func (x *InputProver) ProtoReflect() protoreflect.Message
func (*InputProver) Reset ¶
func (x *InputProver) Reset()
func (*InputProver) String ¶
func (x *InputProver) String() string
type L1Data ¶
type L1Data struct { GlobalExitRoot []byte `protobuf:"bytes,1,opt,name=global_exit_root,json=globalExitRoot,proto3" json:"global_exit_root,omitempty"` BlockhashL1 []byte `protobuf:"bytes,2,opt,name=blockhash_l1,json=blockhashL1,proto3" json:"blockhash_l1,omitempty"` MinTimestamp uint32 `protobuf:"varint,3,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"` SmtProof [][]byte `protobuf:"bytes,4,rep,name=smt_proof,json=smtProof,proto3" json:"smt_proof,omitempty"` // contains filtered or unexported fields }
l1InfoTree leaf values
func (*L1Data) Descriptor
deprecated
func (*L1Data) GetBlockhashL1 ¶
func (*L1Data) GetGlobalExitRoot ¶
func (*L1Data) GetMinTimestamp ¶
func (*L1Data) GetSmtProof ¶
func (*L1Data) ProtoMessage ¶
func (*L1Data) ProtoMessage()
func (*L1Data) ProtoReflect ¶
func (x *L1Data) ProtoReflect() protoreflect.Message
type Prover ¶
type Prover struct {
// contains filtered or unexported fields
}
Prover abstraction of the grpc prover client.
func New ¶
func New(logger *log.Logger, stream AggregatorService_ChannelServer, addr net.Addr, proofStatePollingInterval types.Duration) (*Prover, error)
New returns a new Prover instance.
func (*Prover) AggregatedProof ¶
AggregatedProof instructs the prover to generate an aggregated proof from the two inputs provided. It returns the ID of the proof being computed.
func (*Prover) BatchProof ¶
func (p *Prover) BatchProof(input *StatelessInputProver) (*string, error)
BatchProof instructs the prover to generate a batch proof for the provided input. It returns the ID of the proof being computed.
func (*Prover) CancelProofRequest ¶
CancelProofRequest asks the prover to stop the generation of the proof matching the provided proofID.
func (*Prover) FinalProof ¶
FinalProof instructs the prover to generate a final proof for the given input. It returns the ID of the proof being computed.
func (*Prover) Status ¶
func (p *Prover) Status() (*GetStatusResponse, error)
Status gets the prover status.
func (*Prover) SupportsForkID ¶
SupportsForkID returns true if the prover supports the given fork id.
func (*Prover) WaitFinalProof ¶
WaitFinalProof waits for the final proof to be generated by the prover and returns it.
type ProverMessage ¶
type ProverMessage struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Types that are assignable to Response: // // *ProverMessage_GetStatusResponse // *ProverMessage_GenBatchProofResponse // *ProverMessage_GenAggregatedProofResponse // *ProverMessage_GenFinalProofResponse // *ProverMessage_CancelResponse // *ProverMessage_GetProofResponse Response isProverMessage_Response `protobuf_oneof:"response"` // contains filtered or unexported fields }
func (*ProverMessage) Descriptor
deprecated
func (*ProverMessage) Descriptor() ([]byte, []int)
Deprecated: Use ProverMessage.ProtoReflect.Descriptor instead.
func (*ProverMessage) GetCancelResponse ¶
func (x *ProverMessage) GetCancelResponse() *CancelResponse
func (*ProverMessage) GetGenAggregatedProofResponse ¶
func (x *ProverMessage) GetGenAggregatedProofResponse() *GenAggregatedProofResponse
func (*ProverMessage) GetGenBatchProofResponse ¶
func (x *ProverMessage) GetGenBatchProofResponse() *GenBatchProofResponse
func (*ProverMessage) GetGenFinalProofResponse ¶
func (x *ProverMessage) GetGenFinalProofResponse() *GenFinalProofResponse
func (*ProverMessage) GetGetProofResponse ¶
func (x *ProverMessage) GetGetProofResponse() *GetProofResponse
func (*ProverMessage) GetGetStatusResponse ¶
func (x *ProverMessage) GetGetStatusResponse() *GetStatusResponse
func (*ProverMessage) GetId ¶
func (x *ProverMessage) GetId() string
func (*ProverMessage) GetResponse ¶
func (m *ProverMessage) GetResponse() isProverMessage_Response
func (*ProverMessage) ProtoMessage ¶
func (*ProverMessage) ProtoMessage()
func (*ProverMessage) ProtoReflect ¶
func (x *ProverMessage) ProtoReflect() protoreflect.Message
func (*ProverMessage) Reset ¶
func (x *ProverMessage) Reset()
func (*ProverMessage) String ¶
func (x *ProverMessage) String() string
type ProverMessage_CancelResponse ¶
type ProverMessage_CancelResponse struct {
CancelResponse *CancelResponse `protobuf:"bytes,6,opt,name=cancel_response,json=cancelResponse,proto3,oneof"`
}
type ProverMessage_GenAggregatedProofResponse ¶
type ProverMessage_GenAggregatedProofResponse struct {
GenAggregatedProofResponse *GenAggregatedProofResponse `protobuf:"bytes,4,opt,name=gen_aggregated_proof_response,json=genAggregatedProofResponse,proto3,oneof"`
}
type ProverMessage_GenBatchProofResponse ¶
type ProverMessage_GenBatchProofResponse struct {
GenBatchProofResponse *GenBatchProofResponse `protobuf:"bytes,3,opt,name=gen_batch_proof_response,json=genBatchProofResponse,proto3,oneof"`
}
type ProverMessage_GenFinalProofResponse ¶
type ProverMessage_GenFinalProofResponse struct {
GenFinalProofResponse *GenFinalProofResponse `protobuf:"bytes,5,opt,name=gen_final_proof_response,json=genFinalProofResponse,proto3,oneof"`
}
type ProverMessage_GetProofResponse ¶
type ProverMessage_GetProofResponse struct {
GetProofResponse *GetProofResponse `protobuf:"bytes,7,opt,name=get_proof_response,json=getProofResponse,proto3,oneof"`
}
type ProverMessage_GetStatusResponse ¶
type ProverMessage_GetStatusResponse struct {
GetStatusResponse *GetStatusResponse `protobuf:"bytes,2,opt,name=get_status_response,json=getStatusResponse,proto3,oneof"`
}
type PublicInputs ¶
type PublicInputs struct { OldStateRoot []byte `protobuf:"bytes,1,opt,name=old_state_root,json=oldStateRoot,proto3" json:"old_state_root,omitempty"` OldAccInputHash []byte `protobuf:"bytes,2,opt,name=old_acc_input_hash,json=oldAccInputHash,proto3" json:"old_acc_input_hash,omitempty"` OldBatchNum uint64 `protobuf:"varint,3,opt,name=old_batch_num,json=oldBatchNum,proto3" json:"old_batch_num,omitempty"` ChainId uint64 `protobuf:"varint,4,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` ForkId uint64 `protobuf:"varint,5,opt,name=fork_id,json=forkId,proto3" json:"fork_id,omitempty"` BatchL2Data []byte `protobuf:"bytes,6,opt,name=batch_l2_data,json=batchL2Data,proto3" json:"batch_l2_data,omitempty"` L1InfoRoot []byte `protobuf:"bytes,7,opt,name=l1_info_root,json=l1InfoRoot,proto3" json:"l1_info_root,omitempty"` TimestampLimit uint64 `protobuf:"varint,8,opt,name=timestamp_limit,json=timestampLimit,proto3" json:"timestamp_limit,omitempty"` SequencerAddr string `protobuf:"bytes,9,opt,name=sequencer_addr,json=sequencerAddr,proto3" json:"sequencer_addr,omitempty"` ForcedBlockhashL1 []byte `protobuf:"bytes,10,opt,name=forced_blockhash_l1,json=forcedBlockhashL1,proto3" json:"forced_blockhash_l1,omitempty"` AggregatorAddr string `protobuf:"bytes,12,opt,name=aggregator_addr,json=aggregatorAddr,proto3" json:"aggregator_addr,omitempty"` L1InfoTreeData map[uint32]*L1Data `` /* 197-byte string literal not displayed */ // contains filtered or unexported fields }
@dev PublicInputs @param {old_state_root} @param {old_acc_input_hash} @param {old_batch_num} @param {chain_id} @param {batch_l2_data} @param {global_exit_root} @param {sequencer_addr} @param {aggregator_addr}
func (*PublicInputs) Descriptor
deprecated
func (*PublicInputs) Descriptor() ([]byte, []int)
Deprecated: Use PublicInputs.ProtoReflect.Descriptor instead.
func (*PublicInputs) GetAggregatorAddr ¶
func (x *PublicInputs) GetAggregatorAddr() string
func (*PublicInputs) GetBatchL2Data ¶
func (x *PublicInputs) GetBatchL2Data() []byte
func (*PublicInputs) GetChainId ¶
func (x *PublicInputs) GetChainId() uint64
func (*PublicInputs) GetForcedBlockhashL1 ¶
func (x *PublicInputs) GetForcedBlockhashL1() []byte
func (*PublicInputs) GetForkId ¶
func (x *PublicInputs) GetForkId() uint64
func (*PublicInputs) GetL1InfoRoot ¶
func (x *PublicInputs) GetL1InfoRoot() []byte
func (*PublicInputs) GetL1InfoTreeData ¶
func (x *PublicInputs) GetL1InfoTreeData() map[uint32]*L1Data
func (*PublicInputs) GetOldAccInputHash ¶
func (x *PublicInputs) GetOldAccInputHash() []byte
func (*PublicInputs) GetOldBatchNum ¶
func (x *PublicInputs) GetOldBatchNum() uint64
func (*PublicInputs) GetOldStateRoot ¶
func (x *PublicInputs) GetOldStateRoot() []byte
func (*PublicInputs) GetSequencerAddr ¶
func (x *PublicInputs) GetSequencerAddr() string
func (*PublicInputs) GetTimestampLimit ¶
func (x *PublicInputs) GetTimestampLimit() uint64
func (*PublicInputs) ProtoMessage ¶
func (*PublicInputs) ProtoMessage()
func (*PublicInputs) ProtoReflect ¶
func (x *PublicInputs) ProtoReflect() protoreflect.Message
func (*PublicInputs) Reset ¶
func (x *PublicInputs) Reset()
func (*PublicInputs) String ¶
func (x *PublicInputs) String() string
type PublicInputsExtended ¶
type PublicInputsExtended struct { PublicInputs *PublicInputs `protobuf:"bytes,1,opt,name=public_inputs,json=publicInputs,proto3" json:"public_inputs,omitempty"` NewStateRoot []byte `protobuf:"bytes,2,opt,name=new_state_root,json=newStateRoot,proto3" json:"new_state_root,omitempty"` NewAccInputHash []byte `protobuf:"bytes,3,opt,name=new_acc_input_hash,json=newAccInputHash,proto3" json:"new_acc_input_hash,omitempty"` NewLocalExitRoot []byte `protobuf:"bytes,4,opt,name=new_local_exit_root,json=newLocalExitRoot,proto3" json:"new_local_exit_root,omitempty"` NewBatchNum uint64 `protobuf:"varint,5,opt,name=new_batch_num,json=newBatchNum,proto3" json:"new_batch_num,omitempty"` // contains filtered or unexported fields }
* @dev PublicInputsExtended @param {public_inputs} - public inputs @param {new_state_root} - final state root. Used as a sanity check. @param {new_acc_input_hash} - final accumulate input hash. Used as a sanity check. @param {new_local_exit_root} - new local exit root. Used as a sanity check. @param {new_batch_num} - final num batch. Used as a sanity check.
func (*PublicInputsExtended) Descriptor
deprecated
func (*PublicInputsExtended) Descriptor() ([]byte, []int)
Deprecated: Use PublicInputsExtended.ProtoReflect.Descriptor instead.
func (*PublicInputsExtended) GetNewAccInputHash ¶
func (x *PublicInputsExtended) GetNewAccInputHash() []byte
func (*PublicInputsExtended) GetNewBatchNum ¶
func (x *PublicInputsExtended) GetNewBatchNum() uint64
func (*PublicInputsExtended) GetNewLocalExitRoot ¶
func (x *PublicInputsExtended) GetNewLocalExitRoot() []byte
func (*PublicInputsExtended) GetNewStateRoot ¶
func (x *PublicInputsExtended) GetNewStateRoot() []byte
func (*PublicInputsExtended) GetPublicInputs ¶
func (x *PublicInputsExtended) GetPublicInputs() *PublicInputs
func (*PublicInputsExtended) ProtoMessage ¶
func (*PublicInputsExtended) ProtoMessage()
func (*PublicInputsExtended) ProtoReflect ¶
func (x *PublicInputsExtended) ProtoReflect() protoreflect.Message
func (*PublicInputsExtended) Reset ¶
func (x *PublicInputsExtended) Reset()
func (*PublicInputsExtended) String ¶
func (x *PublicInputsExtended) String() string
type Result ¶
type Result int32
* @dev Result
- OK: succesfully completed
- ERROR: request is not correct, i.e. input data is wrong
- INTERNAL_ERROR: internal server error when delivering the response
func (Result) Descriptor ¶
func (Result) Descriptor() protoreflect.EnumDescriptor
func (Result) EnumDescriptor
deprecated
func (Result) Number ¶
func (x Result) Number() protoreflect.EnumNumber
func (Result) Type ¶
func (Result) Type() protoreflect.EnumType
type StatelessInputProver ¶
type StatelessInputProver struct { PublicInputs *StatelessPublicInputs `protobuf:"bytes,1,opt,name=public_inputs,json=publicInputs,proto3" json:"public_inputs,omitempty"` // contains filtered or unexported fields }
func (*StatelessInputProver) Descriptor
deprecated
func (*StatelessInputProver) Descriptor() ([]byte, []int)
Deprecated: Use StatelessInputProver.ProtoReflect.Descriptor instead.
func (*StatelessInputProver) GetPublicInputs ¶
func (x *StatelessInputProver) GetPublicInputs() *StatelessPublicInputs
func (*StatelessInputProver) ProtoMessage ¶
func (*StatelessInputProver) ProtoMessage()
func (*StatelessInputProver) ProtoReflect ¶
func (x *StatelessInputProver) ProtoReflect() protoreflect.Message
func (*StatelessInputProver) Reset ¶
func (x *StatelessInputProver) Reset()
func (*StatelessInputProver) String ¶
func (x *StatelessInputProver) String() string
type StatelessPublicInputs ¶
type StatelessPublicInputs struct { Witness []byte `protobuf:"bytes,1,opt,name=witness,proto3" json:"witness,omitempty"` OldAccInputHash []byte `protobuf:"bytes,2,opt,name=old_acc_input_hash,json=oldAccInputHash,proto3" json:"old_acc_input_hash,omitempty"` OldBatchNum uint64 `protobuf:"varint,3,opt,name=old_batch_num,json=oldBatchNum,proto3" json:"old_batch_num,omitempty"` ChainId uint64 `protobuf:"varint,4,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` ForkId uint64 `protobuf:"varint,5,opt,name=fork_id,json=forkId,proto3" json:"fork_id,omitempty"` BatchL2Data []byte `protobuf:"bytes,6,opt,name=batch_l2_data,json=batchL2Data,proto3" json:"batch_l2_data,omitempty"` L1InfoRoot []byte `protobuf:"bytes,7,opt,name=l1_info_root,json=l1InfoRoot,proto3" json:"l1_info_root,omitempty"` TimestampLimit uint64 `protobuf:"varint,8,opt,name=timestamp_limit,json=timestampLimit,proto3" json:"timestamp_limit,omitempty"` SequencerAddr string `protobuf:"bytes,9,opt,name=sequencer_addr,json=sequencerAddr,proto3" json:"sequencer_addr,omitempty"` ForcedBlockhashL1 []byte `protobuf:"bytes,10,opt,name=forced_blockhash_l1,json=forcedBlockhashL1,proto3" json:"forced_blockhash_l1,omitempty"` AggregatorAddr string `protobuf:"bytes,11,opt,name=aggregator_addr,json=aggregatorAddr,proto3" json:"aggregator_addr,omitempty"` L1InfoTreeData map[uint32]*L1Data `` /* 197-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StatelessPublicInputs) Descriptor
deprecated
func (*StatelessPublicInputs) Descriptor() ([]byte, []int)
Deprecated: Use StatelessPublicInputs.ProtoReflect.Descriptor instead.
func (*StatelessPublicInputs) GetAggregatorAddr ¶
func (x *StatelessPublicInputs) GetAggregatorAddr() string
func (*StatelessPublicInputs) GetBatchL2Data ¶
func (x *StatelessPublicInputs) GetBatchL2Data() []byte
func (*StatelessPublicInputs) GetChainId ¶
func (x *StatelessPublicInputs) GetChainId() uint64
func (*StatelessPublicInputs) GetForcedBlockhashL1 ¶
func (x *StatelessPublicInputs) GetForcedBlockhashL1() []byte
func (*StatelessPublicInputs) GetForkId ¶
func (x *StatelessPublicInputs) GetForkId() uint64
func (*StatelessPublicInputs) GetL1InfoRoot ¶
func (x *StatelessPublicInputs) GetL1InfoRoot() []byte
func (*StatelessPublicInputs) GetL1InfoTreeData ¶
func (x *StatelessPublicInputs) GetL1InfoTreeData() map[uint32]*L1Data
func (*StatelessPublicInputs) GetOldAccInputHash ¶
func (x *StatelessPublicInputs) GetOldAccInputHash() []byte
func (*StatelessPublicInputs) GetOldBatchNum ¶
func (x *StatelessPublicInputs) GetOldBatchNum() uint64
func (*StatelessPublicInputs) GetSequencerAddr ¶
func (x *StatelessPublicInputs) GetSequencerAddr() string
func (*StatelessPublicInputs) GetTimestampLimit ¶
func (x *StatelessPublicInputs) GetTimestampLimit() uint64
func (*StatelessPublicInputs) GetWitness ¶
func (x *StatelessPublicInputs) GetWitness() []byte
func (*StatelessPublicInputs) ProtoMessage ¶
func (*StatelessPublicInputs) ProtoMessage()
func (*StatelessPublicInputs) ProtoReflect ¶
func (x *StatelessPublicInputs) ProtoReflect() protoreflect.Message
func (*StatelessPublicInputs) Reset ¶
func (x *StatelessPublicInputs) Reset()
func (*StatelessPublicInputs) String ¶
func (x *StatelessPublicInputs) String() string
type UnimplementedAggregatorServiceServer ¶
type UnimplementedAggregatorServiceServer struct { }
UnimplementedAggregatorServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedAggregatorServiceServer) Channel ¶
func (UnimplementedAggregatorServiceServer) Channel(AggregatorService_ChannelServer) error
type UnsafeAggregatorServiceServer ¶
type UnsafeAggregatorServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAggregatorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AggregatorServiceServer will result in compilation errors.
type Version ¶
type Version struct { V0_0_1 string `protobuf:"bytes,1,opt,name=v0_0_1,json=v001,proto3" json:"v0_0_1,omitempty"` // contains filtered or unexported fields }
func (*Version) Descriptor
deprecated
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶
func (x *Version) ProtoReflect() protoreflect.Message