pb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ProveJobResult_Status_name = map[int32]string{
		0: "WAITING_WITNESS",
		1: "QUEUED",
		2: "RUNNING",
		3: "COMPLETED",
		4: "ERRORED",
	}
	ProveJobResult_Status_value = map[string]int32{
		"WAITING_WITNESS": 0,
		"QUEUED":          1,
		"RUNNING":         2,
		"COMPLETED":       3,
		"ERRORED":         4,
	}
)

Enum value maps for ProveJobResult_Status.

View Source 
var File_pb_gnarkd_proto protoreflect.FileDescriptor
View Source 
var Groth16_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gnarkd.Groth16",
	HandlerType: (*Groth16Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Prove",
			Handler:    _Groth16_Prove_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _Groth16_Verify_Handler,
		},
		{
			MethodName: "CreateProveJob",
			Handler:    _Groth16_CreateProveJob_Handler,
		},
		{
			MethodName: "CancelProveJob",
			Handler:    _Groth16_CancelProveJob_Handler,
		},
		{
			MethodName: "ListProveJob",
			Handler:    _Groth16_ListProveJob_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeToProveJob",
			Handler:       _Groth16_SubscribeToProveJob_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pb/gnarkd.proto",
}

Groth16_ServiceDesc is the grpc.ServiceDesc for Groth16 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGroth16Server 

func RegisterGroth16Server(s grpc.ServiceRegistrar, srv Groth16Server)

Types

type CancelProveJobRequest 

type CancelProveJobRequest struct {
	JobID string `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelProveJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelProveJobRequest.ProtoReflect.Descriptor instead.

func (*CancelProveJobRequest) GetJobID 

func (x *CancelProveJobRequest) GetJobID() string

func (*CancelProveJobRequest) ProtoMessage 

func (*CancelProveJobRequest) ProtoMessage()

func (*CancelProveJobRequest) ProtoReflect 

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

func (*CancelProveJobRequest) Reset 

func (x *CancelProveJobRequest) Reset()

func (*CancelProveJobRequest) String 

func (x *CancelProveJobRequest) String() string

type CancelProveJobResponse 

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

func (*CancelProveJobResponse) Descriptor deprecated 

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

Deprecated: Use CancelProveJobResponse.ProtoReflect.Descriptor instead.

func (*CancelProveJobResponse) ProtoMessage 

func (*CancelProveJobResponse) ProtoMessage()

func (*CancelProveJobResponse) ProtoReflect 

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

func (*CancelProveJobResponse) Reset 

func (x *CancelProveJobResponse) Reset()

func (*CancelProveJobResponse) String 

func (x *CancelProveJobResponse) String() string

type CreateProveJobRequest 

type CreateProveJobRequest struct {
	CircuitID string `protobuf:"bytes,1,opt,name=circuitID,proto3" json:"circuitID,omitempty"`
	TTL       *int64 `protobuf:"varint,2,opt,name=TTL,proto3,oneof" json:"TTL,omitempty"` // in seconds
	// contains filtered or unexported fields
}

func (*CreateProveJobRequest) Descriptor deprecated 

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

Deprecated: Use CreateProveJobRequest.ProtoReflect.Descriptor instead.

func (*CreateProveJobRequest) GetCircuitID 

func (x *CreateProveJobRequest) GetCircuitID() string

func (*CreateProveJobRequest) GetTTL 

func (x *CreateProveJobRequest) GetTTL() int64

func (*CreateProveJobRequest) ProtoMessage 

func (*CreateProveJobRequest) ProtoMessage()

func (*CreateProveJobRequest) ProtoReflect 

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

func (*CreateProveJobRequest) Reset 

func (x *CreateProveJobRequest) Reset()

func (*CreateProveJobRequest) String 

func (x *CreateProveJobRequest) String() string

type CreateProveJobResponse 

type CreateProveJobResponse struct {
	JobID string `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProveJobResponse) Descriptor deprecated 

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

Deprecated: Use CreateProveJobResponse.ProtoReflect.Descriptor instead.

func (*CreateProveJobResponse) GetJobID 

func (x *CreateProveJobResponse) GetJobID() string

func (*CreateProveJobResponse) ProtoMessage 

func (*CreateProveJobResponse) ProtoMessage()

func (*CreateProveJobResponse) ProtoReflect 

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

func (*CreateProveJobResponse) Reset 

func (x *CreateProveJobResponse) Reset()

func (*CreateProveJobResponse) String 

func (x *CreateProveJobResponse) String() string

type Groth16Client 

type Groth16Client interface {
	// Prove takes circuitID and witness as parameter
	// this is a synchronous call and bypasses the job queue
	// it is meant to be used for small circuits, for larger circuits (proving time) and witnesses,
	// use CreateProveJob instead
	Prove(ctx context.Context, in *ProveRequest, opts ...grpc.CallOption) (*ProveResult, error)
	// Verify takes circuitID, proof and public witness as parameter
	// this is a synchronous call
	Verify(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyResult, error)
	// CreateProveJob enqueue a job into the job queue with WAITING_WITNESS status
	CreateProveJob(ctx context.Context, in *CreateProveJobRequest, opts ...grpc.CallOption) (*CreateProveJobResponse, error)
	// CancelProveJob does what it says it does.
	CancelProveJob(ctx context.Context, in *CancelProveJobRequest, opts ...grpc.CallOption) (*CancelProveJobResponse, error)
	// ListProveJob does what it says it does.
	ListProveJob(ctx context.Context, in *ListProveJobRequest, opts ...grpc.CallOption) (*ListProveJobResponse, error)
	// SubscribeToProveJob enables a client to get job status changes from the server
	// at connection start, server sends current job status
	// when job is done (ok or errored), server closes connection
	SubscribeToProveJob(ctx context.Context, in *SubscribeToProveJobRequest, opts ...grpc.CallOption) (Groth16_SubscribeToProveJobClient, error)
}

Groth16Client is the client API for Groth16 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 NewGroth16Client 

func NewGroth16Client(cc grpc.ClientConnInterface) Groth16Client

type Groth16Server 

type Groth16Server interface {
	// Prove takes circuitID and witness as parameter
	// this is a synchronous call and bypasses the job queue
	// it is meant to be used for small circuits, for larger circuits (proving time) and witnesses,
	// use CreateProveJob instead
	Prove(context.Context, *ProveRequest) (*ProveResult, error)
	// Verify takes circuitID, proof and public witness as parameter
	// this is a synchronous call
	Verify(context.Context, *VerifyRequest) (*VerifyResult, error)
	// CreateProveJob enqueue a job into the job queue with WAITING_WITNESS status
	CreateProveJob(context.Context, *CreateProveJobRequest) (*CreateProveJobResponse, error)
	// CancelProveJob does what it says it does.
	CancelProveJob(context.Context, *CancelProveJobRequest) (*CancelProveJobResponse, error)
	// ListProveJob does what it says it does.
	ListProveJob(context.Context, *ListProveJobRequest) (*ListProveJobResponse, error)
	// SubscribeToProveJob enables a client to get job status changes from the server
	// at connection start, server sends current job status
	// when job is done (ok or errored), server closes connection
	SubscribeToProveJob(*SubscribeToProveJobRequest, Groth16_SubscribeToProveJobServer) error
	// contains filtered or unexported methods
}

Groth16Server is the server API for Groth16 service. All implementations must embed UnimplementedGroth16Server for forward compatibility

type Groth16_SubscribeToProveJobClient 

type Groth16_SubscribeToProveJobClient interface {
	Recv() (*ProveJobResult, error)
	grpc.ClientStream
}

type Groth16_SubscribeToProveJobServer 

type Groth16_SubscribeToProveJobServer interface {
	Send(*ProveJobResult) error
	grpc.ServerStream
}

type ListProveJobRequest 

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

func (*ListProveJobRequest) Descriptor deprecated 

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

Deprecated: Use ListProveJobRequest.ProtoReflect.Descriptor instead.

func (*ListProveJobRequest) ProtoMessage 

func (*ListProveJobRequest) ProtoMessage()

func (*ListProveJobRequest) ProtoReflect 

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

func (*ListProveJobRequest) Reset 

func (x *ListProveJobRequest) Reset()

func (*ListProveJobRequest) String 

func (x *ListProveJobRequest) String() string

type ListProveJobResponse 

type ListProveJobResponse struct {
	Jobs []*ProveJobResult `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProveJobResponse) Descriptor deprecated 

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

Deprecated: Use ListProveJobResponse.ProtoReflect.Descriptor instead.

func (*ListProveJobResponse) GetJobs 

func (x *ListProveJobResponse) GetJobs() []*ProveJobResult

func (*ListProveJobResponse) ProtoMessage 

func (*ListProveJobResponse) ProtoMessage()

func (*ListProveJobResponse) ProtoReflect 

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

func (*ListProveJobResponse) Reset 

func (x *ListProveJobResponse) Reset()

func (*ListProveJobResponse) String 

func (x *ListProveJobResponse) String() string

type ProveJobResult 

type ProveJobResult struct {
	JobID  string                `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	Status ProveJobResult_Status `protobuf:"varint,2,opt,name=status,proto3,enum=gnarkd.ProveJobResult_Status" json:"status,omitempty"`
	Err    *string               `protobuf:"bytes,3,opt,name=err,proto3,oneof" json:"err,omitempty"`
	Proof  []byte                `protobuf:"bytes,4,opt,name=proof,proto3,oneof" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*ProveJobResult) Descriptor deprecated 

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

Deprecated: Use ProveJobResult.ProtoReflect.Descriptor instead.

func (*ProveJobResult) GetErr 

func (x *ProveJobResult) GetErr() string

func (*ProveJobResult) GetJobID 

func (x *ProveJobResult) GetJobID() string

func (*ProveJobResult) GetProof 

func (x *ProveJobResult) GetProof() []byte

func (*ProveJobResult) GetStatus 

func (x *ProveJobResult) GetStatus() ProveJobResult_Status

func (*ProveJobResult) ProtoMessage 

func (*ProveJobResult) ProtoMessage()

func (*ProveJobResult) ProtoReflect 

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

func (*ProveJobResult) Reset 

func (x *ProveJobResult) Reset()

func (*ProveJobResult) String 

func (x *ProveJobResult) String() string

type ProveJobResult_Status 

type ProveJobResult_Status int32
const (
	ProveJobResult_WAITING_WITNESS ProveJobResult_Status = 0
	ProveJobResult_QUEUED          ProveJobResult_Status = 1
	ProveJobResult_RUNNING         ProveJobResult_Status = 2
	ProveJobResult_COMPLETED       ProveJobResult_Status = 3
	ProveJobResult_ERRORED         ProveJobResult_Status = 4
)

func (ProveJobResult_Status) Descriptor 

func (ProveJobResult_Status) Descriptor() protoreflect.EnumDescriptor

func (ProveJobResult_Status) Enum 

func (x ProveJobResult_Status) Enum() *ProveJobResult_Status

func (ProveJobResult_Status) EnumDescriptor deprecated 

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

Deprecated: Use ProveJobResult_Status.Descriptor instead.

func (ProveJobResult_Status) Number 

func (x ProveJobResult_Status) Number() protoreflect.EnumNumber

func (ProveJobResult_Status) String 

func (x ProveJobResult_Status) String() string

func (ProveJobResult_Status) Type 

func (ProveJobResult_Status) Type() protoreflect.EnumType

type ProveRequest 

type ProveRequest struct {
	CircuitID string `protobuf:"bytes,1,opt,name=circuitID,proto3" json:"circuitID,omitempty"`
	Witness   []byte `protobuf:"bytes,2,opt,name=witness,proto3" json:"witness,omitempty"`
	// contains filtered or unexported fields
}

func (*ProveRequest) Descriptor deprecated 

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

Deprecated: Use ProveRequest.ProtoReflect.Descriptor instead.

func (*ProveRequest) GetCircuitID 

func (x *ProveRequest) GetCircuitID() string

func (*ProveRequest) GetWitness 

func (x *ProveRequest) GetWitness() []byte

func (*ProveRequest) ProtoMessage 

func (*ProveRequest) ProtoMessage()

func (*ProveRequest) ProtoReflect 

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

func (*ProveRequest) Reset 

func (x *ProveRequest) Reset()

func (*ProveRequest) String 

func (x *ProveRequest) String() string

type ProveResult 

type ProveResult struct {
	Proof []byte `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*ProveResult) Descriptor deprecated 

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

Deprecated: Use ProveResult.ProtoReflect.Descriptor instead.

func (*ProveResult) GetProof 

func (x *ProveResult) GetProof() []byte

func (*ProveResult) ProtoMessage 

func (*ProveResult) ProtoMessage()

func (*ProveResult) ProtoReflect 

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

func (*ProveResult) Reset 

func (x *ProveResult) Reset()

func (*ProveResult) String 

func (x *ProveResult) String() string

type SubscribeToProveJobRequest 

type SubscribeToProveJobRequest struct {
	JobID string `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeToProveJobRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeToProveJobRequest.ProtoReflect.Descriptor instead.

func (*SubscribeToProveJobRequest) GetJobID 

func (x *SubscribeToProveJobRequest) GetJobID() string

func (*SubscribeToProveJobRequest) ProtoMessage 

func (*SubscribeToProveJobRequest) ProtoMessage()

func (*SubscribeToProveJobRequest) ProtoReflect 

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

func (*SubscribeToProveJobRequest) Reset 

func (x *SubscribeToProveJobRequest) Reset()

func (*SubscribeToProveJobRequest) String 

func (x *SubscribeToProveJobRequest) String() string

type UnimplementedGroth16Server 

type UnimplementedGroth16Server struct {
}

UnimplementedGroth16Server must be embedded to have forward compatible implementations.

func (UnimplementedGroth16Server) CancelProveJob 

func (UnimplementedGroth16Server) CancelProveJob(context.Context, *CancelProveJobRequest) (*CancelProveJobResponse, error)

func (UnimplementedGroth16Server) CreateProveJob 

func (UnimplementedGroth16Server) CreateProveJob(context.Context, *CreateProveJobRequest) (*CreateProveJobResponse, error)

func (UnimplementedGroth16Server) ListProveJob 

func (UnimplementedGroth16Server) ListProveJob(context.Context, *ListProveJobRequest) (*ListProveJobResponse, error)

func (UnimplementedGroth16Server) Prove 

func (UnimplementedGroth16Server) Prove(context.Context, *ProveRequest) (*ProveResult, error)

func (UnimplementedGroth16Server) SubscribeToProveJob 

func (UnimplementedGroth16Server) SubscribeToProveJob(*SubscribeToProveJobRequest, Groth16_SubscribeToProveJobServer) error

func (UnimplementedGroth16Server) Verify 

func (UnimplementedGroth16Server) Verify(context.Context, *VerifyRequest) (*VerifyResult, error)

type UnsafeGroth16Server 

type UnsafeGroth16Server interface {
	// contains filtered or unexported methods
}

UnsafeGroth16Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to Groth16Server will result in compilation errors.

type VerifyRequest 

type VerifyRequest struct {
	CircuitID     string `protobuf:"bytes,1,opt,name=circuitID,proto3" json:"circuitID,omitempty"`
	Proof         []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
	PublicWitness []byte `protobuf:"bytes,3,opt,name=publicWitness,proto3" json:"publicWitness,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyRequest) Descriptor deprecated 

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

Deprecated: Use VerifyRequest.ProtoReflect.Descriptor instead.

func (*VerifyRequest) GetCircuitID 

func (x *VerifyRequest) GetCircuitID() string

func (*VerifyRequest) GetProof 

func (x *VerifyRequest) GetProof() []byte

func (*VerifyRequest) GetPublicWitness 

func (x *VerifyRequest) GetPublicWitness() []byte

func (*VerifyRequest) ProtoMessage 

func (*VerifyRequest) ProtoMessage()

func (*VerifyRequest) ProtoReflect 

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

func (*VerifyRequest) Reset 

func (x *VerifyRequest) Reset()

func (*VerifyRequest) String 

func (x *VerifyRequest) String() string

type VerifyResult 

type VerifyResult struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyResult) Descriptor deprecated 

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

Deprecated: Use VerifyResult.ProtoReflect.Descriptor instead.

func (*VerifyResult) GetOk 

func (x *VerifyResult) GetOk() bool

func (*VerifyResult) ProtoMessage 

func (*VerifyResult) ProtoMessage()

func (*VerifyResult) ProtoReflect 

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

func (*VerifyResult) Reset 

func (x *VerifyResult) Reset()

func (*VerifyResult) String 

func (x *VerifyResult) 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.