prover

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: AGPL-3.0, AGPL-3.0-or-later Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AggregatorService_Channel_FullMethodName = "/aggregator.v1.AggregatorService/Channel"
)

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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
)
View Source 
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)

View Source 
var File_aggregator_proto protoreflect.FileDescriptor

Functions

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
	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) 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_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.

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

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 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 Prover 

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

Prover abstraction of the grpc prover client.

func New 

func New(stream AggregatorService_ChannelServer, addr net.Addr, proofStatePollingInterval types.Duration) (*Prover, error)

New returns a new Prover instance.

func (*Prover) Addr 

func (p *Prover) Addr() string

Addr returns the prover IP address.

func (*Prover) AggregatedProof 

func (p *Prover) AggregatedProof(inputProof1, inputProof2 string) (*string, error)

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 *InputProver) (*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 

func (p *Prover) CancelProofRequest(proofID string) error

CancelProofRequest asks the prover to stop the generation of the proof matching the provided proofID.

func (*Prover) FinalProof 

func (p *Prover) FinalProof(inputProof string, aggregatorAddr string) (*string, error)

FinalProof instructs the prover to generate a final proof for the given input. It returns the ID of the proof being computed.

func (*Prover) ID 

func (p *Prover) ID() string

ID returns the Prover ID.

func (*Prover) IsIdle 

func (p *Prover) IsIdle() (bool, error)

IsIdle returns true if the prover is idling.

func (*Prover) Name 

func (p *Prover) Name() string

Name returns the Prover name.

func (*Prover) Status 

func (p *Prover) Status() (*GetStatusResponse, error)

Status gets the prover status.

func (*Prover) SupportsForkID 

func (p *Prover) SupportsForkID(forkID uint64) bool

SupportsForkID returns true if the prover supports the given fork id.

func (*Prover) WaitFinalProof 

func (p *Prover) WaitFinalProof(ctx context.Context, proofID string) (*FinalProof, error)

WaitFinalProof waits for the final proof to be generated by the prover and returns it.

func (*Prover) WaitRecursiveProof 

func (p *Prover) WaitRecursiveProof(ctx context.Context, proofID string) (string, error)

WaitRecursiveProof waits for a recursive 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"`
	GlobalExitRoot  []byte `protobuf:"bytes,7,opt,name=global_exit_root,json=globalExitRoot,proto3" json:"global_exit_root,omitempty"`
	EthTimestamp    uint64 `protobuf:"varint,8,opt,name=eth_timestamp,json=ethTimestamp,proto3" json:"eth_timestamp,omitempty"`
	SequencerAddr   string `protobuf:"bytes,9,opt,name=sequencer_addr,json=sequencerAddr,proto3" json:"sequencer_addr,omitempty"`
	AggregatorAddr  string `protobuf:"bytes,10,opt,name=aggregator_addr,json=aggregatorAddr,proto3" json:"aggregator_addr,omitempty"`
	// 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) GetEthTimestamp 

func (x *PublicInputs) GetEthTimestamp() uint64

func (*PublicInputs) GetForkId 

func (x *PublicInputs) GetForkId() uint64

func (*PublicInputs) GetGlobalExitRoot 

func (x *PublicInputs) GetGlobalExitRoot() []byte

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) 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
const (
	Result_RESULT_UNSPECIFIED    Result = 0
	Result_RESULT_OK             Result = 1
	Result_RESULT_ERROR          Result = 2
	Result_RESULT_INTERNAL_ERROR Result = 3
)

func (Result) Descriptor 

func (Result) Descriptor() protoreflect.EnumDescriptor

func (Result) Enum 

func (x Result) Enum() *Result

func (Result) EnumDescriptor deprecated 

func (Result) EnumDescriptor() ([]byte, []int)

Deprecated: Use Result.Descriptor instead.

func (Result) Number 

func (x Result) Number() protoreflect.EnumNumber

func (Result) String 

func (x Result) String() string

func (Result) Type 

func (Result) Type() protoreflect.EnumType

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) Descriptor() ([]byte, []int)

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetV0_0_1 

func (x *Version) GetV0_0_1() string

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

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

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

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.