rpc

package
v3.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2022 License: AGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TransactionState_name = map[int32]string{
		0: "TRANSACTION_STATE_UNSPECIFIED",
		1: "TRANSACTION_STATE_COMMITTED",
		2: "TRANSACTION_STATE_ABORTED",
		3: "TRANSACTION_STATE_UNKNOWN",
	}
	TransactionState_value = map[string]int32{
		"TRANSACTION_STATE_UNSPECIFIED": 0,
		"TRANSACTION_STATE_COMMITTED":   1,
		"TRANSACTION_STATE_ABORTED":     2,
		"TRANSACTION_STATE_UNKNOWN":     3,
	}
)

Enum value maps for TransactionState.

View Source 
var AuditorPrivileged_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.AuditorPrivileged",
	HandlerType: (*AuditorPrivilegedServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterCert",
			Handler:    _AuditorPrivileged_RegisterCert_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

AuditorPrivileged_ServiceDesc is the grpc.ServiceDesc for AuditorPrivileged 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 Auditor_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Auditor",
	HandlerType: (*AuditorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterContract",
			Handler:    _Auditor_RegisterContract_Handler,
		},
		{
			MethodName: "ListContracts",
			Handler:    _Auditor_ListContracts_Handler,
		},
		{
			MethodName: "OrderExecution",
			Handler:    _Auditor_OrderExecution_Handler,
		},
		{
			MethodName: "ValidateExecution",
			Handler:    _Auditor_ValidateExecution_Handler,
		},
		{
			MethodName: "ValidateLedger",
			Handler:    _Auditor_ValidateLedger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

Auditor_ServiceDesc is the grpc.ServiceDesc for Auditor 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_scalar_proto protoreflect.FileDescriptor
View Source 
var LedgerPrivileged_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.LedgerPrivileged",
	HandlerType: (*LedgerPrivilegedServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterCert",
			Handler:    _LedgerPrivileged_RegisterCert_Handler,
		},
		{
			MethodName: "RegisterFunction",
			Handler:    _LedgerPrivileged_RegisterFunction_Handler,
		},
		{
			MethodName: "RetrieveState",
			Handler:    _LedgerPrivileged_RetrieveState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

LedgerPrivileged_ServiceDesc is the grpc.ServiceDesc for LedgerPrivileged 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 Ledger_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Ledger",
	HandlerType: (*LedgerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterContract",
			Handler:    _Ledger_RegisterContract_Handler,
		},
		{
			MethodName: "ListContracts",
			Handler:    _Ledger_ListContracts_Handler,
		},
		{
			MethodName: "ExecuteContract",
			Handler:    _Ledger_ExecuteContract_Handler,
		},
		{
			MethodName: "ValidateLedger",
			Handler:    _Ledger_ValidateLedger_Handler,
		},
		{
			MethodName: "RetrieveAssetProof",
			Handler:    _Ledger_RetrieveAssetProof_Handler,
		},
		{
			MethodName: "AbortExecution",
			Handler:    _Ledger_AbortExecution_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

Ledger_ServiceDesc is the grpc.ServiceDesc for Ledger 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 ProofRegistry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.ProofRegistry",
	HandlerType: (*ProofRegistryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterProofs",
			Handler:    _ProofRegistry_RegisterProofs_Handler,
		},
		{
			MethodName: "RetrieveProof",
			Handler:    _ProofRegistry_RetrieveProof_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

ProofRegistry_ServiceDesc is the grpc.ServiceDesc for ProofRegistry 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 Proxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "rpc.Proxy",
	HandlerType: (*ProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterCert",
			Handler:    _Proxy_RegisterCert_Handler,
		},
		{
			MethodName: "RegisterContract",
			Handler:    _Proxy_RegisterContract_Handler,
		},
		{
			MethodName: "RegisterFunction",
			Handler:    _Proxy_RegisterFunction_Handler,
		},
		{
			MethodName: "ExecuteContract",
			Handler:    _Proxy_ExecuteContract_Handler,
		},
		{
			MethodName: "ValidateLedgers",
			Handler:    _Proxy_ValidateLedgers_Handler,
		},
		{
			MethodName: "ProxyResponse",
			Handler:    _Proxy_ProxyResponse_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "scalar.proto",
}

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

Functions

func RegisterAuditorPrivilegedServer 

func RegisterAuditorPrivilegedServer(s grpc.ServiceRegistrar, srv AuditorPrivilegedServer)

func RegisterAuditorServer 

func RegisterAuditorServer(s grpc.ServiceRegistrar, srv AuditorServer)

func RegisterLedgerPrivilegedServer 

func RegisterLedgerPrivilegedServer(s grpc.ServiceRegistrar, srv LedgerPrivilegedServer)

func RegisterLedgerServer 

func RegisterLedgerServer(s grpc.ServiceRegistrar, srv LedgerServer)

func RegisterProofRegistryServer 

func RegisterProofRegistryServer(s grpc.ServiceRegistrar, srv ProofRegistryServer)

func RegisterProxyServer 

func RegisterProxyServer(s grpc.ServiceRegistrar, srv ProxyServer)

Types

type AssetProof 

type AssetProof struct {
	AssetId   string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	Age       uint32 `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
	Nonce     string `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Input     string `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Hash      []byte `protobuf:"bytes,5,opt,name=hash,proto3" json:"hash,omitempty"`
	PrevHash  []byte `protobuf:"bytes,6,opt,name=prev_hash,json=prevHash,proto3" json:"prev_hash,omitempty"`
	Signature []byte `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AssetProof) Descriptor deprecated 

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

Deprecated: Use AssetProof.ProtoReflect.Descriptor instead.

func (*AssetProof) GetAge 

func (x *AssetProof) GetAge() uint32

func (*AssetProof) GetAssetId 

func (x *AssetProof) GetAssetId() string

func (*AssetProof) GetHash 

func (x *AssetProof) GetHash() []byte

func (*AssetProof) GetInput 

func (x *AssetProof) GetInput() string

func (*AssetProof) GetNonce 

func (x *AssetProof) GetNonce() string

func (*AssetProof) GetPrevHash 

func (x *AssetProof) GetPrevHash() []byte

func (*AssetProof) GetSignature 

func (x *AssetProof) GetSignature() []byte

func (*AssetProof) ProtoMessage 

func (*AssetProof) ProtoMessage()

func (*AssetProof) ProtoReflect 

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

func (*AssetProof) Reset 

func (x *AssetProof) Reset()

func (*AssetProof) String 

func (x *AssetProof) String() string

type AssetProofRetrievalRequest 

type AssetProofRetrievalRequest struct {
	AssetId      string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	Age          int32  `protobuf:"varint,2,opt,name=age,proto3" json:"age,omitempty"`
	CertHolderId string `protobuf:"bytes,3,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,4,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	Signature    []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*AssetProofRetrievalRequest) Descriptor deprecated 

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

Deprecated: Use AssetProofRetrievalRequest.ProtoReflect.Descriptor instead.

func (*AssetProofRetrievalRequest) GetAge 

func (x *AssetProofRetrievalRequest) GetAge() int32

func (*AssetProofRetrievalRequest) GetAssetId 

func (x *AssetProofRetrievalRequest) GetAssetId() string

func (*AssetProofRetrievalRequest) GetCertHolderId 

func (x *AssetProofRetrievalRequest) GetCertHolderId() string

func (*AssetProofRetrievalRequest) GetCertVersion 

func (x *AssetProofRetrievalRequest) GetCertVersion() uint32

func (*AssetProofRetrievalRequest) GetSignature 

func (x *AssetProofRetrievalRequest) GetSignature() []byte

func (*AssetProofRetrievalRequest) ProtoMessage 

func (*AssetProofRetrievalRequest) ProtoMessage()

func (*AssetProofRetrievalRequest) ProtoReflect 

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

func (*AssetProofRetrievalRequest) Reset 

func (x *AssetProofRetrievalRequest) Reset()

func (*AssetProofRetrievalRequest) SignWith 

func (r *AssetProofRetrievalRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs AssetProofRetrievalRequest with the given signer and fill the signature.

func (*AssetProofRetrievalRequest) String 

func (x *AssetProofRetrievalRequest) String() string

type AssetProofRetrievalResponse 

type AssetProofRetrievalResponse struct {
	Proof      *AssetProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	LedgerName string      `protobuf:"bytes,2,opt,name=ledger_name,json=ledgerName,proto3" json:"ledger_name,omitempty"`
	// contains filtered or unexported fields
}

func (*AssetProofRetrievalResponse) Descriptor deprecated 

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

Deprecated: Use AssetProofRetrievalResponse.ProtoReflect.Descriptor instead.

func (*AssetProofRetrievalResponse) GetLedgerName 

func (x *AssetProofRetrievalResponse) GetLedgerName() string

func (*AssetProofRetrievalResponse) GetProof 

func (x *AssetProofRetrievalResponse) GetProof() *AssetProof

func (*AssetProofRetrievalResponse) ProtoMessage 

func (*AssetProofRetrievalResponse) ProtoMessage()

func (*AssetProofRetrievalResponse) ProtoReflect 

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

func (*AssetProofRetrievalResponse) Reset 

func (x *AssetProofRetrievalResponse) Reset()

func (*AssetProofRetrievalResponse) String 

func (x *AssetProofRetrievalResponse) String() string

type AuditorClient 

type AuditorClient interface {
	RegisterContract(ctx context.Context, in *ContractRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListContracts(ctx context.Context, in *ContractsListingRequest, opts ...grpc.CallOption) (*ContractsListingResponse, error)
	OrderExecution(ctx context.Context, in *ContractExecutionRequest, opts ...grpc.CallOption) (*ExecutionOrderingResponse, error)
	ValidateExecution(ctx context.Context, in *ExecutionValidationRequest, opts ...grpc.CallOption) (*ContractExecutionResponse, error)
	ValidateLedger(ctx context.Context, in *LedgerValidationRequest, opts ...grpc.CallOption) (*LedgerValidationResponse, error)
}

AuditorClient is the client API for Auditor 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 NewAuditorClient 

func NewAuditorClient(cc grpc.ClientConnInterface) AuditorClient

type AuditorPrivilegedClient 

type AuditorPrivilegedClient interface {
	RegisterCert(ctx context.Context, in *CertificateRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

AuditorPrivilegedClient is the client API for AuditorPrivileged 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 NewAuditorPrivilegedClient 

func NewAuditorPrivilegedClient(cc grpc.ClientConnInterface) AuditorPrivilegedClient

type AuditorPrivilegedServer 

type AuditorPrivilegedServer interface {
	RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

AuditorPrivilegedServer is the server API for AuditorPrivileged service. All implementations must embed UnimplementedAuditorPrivilegedServer for forward compatibility

type AuditorServer 

type AuditorServer interface {
	RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)
	ListContracts(context.Context, *ContractsListingRequest) (*ContractsListingResponse, error)
	OrderExecution(context.Context, *ContractExecutionRequest) (*ExecutionOrderingResponse, error)
	ValidateExecution(context.Context, *ExecutionValidationRequest) (*ContractExecutionResponse, error)
	ValidateLedger(context.Context, *LedgerValidationRequest) (*LedgerValidationResponse, error)
	// contains filtered or unexported methods
}

AuditorServer is the server API for Auditor service. All implementations must embed UnimplementedAuditorServer for forward compatibility

type CertificateRegistrationRequest 

type CertificateRegistrationRequest struct {
	CertHolderId string `protobuf:"bytes,1,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,2,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	CertPem      string `protobuf:"bytes,3,opt,name=cert_pem,json=certPem,proto3" json:"cert_pem,omitempty"`
	ViaProxy     bool   `protobuf:"varint,4,opt,name=via_proxy,json=viaProxy,proto3" json:"via_proxy,omitempty"`
	// contains filtered or unexported fields
}

func (*CertificateRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use CertificateRegistrationRequest.ProtoReflect.Descriptor instead.

func (*CertificateRegistrationRequest) GetCertHolderId 

func (x *CertificateRegistrationRequest) GetCertHolderId() string

func (*CertificateRegistrationRequest) GetCertPem 

func (x *CertificateRegistrationRequest) GetCertPem() string

func (*CertificateRegistrationRequest) GetCertVersion 

func (x *CertificateRegistrationRequest) GetCertVersion() uint32

func (*CertificateRegistrationRequest) GetViaProxy 

func (x *CertificateRegistrationRequest) GetViaProxy() bool

func (*CertificateRegistrationRequest) ProtoMessage 

func (*CertificateRegistrationRequest) ProtoMessage()

func (*CertificateRegistrationRequest) ProtoReflect 

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

func (*CertificateRegistrationRequest) Reset 

func (x *CertificateRegistrationRequest) Reset()

func (*CertificateRegistrationRequest) String 

func (x *CertificateRegistrationRequest) String() string

type ContractExecutionRequest 

type ContractExecutionRequest struct {
	ContractId       string   `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	ContractArgument string   `protobuf:"bytes,2,opt,name=contract_argument,json=contractArgument,proto3" json:"contract_argument,omitempty"`
	CertHolderId     string   `protobuf:"bytes,3,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion      uint32   `protobuf:"varint,4,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	FunctionArgument string   `protobuf:"bytes,5,opt,name=function_argument,json=functionArgument,proto3" json:"function_argument,omitempty"`
	Signature        []byte   `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
	AuditorSignature []byte   `protobuf:"bytes,7,opt,name=auditor_signature,json=auditorSignature,proto3" json:"auditor_signature,omitempty"`
	PreExecution     bool     `protobuf:"varint,8,opt,name=pre_execution,json=preExecution,proto3" json:"pre_execution,omitempty"`
	OrderingKeys     []string `protobuf:"bytes,9,rep,name=ordering_keys,json=orderingKeys,proto3" json:"ordering_keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ContractExecutionRequest) Descriptor deprecated 

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

Deprecated: Use ContractExecutionRequest.ProtoReflect.Descriptor instead.

func (*ContractExecutionRequest) GetAuditorSignature 

func (x *ContractExecutionRequest) GetAuditorSignature() []byte

func (*ContractExecutionRequest) GetCertHolderId 

func (x *ContractExecutionRequest) GetCertHolderId() string

func (*ContractExecutionRequest) GetCertVersion 

func (x *ContractExecutionRequest) GetCertVersion() uint32

func (*ContractExecutionRequest) GetContractArgument 

func (x *ContractExecutionRequest) GetContractArgument() string

func (*ContractExecutionRequest) GetContractId 

func (x *ContractExecutionRequest) GetContractId() string

func (*ContractExecutionRequest) GetFunctionArgument 

func (x *ContractExecutionRequest) GetFunctionArgument() string

func (*ContractExecutionRequest) GetOrderingKeys 

func (x *ContractExecutionRequest) GetOrderingKeys() []string

func (*ContractExecutionRequest) GetPreExecution 

func (x *ContractExecutionRequest) GetPreExecution() bool

func (*ContractExecutionRequest) GetSignature 

func (x *ContractExecutionRequest) GetSignature() []byte

func (*ContractExecutionRequest) ProtoMessage 

func (*ContractExecutionRequest) ProtoMessage()

func (*ContractExecutionRequest) ProtoReflect 

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

func (*ContractExecutionRequest) Reset 

func (x *ContractExecutionRequest) Reset()

func (*ContractExecutionRequest) SignWith 

func (r *ContractExecutionRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs ContractExecutionRequest with the given signer and fill the signature.

func (*ContractExecutionRequest) String 

func (x *ContractExecutionRequest) String() string

type ContractExecutionResponse 

type ContractExecutionResponse struct {
	Result string        `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // a result of contract execution
	Proofs []*AssetProof `protobuf:"bytes,2,rep,name=proofs,proto3" json:"proofs,omitempty"` // proofs given from the ledger server
	// contains filtered or unexported fields
}

func (*ContractExecutionResponse) Descriptor deprecated 

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

Deprecated: Use ContractExecutionResponse.ProtoReflect.Descriptor instead.

func (*ContractExecutionResponse) GetProofs 

func (x *ContractExecutionResponse) GetProofs() []*AssetProof

func (*ContractExecutionResponse) GetResult 

func (x *ContractExecutionResponse) GetResult() string

func (*ContractExecutionResponse) ProtoMessage 

func (*ContractExecutionResponse) ProtoMessage()

func (*ContractExecutionResponse) ProtoReflect 

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

func (*ContractExecutionResponse) Reset 

func (x *ContractExecutionResponse) Reset()

func (*ContractExecutionResponse) String 

func (x *ContractExecutionResponse) String() string

type ContractRegistrationRequest 

type ContractRegistrationRequest struct {
	ContractId         string `protobuf:"bytes,1,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	ContractBinaryName string `protobuf:"bytes,2,opt,name=contract_binary_name,json=contractBinaryName,proto3" json:"contract_binary_name,omitempty"`
	ContractByteCode   []byte `protobuf:"bytes,3,opt,name=contract_byte_code,json=contractByteCode,proto3" json:"contract_byte_code,omitempty"`
	ContractProperties string `protobuf:"bytes,4,opt,name=contract_properties,json=contractProperties,proto3" json:"contract_properties,omitempty"`
	CertHolderId       string `protobuf:"bytes,5,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion        uint32 `protobuf:"varint,6,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	Signature          []byte `protobuf:"bytes,7,opt,name=signature,proto3" json:"signature,omitempty"`
	ViaProxy           bool   `protobuf:"varint,8,opt,name=via_proxy,json=viaProxy,proto3" json:"via_proxy,omitempty"`
	// contains filtered or unexported fields
}

func (*ContractRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use ContractRegistrationRequest.ProtoReflect.Descriptor instead.

func (*ContractRegistrationRequest) GetCertHolderId 

func (x *ContractRegistrationRequest) GetCertHolderId() string

func (*ContractRegistrationRequest) GetCertVersion 

func (x *ContractRegistrationRequest) GetCertVersion() uint32

func (*ContractRegistrationRequest) GetContractBinaryName 

func (x *ContractRegistrationRequest) GetContractBinaryName() string

func (*ContractRegistrationRequest) GetContractByteCode 

func (x *ContractRegistrationRequest) GetContractByteCode() []byte

func (*ContractRegistrationRequest) GetContractId 

func (x *ContractRegistrationRequest) GetContractId() string

func (*ContractRegistrationRequest) GetContractProperties 

func (x *ContractRegistrationRequest) GetContractProperties() string

func (*ContractRegistrationRequest) GetSignature 

func (x *ContractRegistrationRequest) GetSignature() []byte

func (*ContractRegistrationRequest) GetViaProxy 

func (x *ContractRegistrationRequest) GetViaProxy() bool

func (*ContractRegistrationRequest) ProtoMessage 

func (*ContractRegistrationRequest) ProtoMessage()

func (*ContractRegistrationRequest) ProtoReflect 

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

func (*ContractRegistrationRequest) Reset 

func (x *ContractRegistrationRequest) Reset()

func (*ContractRegistrationRequest) SignWith 

func (r *ContractRegistrationRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs ContractRegistrationRequest with the given signer and fill the signature.

func (*ContractRegistrationRequest) String 

func (x *ContractRegistrationRequest) String() string

type ContractsListingRequest 

type ContractsListingRequest struct {
	CertHolderId string `protobuf:"bytes,1,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,2,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	ContractId   string `protobuf:"bytes,3,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
	Signature    []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ContractsListingRequest) Descriptor deprecated 

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

Deprecated: Use ContractsListingRequest.ProtoReflect.Descriptor instead.

func (*ContractsListingRequest) GetCertHolderId 

func (x *ContractsListingRequest) GetCertHolderId() string

func (*ContractsListingRequest) GetCertVersion 

func (x *ContractsListingRequest) GetCertVersion() uint32

func (*ContractsListingRequest) GetContractId 

func (x *ContractsListingRequest) GetContractId() string

func (*ContractsListingRequest) GetSignature 

func (x *ContractsListingRequest) GetSignature() []byte

func (*ContractsListingRequest) ProtoMessage 

func (*ContractsListingRequest) ProtoMessage()

func (*ContractsListingRequest) ProtoReflect 

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

func (*ContractsListingRequest) Reset 

func (x *ContractsListingRequest) Reset()

func (*ContractsListingRequest) SignWith 

func (r *ContractsListingRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs ContractsListingRequest with the given signer and fill the signature.

func (*ContractsListingRequest) String 

func (x *ContractsListingRequest) String() string

type ContractsListingResponse 

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

func (*ContractsListingResponse) Descriptor deprecated 

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

Deprecated: Use ContractsListingResponse.ProtoReflect.Descriptor instead.

func (*ContractsListingResponse) GetJson 

func (x *ContractsListingResponse) GetJson() string

func (*ContractsListingResponse) ProtoMessage 

func (*ContractsListingResponse) ProtoMessage()

func (*ContractsListingResponse) ProtoReflect 

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

func (*ContractsListingResponse) Reset 

func (x *ContractsListingResponse) Reset()

func (*ContractsListingResponse) String 

func (x *ContractsListingResponse) String() string

type ExecutionAbortRequest 

type ExecutionAbortRequest struct {
	Nonce        string `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	CertHolderId string `protobuf:"bytes,2,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,3,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	Signature    []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionAbortRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionAbortRequest.ProtoReflect.Descriptor instead.

func (*ExecutionAbortRequest) GetCertHolderId 

func (x *ExecutionAbortRequest) GetCertHolderId() string

func (*ExecutionAbortRequest) GetCertVersion 

func (x *ExecutionAbortRequest) GetCertVersion() uint32

func (*ExecutionAbortRequest) GetNonce 

func (x *ExecutionAbortRequest) GetNonce() string

func (*ExecutionAbortRequest) GetSignature 

func (x *ExecutionAbortRequest) GetSignature() []byte

func (*ExecutionAbortRequest) ProtoMessage 

func (*ExecutionAbortRequest) ProtoMessage()

func (*ExecutionAbortRequest) ProtoReflect 

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

func (*ExecutionAbortRequest) Reset 

func (x *ExecutionAbortRequest) Reset()

func (*ExecutionAbortRequest) SignWith 

func (r *ExecutionAbortRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs ExecutionAbortRequest with the given signer and fill the signature.

func (*ExecutionAbortRequest) String 

func (x *ExecutionAbortRequest) String() string

type ExecutionAbortResponse 

type ExecutionAbortResponse struct {
	State TransactionState `protobuf:"varint,1,opt,name=state,proto3,enum=rpc.TransactionState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionAbortResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionAbortResponse.ProtoReflect.Descriptor instead.

func (*ExecutionAbortResponse) GetState 

func (x *ExecutionAbortResponse) GetState() TransactionState

func (*ExecutionAbortResponse) ProtoMessage 

func (*ExecutionAbortResponse) ProtoMessage()

func (*ExecutionAbortResponse) ProtoReflect 

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

func (*ExecutionAbortResponse) Reset 

func (x *ExecutionAbortResponse) Reset()

func (*ExecutionAbortResponse) String 

func (x *ExecutionAbortResponse) String() string

type ExecutionOrderingResponse 

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

func (*ExecutionOrderingResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionOrderingResponse.ProtoReflect.Descriptor instead.

func (*ExecutionOrderingResponse) GetSignature 

func (x *ExecutionOrderingResponse) GetSignature() []byte

func (*ExecutionOrderingResponse) ProtoMessage 

func (*ExecutionOrderingResponse) ProtoMessage()

func (*ExecutionOrderingResponse) ProtoReflect 

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

func (*ExecutionOrderingResponse) Reset 

func (x *ExecutionOrderingResponse) Reset()

func (*ExecutionOrderingResponse) String 

func (x *ExecutionOrderingResponse) String() string

type ExecutionValidationRequest 

type ExecutionValidationRequest struct {
	Request *ContractExecutionRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Proofs  []*AssetProof             `protobuf:"bytes,2,rep,name=proofs,proto3" json:"proofs,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionValidationRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionValidationRequest.ProtoReflect.Descriptor instead.

func (*ExecutionValidationRequest) GetProofs 

func (x *ExecutionValidationRequest) GetProofs() []*AssetProof

func (*ExecutionValidationRequest) GetRequest 

func (x *ExecutionValidationRequest) GetRequest() *ContractExecutionRequest

func (*ExecutionValidationRequest) ProtoMessage 

func (*ExecutionValidationRequest) ProtoMessage()

func (*ExecutionValidationRequest) ProtoReflect 

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

func (*ExecutionValidationRequest) Reset 

func (x *ExecutionValidationRequest) Reset()

func (*ExecutionValidationRequest) String 

func (x *ExecutionValidationRequest) String() string

type FunctionRegistrationRequest 

type FunctionRegistrationRequest struct {
	FunctionId         string `protobuf:"bytes,1,opt,name=function_id,json=functionId,proto3" json:"function_id,omitempty"`
	FunctionBinaryName string `protobuf:"bytes,2,opt,name=function_binary_name,json=functionBinaryName,proto3" json:"function_binary_name,omitempty"`
	FunctionByteCode   []byte `protobuf:"bytes,3,opt,name=function_byte_code,json=functionByteCode,proto3" json:"function_byte_code,omitempty"`
	ViaProxy           bool   `protobuf:"varint,4,opt,name=via_proxy,json=viaProxy,proto3" json:"via_proxy,omitempty"`
	// contains filtered or unexported fields
}

func (*FunctionRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use FunctionRegistrationRequest.ProtoReflect.Descriptor instead.

func (*FunctionRegistrationRequest) GetFunctionBinaryName 

func (x *FunctionRegistrationRequest) GetFunctionBinaryName() string

func (*FunctionRegistrationRequest) GetFunctionByteCode 

func (x *FunctionRegistrationRequest) GetFunctionByteCode() []byte

func (*FunctionRegistrationRequest) GetFunctionId 

func (x *FunctionRegistrationRequest) GetFunctionId() string

func (*FunctionRegistrationRequest) GetViaProxy 

func (x *FunctionRegistrationRequest) GetViaProxy() bool

func (*FunctionRegistrationRequest) ProtoMessage 

func (*FunctionRegistrationRequest) ProtoMessage()

func (*FunctionRegistrationRequest) ProtoReflect 

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

func (*FunctionRegistrationRequest) Reset 

func (x *FunctionRegistrationRequest) Reset()

func (*FunctionRegistrationRequest) String 

func (x *FunctionRegistrationRequest) String() string

type IdentifiableResponse 

type IdentifiableResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Response:
	//	*IdentifiableResponse_ContractExecutionResponse
	Response   isIdentifiableResponse_Response `protobuf_oneof:"response"`
	StatusCode uint32                          `protobuf:"varint,3,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	// contains filtered or unexported fields
}

func (*IdentifiableResponse) Descriptor deprecated 

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

Deprecated: Use IdentifiableResponse.ProtoReflect.Descriptor instead.

func (*IdentifiableResponse) GetContractExecutionResponse 

func (x *IdentifiableResponse) GetContractExecutionResponse() *ContractExecutionResponse

func (*IdentifiableResponse) GetId 

func (x *IdentifiableResponse) GetId() string

func (*IdentifiableResponse) GetResponse 

func (m *IdentifiableResponse) GetResponse() isIdentifiableResponse_Response

func (*IdentifiableResponse) GetStatusCode 

func (x *IdentifiableResponse) GetStatusCode() uint32

func (*IdentifiableResponse) ProtoMessage 

func (*IdentifiableResponse) ProtoMessage()

func (*IdentifiableResponse) ProtoReflect 

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

func (*IdentifiableResponse) Reset 

func (x *IdentifiableResponse) Reset()

func (*IdentifiableResponse) String 

func (x *IdentifiableResponse) String() string

type IdentifiableResponse_ContractExecutionResponse 

type IdentifiableResponse_ContractExecutionResponse struct {
	ContractExecutionResponse *ContractExecutionResponse `protobuf:"bytes,2,opt,name=contract_execution_response,json=contractExecutionResponse,proto3,oneof"`
}

type LedgerClient 

type LedgerClient interface {
	RegisterContract(ctx context.Context, in *ContractRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListContracts(ctx context.Context, in *ContractsListingRequest, opts ...grpc.CallOption) (*ContractsListingResponse, error)
	ExecuteContract(ctx context.Context, in *ContractExecutionRequest, opts ...grpc.CallOption) (*ContractExecutionResponse, error)
	ValidateLedger(ctx context.Context, in *LedgerValidationRequest, opts ...grpc.CallOption) (*LedgerValidationResponse, error)
	RetrieveAssetProof(ctx context.Context, in *AssetProofRetrievalRequest, opts ...grpc.CallOption) (*AssetProofRetrievalResponse, error)
	AbortExecution(ctx context.Context, in *ExecutionAbortRequest, opts ...grpc.CallOption) (*ExecutionAbortResponse, error)
}

LedgerClient is the client API for Ledger 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 NewLedgerClient 

func NewLedgerClient(cc grpc.ClientConnInterface) LedgerClient

type LedgerPrivilegedClient 

type LedgerPrivilegedClient interface {
	RegisterCert(ctx context.Context, in *CertificateRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RegisterFunction(ctx context.Context, in *FunctionRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RetrieveState(ctx context.Context, in *StateRetrievalRequest, opts ...grpc.CallOption) (*StateRetrievalResponse, error)
}

LedgerPrivilegedClient is the client API for LedgerPrivileged 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 NewLedgerPrivilegedClient 

func NewLedgerPrivilegedClient(cc grpc.ClientConnInterface) LedgerPrivilegedClient

type LedgerPrivilegedServer 

type LedgerPrivilegedServer interface {
	RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)
	RegisterFunction(context.Context, *FunctionRegistrationRequest) (*emptypb.Empty, error)
	RetrieveState(context.Context, *StateRetrievalRequest) (*StateRetrievalResponse, error)
	// contains filtered or unexported methods
}

LedgerPrivilegedServer is the server API for LedgerPrivileged service. All implementations must embed UnimplementedLedgerPrivilegedServer for forward compatibility

type LedgerServer 

type LedgerServer interface {
	RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)
	ListContracts(context.Context, *ContractsListingRequest) (*ContractsListingResponse, error)
	ExecuteContract(context.Context, *ContractExecutionRequest) (*ContractExecutionResponse, error)
	ValidateLedger(context.Context, *LedgerValidationRequest) (*LedgerValidationResponse, error)
	RetrieveAssetProof(context.Context, *AssetProofRetrievalRequest) (*AssetProofRetrievalResponse, error)
	AbortExecution(context.Context, *ExecutionAbortRequest) (*ExecutionAbortResponse, error)
	// contains filtered or unexported methods
}

LedgerServer is the server API for Ledger service. All implementations must embed UnimplementedLedgerServer for forward compatibility

type LedgerValidationRequest 

type LedgerValidationRequest struct {
	AssetId      string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	StartAge     uint32 `protobuf:"varint,2,opt,name=start_age,json=startAge,proto3" json:"start_age,omitempty"`
	EndAge       uint32 `protobuf:"varint,3,opt,name=end_age,json=endAge,proto3" json:"end_age,omitempty"`
	CertHolderId string `protobuf:"bytes,4,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,5,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	Signature    []byte `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*LedgerValidationRequest) Descriptor deprecated 

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

Deprecated: Use LedgerValidationRequest.ProtoReflect.Descriptor instead.

func (*LedgerValidationRequest) GetAssetId 

func (x *LedgerValidationRequest) GetAssetId() string

func (*LedgerValidationRequest) GetCertHolderId 

func (x *LedgerValidationRequest) GetCertHolderId() string

func (*LedgerValidationRequest) GetCertVersion 

func (x *LedgerValidationRequest) GetCertVersion() uint32

func (*LedgerValidationRequest) GetEndAge 

func (x *LedgerValidationRequest) GetEndAge() uint32

func (*LedgerValidationRequest) GetSignature 

func (x *LedgerValidationRequest) GetSignature() []byte

func (*LedgerValidationRequest) GetStartAge 

func (x *LedgerValidationRequest) GetStartAge() uint32

func (*LedgerValidationRequest) ProtoMessage 

func (*LedgerValidationRequest) ProtoMessage()

func (*LedgerValidationRequest) ProtoReflect 

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

func (*LedgerValidationRequest) Reset 

func (x *LedgerValidationRequest) Reset()

func (*LedgerValidationRequest) SignWith 

func (r *LedgerValidationRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs LedgerValidationRequest with the given signer and fill the signature

func (*LedgerValidationRequest) String 

func (x *LedgerValidationRequest) String() string

type LedgerValidationResponse 

type LedgerValidationResponse struct {
	StatusCode uint32      `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Proof      *AssetProof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // a proof given from the ledger server
	// contains filtered or unexported fields
}

func (*LedgerValidationResponse) Descriptor deprecated 

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

Deprecated: Use LedgerValidationResponse.ProtoReflect.Descriptor instead.

func (*LedgerValidationResponse) GetProof 

func (x *LedgerValidationResponse) GetProof() *AssetProof

func (*LedgerValidationResponse) GetStatusCode 

func (x *LedgerValidationResponse) GetStatusCode() uint32

func (*LedgerValidationResponse) ProtoMessage 

func (*LedgerValidationResponse) ProtoMessage()

func (*LedgerValidationResponse) ProtoReflect 

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

func (*LedgerValidationResponse) Reset 

func (x *LedgerValidationResponse) Reset()

func (*LedgerValidationResponse) String 

func (x *LedgerValidationResponse) String() string

type LedgersValidationRequest 

type LedgersValidationRequest struct {
	AssetId      string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	CertHolderId string `protobuf:"bytes,2,opt,name=cert_holder_id,json=certHolderId,proto3" json:"cert_holder_id,omitempty"`
	CertVersion  uint32 `protobuf:"varint,3,opt,name=cert_version,json=certVersion,proto3" json:"cert_version,omitempty"`
	Signature    []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*LedgersValidationRequest) Descriptor deprecated 

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

Deprecated: Use LedgersValidationRequest.ProtoReflect.Descriptor instead.

func (*LedgersValidationRequest) GetAssetId 

func (x *LedgersValidationRequest) GetAssetId() string

func (*LedgersValidationRequest) GetCertHolderId 

func (x *LedgersValidationRequest) GetCertHolderId() string

func (*LedgersValidationRequest) GetCertVersion 

func (x *LedgersValidationRequest) GetCertVersion() uint32

func (*LedgersValidationRequest) GetSignature 

func (x *LedgersValidationRequest) GetSignature() []byte

func (*LedgersValidationRequest) ProtoMessage 

func (*LedgersValidationRequest) ProtoMessage()

func (*LedgersValidationRequest) ProtoReflect 

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

func (*LedgersValidationRequest) Reset 

func (x *LedgersValidationRequest) Reset()

func (*LedgersValidationRequest) SignWith 

func (r *LedgersValidationRequest) SignWith(signer crypto.Signer) (err error)

SignWith signs LedgersValidationRequest with the given signer and fill the signature.

func (*LedgersValidationRequest) String 

func (x *LedgersValidationRequest) String() string

type LedgersValidationResponse 

type LedgersValidationResponse struct {
	Response []*AssetProofRetrievalResponse `protobuf:"bytes,1,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*LedgersValidationResponse) Descriptor deprecated 

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

Deprecated: Use LedgersValidationResponse.ProtoReflect.Descriptor instead.

func (*LedgersValidationResponse) GetResponse 

func (x *LedgersValidationResponse) GetResponse() []*AssetProofRetrievalResponse

func (*LedgersValidationResponse) ProtoMessage 

func (*LedgersValidationResponse) ProtoMessage()

func (*LedgersValidationResponse) ProtoReflect 

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

func (*LedgersValidationResponse) Reset 

func (x *LedgersValidationResponse) Reset()

func (*LedgersValidationResponse) String 

func (x *LedgersValidationResponse) String() string

type ProofRegistryClient 

type ProofRegistryClient interface {
	RegisterProofs(ctx context.Context, in *ProofsRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RetrieveProof(ctx context.Context, in *ProofRetrievalRequest, opts ...grpc.CallOption) (*ProofRetrievalResponse, error)
}

ProofRegistryClient is the client API for ProofRegistry 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 NewProofRegistryClient 

func NewProofRegistryClient(cc grpc.ClientConnInterface) ProofRegistryClient

type ProofRegistryServer 

type ProofRegistryServer interface {
	RegisterProofs(context.Context, *ProofsRegistrationRequest) (*emptypb.Empty, error)
	RetrieveProof(context.Context, *ProofRetrievalRequest) (*ProofRetrievalResponse, error)
	// contains filtered or unexported methods
}

ProofRegistryServer is the server API for ProofRegistry service. All implementations must embed UnimplementedProofRegistryServer for forward compatibility

type ProofRetrievalRequest 

type ProofRetrievalRequest struct {
	AssetId string `protobuf:"bytes,1,opt,name=asset_id,json=assetId,proto3" json:"asset_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ProofRetrievalRequest) Descriptor deprecated 

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

Deprecated: Use ProofRetrievalRequest.ProtoReflect.Descriptor instead.

func (*ProofRetrievalRequest) GetAssetId 

func (x *ProofRetrievalRequest) GetAssetId() string

func (*ProofRetrievalRequest) ProtoMessage 

func (*ProofRetrievalRequest) ProtoMessage()

func (*ProofRetrievalRequest) ProtoReflect 

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

func (*ProofRetrievalRequest) Reset 

func (x *ProofRetrievalRequest) Reset()

func (*ProofRetrievalRequest) String 

func (x *ProofRetrievalRequest) String() string

type ProofRetrievalResponse 

type ProofRetrievalResponse struct {
	Proof *AssetProof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	// contains filtered or unexported fields
}

func (*ProofRetrievalResponse) Descriptor deprecated 

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

Deprecated: Use ProofRetrievalResponse.ProtoReflect.Descriptor instead.

func (*ProofRetrievalResponse) GetProof 

func (x *ProofRetrievalResponse) GetProof() *AssetProof

func (*ProofRetrievalResponse) ProtoMessage 

func (*ProofRetrievalResponse) ProtoMessage()

func (*ProofRetrievalResponse) ProtoReflect 

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

func (*ProofRetrievalResponse) Reset 

func (x *ProofRetrievalResponse) Reset()

func (*ProofRetrievalResponse) String 

func (x *ProofRetrievalResponse) String() string

type ProofsRegistrationRequest 

type ProofsRegistrationRequest struct {
	Proofs []*AssetProof `protobuf:"bytes,1,rep,name=proofs,proto3" json:"proofs,omitempty"`
	// contains filtered or unexported fields
}

func (*ProofsRegistrationRequest) Descriptor deprecated 

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

Deprecated: Use ProofsRegistrationRequest.ProtoReflect.Descriptor instead.

func (*ProofsRegistrationRequest) GetProofs 

func (x *ProofsRegistrationRequest) GetProofs() []*AssetProof

func (*ProofsRegistrationRequest) ProtoMessage 

func (*ProofsRegistrationRequest) ProtoMessage()

func (*ProofsRegistrationRequest) ProtoReflect 

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

func (*ProofsRegistrationRequest) Reset 

func (x *ProofsRegistrationRequest) Reset()

func (*ProofsRegistrationRequest) String 

func (x *ProofsRegistrationRequest) String() string

type ProxyClient 

type ProxyClient interface {
	RegisterCert(ctx context.Context, in *CertificateRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RegisterContract(ctx context.Context, in *ContractRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RegisterFunction(ctx context.Context, in *FunctionRegistrationRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ExecuteContract(ctx context.Context, in *ContractExecutionRequest, opts ...grpc.CallOption) (*ContractExecutionResponse, error)
	ValidateLedgers(ctx context.Context, in *LedgersValidationRequest, opts ...grpc.CallOption) (*LedgersValidationResponse, error)
	ProxyResponse(ctx context.Context, in *IdentifiableResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ProxyClient is the client API for Proxy 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 NewProxyClient 

func NewProxyClient(cc grpc.ClientConnInterface) ProxyClient

type ProxyServer 

type ProxyServer interface {
	RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)
	RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)
	RegisterFunction(context.Context, *FunctionRegistrationRequest) (*emptypb.Empty, error)
	ExecuteContract(context.Context, *ContractExecutionRequest) (*ContractExecutionResponse, error)
	ValidateLedgers(context.Context, *LedgersValidationRequest) (*LedgersValidationResponse, error)
	ProxyResponse(context.Context, *IdentifiableResponse) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ProxyServer is the server API for Proxy service. All implementations must embed UnimplementedProxyServer for forward compatibility

type ReturnableRequest 

type ReturnableRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Request:
	//	*ReturnableRequest_CertificateRegistrationRequest
	//	*ReturnableRequest_ContractRegistrationRequest
	//	*ReturnableRequest_FunctionRegistrationRequest
	//	*ReturnableRequest_ContractExecutionRequest
	Request   isReturnableRequest_Request `protobuf_oneof:"request"`
	Hostname  string                      `protobuf:"bytes,6,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port      uint32                      `protobuf:"varint,7,opt,name=port,proto3" json:"port,omitempty"`
	Signature []byte                      `protobuf:"bytes,8,opt,name=signature,proto3" json:"signature,omitempty"` // TODO: to be deleted later
	// contains filtered or unexported fields
}

func (*ReturnableRequest) Descriptor deprecated 

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

Deprecated: Use ReturnableRequest.ProtoReflect.Descriptor instead.

func (*ReturnableRequest) GetCertificateRegistrationRequest 

func (x *ReturnableRequest) GetCertificateRegistrationRequest() *CertificateRegistrationRequest

func (*ReturnableRequest) GetContractExecutionRequest 

func (x *ReturnableRequest) GetContractExecutionRequest() *ContractExecutionRequest

func (*ReturnableRequest) GetContractRegistrationRequest 

func (x *ReturnableRequest) GetContractRegistrationRequest() *ContractRegistrationRequest

func (*ReturnableRequest) GetFunctionRegistrationRequest 

func (x *ReturnableRequest) GetFunctionRegistrationRequest() *FunctionRegistrationRequest

func (*ReturnableRequest) GetHostname 

func (x *ReturnableRequest) GetHostname() string

func (*ReturnableRequest) GetId 

func (x *ReturnableRequest) GetId() string

func (*ReturnableRequest) GetPort 

func (x *ReturnableRequest) GetPort() uint32

func (*ReturnableRequest) GetRequest 

func (m *ReturnableRequest) GetRequest() isReturnableRequest_Request

func (*ReturnableRequest) GetSignature 

func (x *ReturnableRequest) GetSignature() []byte

func (*ReturnableRequest) ProtoMessage 

func (*ReturnableRequest) ProtoMessage()

func (*ReturnableRequest) ProtoReflect 

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

func (*ReturnableRequest) Reset 

func (x *ReturnableRequest) Reset()

func (*ReturnableRequest) String 

func (x *ReturnableRequest) String() string

type ReturnableRequest_CertificateRegistrationRequest 

type ReturnableRequest_CertificateRegistrationRequest struct {
	CertificateRegistrationRequest *CertificateRegistrationRequest `protobuf:"bytes,2,opt,name=certificate_registration_request,json=certificateRegistrationRequest,proto3,oneof"`
}

type ReturnableRequest_ContractExecutionRequest 

type ReturnableRequest_ContractExecutionRequest struct {
	ContractExecutionRequest *ContractExecutionRequest `protobuf:"bytes,5,opt,name=contract_execution_request,json=contractExecutionRequest,proto3,oneof"`
}

type ReturnableRequest_ContractRegistrationRequest 

type ReturnableRequest_ContractRegistrationRequest struct {
	ContractRegistrationRequest *ContractRegistrationRequest `protobuf:"bytes,3,opt,name=contract_registration_request,json=contractRegistrationRequest,proto3,oneof"`
}

type ReturnableRequest_FunctionRegistrationRequest 

type ReturnableRequest_FunctionRegistrationRequest struct {
	FunctionRegistrationRequest *FunctionRegistrationRequest `protobuf:"bytes,4,opt,name=function_registration_request,json=functionRegistrationRequest,proto3,oneof"`
}

type StateRetrievalRequest 

type StateRetrievalRequest struct {
	TransactionId string `protobuf:"bytes,1,opt,name=transaction_id,json=transactionId,proto3" json:"transaction_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StateRetrievalRequest) Descriptor deprecated 

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

Deprecated: Use StateRetrievalRequest.ProtoReflect.Descriptor instead.

func (*StateRetrievalRequest) GetTransactionId 

func (x *StateRetrievalRequest) GetTransactionId() string

func (*StateRetrievalRequest) ProtoMessage 

func (*StateRetrievalRequest) ProtoMessage()

func (*StateRetrievalRequest) ProtoReflect 

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

func (*StateRetrievalRequest) Reset 

func (x *StateRetrievalRequest) Reset()

func (*StateRetrievalRequest) String 

func (x *StateRetrievalRequest) String() string

type StateRetrievalResponse 

type StateRetrievalResponse struct {
	State TransactionState `protobuf:"varint,1,opt,name=state,proto3,enum=rpc.TransactionState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*StateRetrievalResponse) Descriptor deprecated 

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

Deprecated: Use StateRetrievalResponse.ProtoReflect.Descriptor instead.

func (*StateRetrievalResponse) GetState 

func (x *StateRetrievalResponse) GetState() TransactionState

func (*StateRetrievalResponse) ProtoMessage 

func (*StateRetrievalResponse) ProtoMessage()

func (*StateRetrievalResponse) ProtoReflect 

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

func (*StateRetrievalResponse) Reset 

func (x *StateRetrievalResponse) Reset()

func (*StateRetrievalResponse) String 

func (x *StateRetrievalResponse) String() string

type Status 

type Status struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() uint32

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type TransactionState 

type TransactionState int32
const (
	TransactionState_TRANSACTION_STATE_UNSPECIFIED TransactionState = 0
	TransactionState_TRANSACTION_STATE_COMMITTED   TransactionState = 1
	TransactionState_TRANSACTION_STATE_ABORTED     TransactionState = 2
	TransactionState_TRANSACTION_STATE_UNKNOWN     TransactionState = 3
)

func (TransactionState) Descriptor 

func (TransactionState) Descriptor() protoreflect.EnumDescriptor

func (TransactionState) Enum 

func (x TransactionState) Enum() *TransactionState

func (TransactionState) EnumDescriptor deprecated 

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

Deprecated: Use TransactionState.Descriptor instead.

func (TransactionState) Number 

func (x TransactionState) Number() protoreflect.EnumNumber

func (TransactionState) String 

func (x TransactionState) String() string

func (TransactionState) Type 

func (TransactionState) Type() protoreflect.EnumType

type UnimplementedAuditorPrivilegedServer 

type UnimplementedAuditorPrivilegedServer struct {
}

UnimplementedAuditorPrivilegedServer must be embedded to have forward compatible implementations.

func (UnimplementedAuditorPrivilegedServer) RegisterCert 

func (UnimplementedAuditorPrivilegedServer) RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)

type UnimplementedAuditorServer 

type UnimplementedAuditorServer struct {
}

UnimplementedAuditorServer must be embedded to have forward compatible implementations.

func (UnimplementedAuditorServer) ListContracts 

func (UnimplementedAuditorServer) ListContracts(context.Context, *ContractsListingRequest) (*ContractsListingResponse, error)

func (UnimplementedAuditorServer) OrderExecution 

func (UnimplementedAuditorServer) OrderExecution(context.Context, *ContractExecutionRequest) (*ExecutionOrderingResponse, error)

func (UnimplementedAuditorServer) RegisterContract 

func (UnimplementedAuditorServer) RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedAuditorServer) ValidateExecution 

func (UnimplementedAuditorServer) ValidateExecution(context.Context, *ExecutionValidationRequest) (*ContractExecutionResponse, error)

func (UnimplementedAuditorServer) ValidateLedger 

func (UnimplementedAuditorServer) ValidateLedger(context.Context, *LedgerValidationRequest) (*LedgerValidationResponse, error)

type UnimplementedLedgerPrivilegedServer 

type UnimplementedLedgerPrivilegedServer struct {
}

UnimplementedLedgerPrivilegedServer must be embedded to have forward compatible implementations.

func (UnimplementedLedgerPrivilegedServer) RegisterCert 

func (UnimplementedLedgerPrivilegedServer) RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedLedgerPrivilegedServer) RegisterFunction 

func (UnimplementedLedgerPrivilegedServer) RegisterFunction(context.Context, *FunctionRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedLedgerPrivilegedServer) RetrieveState 

func (UnimplementedLedgerPrivilegedServer) RetrieveState(context.Context, *StateRetrievalRequest) (*StateRetrievalResponse, error)

type UnimplementedLedgerServer 

type UnimplementedLedgerServer struct {
}

UnimplementedLedgerServer must be embedded to have forward compatible implementations.

func (UnimplementedLedgerServer) AbortExecution 

func (UnimplementedLedgerServer) AbortExecution(context.Context, *ExecutionAbortRequest) (*ExecutionAbortResponse, error)

func (UnimplementedLedgerServer) ExecuteContract 

func (UnimplementedLedgerServer) ExecuteContract(context.Context, *ContractExecutionRequest) (*ContractExecutionResponse, error)

func (UnimplementedLedgerServer) ListContracts 

func (UnimplementedLedgerServer) ListContracts(context.Context, *ContractsListingRequest) (*ContractsListingResponse, error)

func (UnimplementedLedgerServer) RegisterContract 

func (UnimplementedLedgerServer) RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedLedgerServer) RetrieveAssetProof 

func (UnimplementedLedgerServer) RetrieveAssetProof(context.Context, *AssetProofRetrievalRequest) (*AssetProofRetrievalResponse, error)

func (UnimplementedLedgerServer) ValidateLedger 

func (UnimplementedLedgerServer) ValidateLedger(context.Context, *LedgerValidationRequest) (*LedgerValidationResponse, error)

type UnimplementedProofRegistryServer 

type UnimplementedProofRegistryServer struct {
}

UnimplementedProofRegistryServer must be embedded to have forward compatible implementations.

func (UnimplementedProofRegistryServer) RegisterProofs 

func (UnimplementedProofRegistryServer) RegisterProofs(context.Context, *ProofsRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedProofRegistryServer) RetrieveProof 

func (UnimplementedProofRegistryServer) RetrieveProof(context.Context, *ProofRetrievalRequest) (*ProofRetrievalResponse, error)

type UnimplementedProxyServer 

type UnimplementedProxyServer struct {
}

UnimplementedProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedProxyServer) ExecuteContract 

func (UnimplementedProxyServer) ExecuteContract(context.Context, *ContractExecutionRequest) (*ContractExecutionResponse, error)

func (UnimplementedProxyServer) ProxyResponse 

func (UnimplementedProxyServer) ProxyResponse(context.Context, *IdentifiableResponse) (*emptypb.Empty, error)

func (UnimplementedProxyServer) RegisterCert 

func (UnimplementedProxyServer) RegisterCert(context.Context, *CertificateRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedProxyServer) RegisterContract 

func (UnimplementedProxyServer) RegisterContract(context.Context, *ContractRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedProxyServer) RegisterFunction 

func (UnimplementedProxyServer) RegisterFunction(context.Context, *FunctionRegistrationRequest) (*emptypb.Empty, error)

func (UnimplementedProxyServer) ValidateLedgers 

func (UnimplementedProxyServer) ValidateLedgers(context.Context, *LedgersValidationRequest) (*LedgersValidationResponse, error)

type UnsafeAuditorPrivilegedServer 

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

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

type UnsafeAuditorServer 

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

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

type UnsafeLedgerPrivilegedServer 

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

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

type UnsafeLedgerServer 

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

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

type UnsafeProofRegistryServer 

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

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

type UnsafeProxyServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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