grpc_api

package
v0.0.0-...-982e07a Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

README

Install grpc dependencies

# from https://developers.google.com/protocol-buffers/docs/gotutorial
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest

To recompile proto file run from root of acra repository:

make build_protobuf

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrKeysNotFound     = errors.New("keys not found")
	ErrEncryptionFailed = errors.New("encryption failed")
)

Errors related with gRPC requests

View Source
var (
	ErrCantDecrypt = errors.New("can't decrypt data")
)

Errors possible during decrypting AcraStructs.

View Source
var ErrEmptyClientID = errors.New("ClientID parameter is required")

ErrEmptyClientID error used if ClientID required in request but not provided

View Source
var ErrNoTranslatorData = errors.New("passed nil TranslatorData")

ErrNoTranslatorData error used if passed nil TranslatorData

View Source
var ReaderSym_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.ReaderSym",
	HandlerType: (*ReaderSymServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DecryptSym",
			Handler:    _ReaderSym_DecryptSym_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

ReaderSym_ServiceDesc is the grpc.ServiceDesc for ReaderSym 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 Reader_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.Reader",
	HandlerType: (*ReaderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Decrypt",
			Handler:    _Reader_Decrypt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

Reader_ServiceDesc is the grpc.ServiceDesc for Reader 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 SearchableEncryption_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.SearchableEncryption",
	HandlerType: (*SearchableEncryptionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EncryptSearchable",
			Handler:    _SearchableEncryption_EncryptSearchable_Handler,
		},
		{
			MethodName: "DecryptSearchable",
			Handler:    _SearchableEncryption_DecryptSearchable_Handler,
		},
		{
			MethodName: "EncryptSymSearchable",
			Handler:    _SearchableEncryption_EncryptSymSearchable_Handler,
		},
		{
			MethodName: "DecryptSymSearchable",
			Handler:    _SearchableEncryption_DecryptSymSearchable_Handler,
		},
		{
			MethodName: "GenerateQueryHash",
			Handler:    _SearchableEncryption_GenerateQueryHash_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

SearchableEncryption_ServiceDesc is the grpc.ServiceDesc for SearchableEncryption 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 Tokenizator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.Tokenizator",
	HandlerType: (*TokenizatorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Tokenize",
			Handler:    _Tokenizator_Tokenize_Handler,
		},
		{
			MethodName: "Detokenize",
			Handler:    _Tokenizator_Detokenize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

Tokenizator_ServiceDesc is the grpc.ServiceDesc for Tokenizator 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 WriterSym_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.WriterSym",
	HandlerType: (*WriterSymServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "EncryptSym",
			Handler:    _WriterSym_EncryptSym_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

WriterSym_ServiceDesc is the grpc.ServiceDesc for WriterSym 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 Writer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_api.Writer",
	HandlerType: (*WriterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Encrypt",
			Handler:    _Writer_Encrypt_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

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

Functions

func AddgRPCServerSubscriber

func AddgRPCServerSubscriber(subscriber GRPCServerSubscriber)

AddgRPCServerSubscriber register callback for gRPC server

func NewServer

func NewServer(data *common.TranslatorData, connectionWrapper network.GRPCConnectionWrapper) (*grpc.Server, error)

NewServer return new grpc.Server with AcraTranslator methods as gRPC service

func OngRPCServerInit

func OngRPCServerInit(server *grpc.Server, data *common.TranslatorData, service DecryptService)

OngRPCServerInit call all registered callbacks on gRPC server initialization

func RegisterReaderServer

func RegisterReaderServer(s grpc.ServiceRegistrar, srv ReaderServer)

func RegisterReaderSymServer

func RegisterReaderSymServer(s grpc.ServiceRegistrar, srv ReaderSymServer)

func RegisterSearchableEncryptionServer

func RegisterSearchableEncryptionServer(s grpc.ServiceRegistrar, srv SearchableEncryptionServer)

func RegisterTokenizatorServer

func RegisterTokenizatorServer(s grpc.ServiceRegistrar, srv TokenizatorServer)

func RegisterWriterServer

func RegisterWriterServer(s grpc.ServiceRegistrar, srv WriterServer)

func RegisterWriterSymServer

func RegisterWriterSymServer(s grpc.ServiceRegistrar, srv WriterSymServer)

Types

type DecryptRequest

type DecryptRequest struct {
	ClientId   []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Acrastruct []byte `protobuf:"bytes,3,opt,name=acrastruct,proto3" json:"acrastruct,omitempty"`
	// contains filtered or unexported fields
}

func (*DecryptRequest) Descriptor deprecated

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

Deprecated: Use DecryptRequest.ProtoReflect.Descriptor instead.

func (*DecryptRequest) GetAcrastruct

func (x *DecryptRequest) GetAcrastruct() []byte

func (*DecryptRequest) GetClientId

func (x *DecryptRequest) GetClientId() []byte

func (*DecryptRequest) ProtoMessage

func (*DecryptRequest) ProtoMessage()

func (*DecryptRequest) ProtoReflect

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

func (*DecryptRequest) Reset

func (x *DecryptRequest) Reset()

func (*DecryptRequest) String

func (x *DecryptRequest) String() string

type DecryptResponse

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

func (*DecryptResponse) Descriptor deprecated

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

Deprecated: Use DecryptResponse.ProtoReflect.Descriptor instead.

func (*DecryptResponse) GetData

func (x *DecryptResponse) GetData() []byte

func (*DecryptResponse) ProtoMessage

func (*DecryptResponse) ProtoMessage()

func (*DecryptResponse) ProtoReflect

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

func (*DecryptResponse) Reset

func (x *DecryptResponse) Reset()

func (*DecryptResponse) String

func (x *DecryptResponse) String() string

type DecryptService

DecryptService aggregated interface of each grpc service

type DecryptSymRequest

type DecryptSymRequest struct {
	ClientId  []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Acrablock []byte `protobuf:"bytes,3,opt,name=acrablock,proto3" json:"acrablock,omitempty"`
	// contains filtered or unexported fields
}

func (*DecryptSymRequest) Descriptor deprecated

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

Deprecated: Use DecryptSymRequest.ProtoReflect.Descriptor instead.

func (*DecryptSymRequest) GetAcrablock

func (x *DecryptSymRequest) GetAcrablock() []byte

func (*DecryptSymRequest) GetClientId

func (x *DecryptSymRequest) GetClientId() []byte

func (*DecryptSymRequest) ProtoMessage

func (*DecryptSymRequest) ProtoMessage()

func (*DecryptSymRequest) ProtoReflect

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

func (*DecryptSymRequest) Reset

func (x *DecryptSymRequest) Reset()

func (*DecryptSymRequest) String

func (x *DecryptSymRequest) String() string

type DecryptSymResponse

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

func (*DecryptSymResponse) Descriptor deprecated

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

Deprecated: Use DecryptSymResponse.ProtoReflect.Descriptor instead.

func (*DecryptSymResponse) GetData

func (x *DecryptSymResponse) GetData() []byte

func (*DecryptSymResponse) ProtoMessage

func (*DecryptSymResponse) ProtoMessage()

func (*DecryptSymResponse) ProtoReflect

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

func (*DecryptSymResponse) Reset

func (x *DecryptSymResponse) Reset()

func (*DecryptSymResponse) String

func (x *DecryptSymResponse) String() string

type EncryptRequest

type EncryptRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*EncryptRequest) Descriptor deprecated

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

Deprecated: Use EncryptRequest.ProtoReflect.Descriptor instead.

func (*EncryptRequest) GetClientId

func (x *EncryptRequest) GetClientId() []byte

func (*EncryptRequest) GetData

func (x *EncryptRequest) GetData() []byte

func (*EncryptRequest) ProtoMessage

func (*EncryptRequest) ProtoMessage()

func (*EncryptRequest) ProtoReflect

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

func (*EncryptRequest) Reset

func (x *EncryptRequest) Reset()

func (*EncryptRequest) String

func (x *EncryptRequest) String() string

type EncryptResponse

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

func (*EncryptResponse) Descriptor deprecated

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

Deprecated: Use EncryptResponse.ProtoReflect.Descriptor instead.

func (*EncryptResponse) GetAcrastruct

func (x *EncryptResponse) GetAcrastruct() []byte

func (*EncryptResponse) ProtoMessage

func (*EncryptResponse) ProtoMessage()

func (*EncryptResponse) ProtoReflect

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

func (*EncryptResponse) Reset

func (x *EncryptResponse) Reset()

func (*EncryptResponse) String

func (x *EncryptResponse) String() string

type EncryptSymRequest

type EncryptSymRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*EncryptSymRequest) Descriptor deprecated

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

Deprecated: Use EncryptSymRequest.ProtoReflect.Descriptor instead.

func (*EncryptSymRequest) GetClientId

func (x *EncryptSymRequest) GetClientId() []byte

func (*EncryptSymRequest) GetData

func (x *EncryptSymRequest) GetData() []byte

func (*EncryptSymRequest) ProtoMessage

func (*EncryptSymRequest) ProtoMessage()

func (*EncryptSymRequest) ProtoReflect

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

func (*EncryptSymRequest) Reset

func (x *EncryptSymRequest) Reset()

func (*EncryptSymRequest) String

func (x *EncryptSymRequest) String() string

type EncryptSymResponse

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

func (*EncryptSymResponse) Descriptor deprecated

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

Deprecated: Use EncryptSymResponse.ProtoReflect.Descriptor instead.

func (*EncryptSymResponse) GetAcrablock

func (x *EncryptSymResponse) GetAcrablock() []byte

func (*EncryptSymResponse) ProtoMessage

func (*EncryptSymResponse) ProtoMessage()

func (*EncryptSymResponse) ProtoReflect

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

func (*EncryptSymResponse) Reset

func (x *EncryptSymResponse) Reset()

func (*EncryptSymResponse) String

func (x *EncryptSymResponse) String() string

type GRPCServerSubscriber

type GRPCServerSubscriber interface {
	OnServerInit(server *grpc.Server, data *common.TranslatorData, service DecryptService)
}

GRPCServerSubscriber declares callbacks for gRPC server subscribers

type QueryHashRequest

type QueryHashRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryHashRequest) Descriptor deprecated

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

Deprecated: Use QueryHashRequest.ProtoReflect.Descriptor instead.

func (*QueryHashRequest) GetClientId

func (x *QueryHashRequest) GetClientId() []byte

func (*QueryHashRequest) GetData

func (x *QueryHashRequest) GetData() []byte

func (*QueryHashRequest) ProtoMessage

func (*QueryHashRequest) ProtoMessage()

func (*QueryHashRequest) ProtoReflect

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

func (*QueryHashRequest) Reset

func (x *QueryHashRequest) Reset()

func (*QueryHashRequest) String

func (x *QueryHashRequest) String() string

type QueryHashResponse

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

func (*QueryHashResponse) Descriptor deprecated

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

Deprecated: Use QueryHashResponse.ProtoReflect.Descriptor instead.

func (*QueryHashResponse) GetHash

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

func (*QueryHashResponse) ProtoMessage

func (*QueryHashResponse) ProtoMessage()

func (*QueryHashResponse) ProtoReflect

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

func (*QueryHashResponse) Reset

func (x *QueryHashResponse) Reset()

func (*QueryHashResponse) String

func (x *QueryHashResponse) String() string

type ReaderClient

type ReaderClient interface {
	Decrypt(ctx context.Context, in *DecryptRequest, opts ...grpc.CallOption) (*DecryptResponse, error)
}

ReaderClient is the client API for Reader 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 NewReaderClient

func NewReaderClient(cc grpc.ClientConnInterface) ReaderClient

type ReaderServer

type ReaderServer interface {
	Decrypt(context.Context, *DecryptRequest) (*DecryptResponse, error)
	// contains filtered or unexported methods
}

ReaderServer is the server API for Reader service. All implementations must embed UnimplementedReaderServer for forward compatibility

type ReaderSymClient

type ReaderSymClient interface {
	DecryptSym(ctx context.Context, in *DecryptSymRequest, opts ...grpc.CallOption) (*DecryptSymResponse, error)
}

ReaderSymClient is the client API for ReaderSym 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 NewReaderSymClient

func NewReaderSymClient(cc grpc.ClientConnInterface) ReaderSymClient

type ReaderSymServer

type ReaderSymServer interface {
	DecryptSym(context.Context, *DecryptSymRequest) (*DecryptSymResponse, error)
	// contains filtered or unexported methods
}

ReaderSymServer is the server API for ReaderSym service. All implementations must embed UnimplementedReaderSymServer for forward compatibility

type SearchableDecryptionRequest

type SearchableDecryptionRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Hash     []byte `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableDecryptionRequest) Descriptor deprecated

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

Deprecated: Use SearchableDecryptionRequest.ProtoReflect.Descriptor instead.

func (*SearchableDecryptionRequest) GetClientId

func (x *SearchableDecryptionRequest) GetClientId() []byte

func (*SearchableDecryptionRequest) GetData

func (x *SearchableDecryptionRequest) GetData() []byte

func (*SearchableDecryptionRequest) GetHash

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

func (*SearchableDecryptionRequest) ProtoMessage

func (*SearchableDecryptionRequest) ProtoMessage()

func (*SearchableDecryptionRequest) ProtoReflect

func (*SearchableDecryptionRequest) Reset

func (x *SearchableDecryptionRequest) Reset()

func (*SearchableDecryptionRequest) String

func (x *SearchableDecryptionRequest) String() string

type SearchableDecryptionResponse

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

func (*SearchableDecryptionResponse) Descriptor deprecated

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

Deprecated: Use SearchableDecryptionResponse.ProtoReflect.Descriptor instead.

func (*SearchableDecryptionResponse) GetData

func (x *SearchableDecryptionResponse) GetData() []byte

func (*SearchableDecryptionResponse) ProtoMessage

func (*SearchableDecryptionResponse) ProtoMessage()

func (*SearchableDecryptionResponse) ProtoReflect

func (*SearchableDecryptionResponse) Reset

func (x *SearchableDecryptionResponse) Reset()

func (*SearchableDecryptionResponse) String

type SearchableEncryptionClient

type SearchableEncryptionClient interface {
	EncryptSearchable(ctx context.Context, in *SearchableEncryptionRequest, opts ...grpc.CallOption) (*SearchableEncryptionResponse, error)
	DecryptSearchable(ctx context.Context, in *SearchableDecryptionRequest, opts ...grpc.CallOption) (*SearchableDecryptionResponse, error)
	EncryptSymSearchable(ctx context.Context, in *SearchableSymEncryptionRequest, opts ...grpc.CallOption) (*SearchableSymEncryptionResponse, error)
	DecryptSymSearchable(ctx context.Context, in *SearchableSymDecryptionRequest, opts ...grpc.CallOption) (*SearchableSymDecryptionResponse, error)
	GenerateQueryHash(ctx context.Context, in *QueryHashRequest, opts ...grpc.CallOption) (*QueryHashResponse, error)
}

SearchableEncryptionClient is the client API for SearchableEncryption 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.

type SearchableEncryptionRequest

type SearchableEncryptionRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableEncryptionRequest) Descriptor deprecated

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

Deprecated: Use SearchableEncryptionRequest.ProtoReflect.Descriptor instead.

func (*SearchableEncryptionRequest) GetClientId

func (x *SearchableEncryptionRequest) GetClientId() []byte

func (*SearchableEncryptionRequest) GetData

func (x *SearchableEncryptionRequest) GetData() []byte

func (*SearchableEncryptionRequest) ProtoMessage

func (*SearchableEncryptionRequest) ProtoMessage()

func (*SearchableEncryptionRequest) ProtoReflect

func (*SearchableEncryptionRequest) Reset

func (x *SearchableEncryptionRequest) Reset()

func (*SearchableEncryptionRequest) String

func (x *SearchableEncryptionRequest) String() string

type SearchableEncryptionResponse

type SearchableEncryptionResponse struct {
	Hash       []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Acrastruct []byte `protobuf:"bytes,2,opt,name=acrastruct,proto3" json:"acrastruct,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableEncryptionResponse) Descriptor deprecated

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

Deprecated: Use SearchableEncryptionResponse.ProtoReflect.Descriptor instead.

func (*SearchableEncryptionResponse) GetAcrastruct

func (x *SearchableEncryptionResponse) GetAcrastruct() []byte

func (*SearchableEncryptionResponse) GetHash

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

func (*SearchableEncryptionResponse) ProtoMessage

func (*SearchableEncryptionResponse) ProtoMessage()

func (*SearchableEncryptionResponse) ProtoReflect

func (*SearchableEncryptionResponse) Reset

func (x *SearchableEncryptionResponse) Reset()

func (*SearchableEncryptionResponse) String

type SearchableEncryptionServer

type SearchableEncryptionServer interface {
	EncryptSearchable(context.Context, *SearchableEncryptionRequest) (*SearchableEncryptionResponse, error)
	DecryptSearchable(context.Context, *SearchableDecryptionRequest) (*SearchableDecryptionResponse, error)
	EncryptSymSearchable(context.Context, *SearchableSymEncryptionRequest) (*SearchableSymEncryptionResponse, error)
	DecryptSymSearchable(context.Context, *SearchableSymDecryptionRequest) (*SearchableSymDecryptionResponse, error)
	GenerateQueryHash(context.Context, *QueryHashRequest) (*QueryHashResponse, error)
	// contains filtered or unexported methods
}

SearchableEncryptionServer is the server API for SearchableEncryption service. All implementations must embed UnimplementedSearchableEncryptionServer for forward compatibility

type SearchableSymDecryptionRequest

type SearchableSymDecryptionRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Hash     []byte `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableSymDecryptionRequest) Descriptor deprecated

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

Deprecated: Use SearchableSymDecryptionRequest.ProtoReflect.Descriptor instead.

func (*SearchableSymDecryptionRequest) GetClientId

func (x *SearchableSymDecryptionRequest) GetClientId() []byte

func (*SearchableSymDecryptionRequest) GetData

func (x *SearchableSymDecryptionRequest) GetData() []byte

func (*SearchableSymDecryptionRequest) GetHash

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

func (*SearchableSymDecryptionRequest) ProtoMessage

func (*SearchableSymDecryptionRequest) ProtoMessage()

func (*SearchableSymDecryptionRequest) ProtoReflect

func (*SearchableSymDecryptionRequest) Reset

func (x *SearchableSymDecryptionRequest) Reset()

func (*SearchableSymDecryptionRequest) String

type SearchableSymDecryptionResponse

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

func (*SearchableSymDecryptionResponse) Descriptor deprecated

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

Deprecated: Use SearchableSymDecryptionResponse.ProtoReflect.Descriptor instead.

func (*SearchableSymDecryptionResponse) GetData

func (x *SearchableSymDecryptionResponse) GetData() []byte

func (*SearchableSymDecryptionResponse) ProtoMessage

func (*SearchableSymDecryptionResponse) ProtoMessage()

func (*SearchableSymDecryptionResponse) ProtoReflect

func (*SearchableSymDecryptionResponse) Reset

func (*SearchableSymDecryptionResponse) String

type SearchableSymEncryptionRequest

type SearchableSymEncryptionRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableSymEncryptionRequest) Descriptor deprecated

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

Deprecated: Use SearchableSymEncryptionRequest.ProtoReflect.Descriptor instead.

func (*SearchableSymEncryptionRequest) GetClientId

func (x *SearchableSymEncryptionRequest) GetClientId() []byte

func (*SearchableSymEncryptionRequest) GetData

func (x *SearchableSymEncryptionRequest) GetData() []byte

func (*SearchableSymEncryptionRequest) ProtoMessage

func (*SearchableSymEncryptionRequest) ProtoMessage()

func (*SearchableSymEncryptionRequest) ProtoReflect

func (*SearchableSymEncryptionRequest) Reset

func (x *SearchableSymEncryptionRequest) Reset()

func (*SearchableSymEncryptionRequest) String

type SearchableSymEncryptionResponse

type SearchableSymEncryptionResponse struct {
	Hash      []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Acrablock []byte `protobuf:"bytes,2,opt,name=acrablock,proto3" json:"acrablock,omitempty"`
	// contains filtered or unexported fields
}

func (*SearchableSymEncryptionResponse) Descriptor deprecated

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

Deprecated: Use SearchableSymEncryptionResponse.ProtoReflect.Descriptor instead.

func (*SearchableSymEncryptionResponse) GetAcrablock

func (x *SearchableSymEncryptionResponse) GetAcrablock() []byte

func (*SearchableSymEncryptionResponse) GetHash

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

func (*SearchableSymEncryptionResponse) ProtoMessage

func (*SearchableSymEncryptionResponse) ProtoMessage()

func (*SearchableSymEncryptionResponse) ProtoReflect

func (*SearchableSymEncryptionResponse) Reset

func (*SearchableSymEncryptionResponse) String

type TLSDecryptServiceWrapper

TLSDecryptServiceWrapper wraps DecryptService and replace clientID in requests with clientID from connection info

func NewTLSDecryptServiceWrapper

func NewTLSDecryptServiceWrapper(service DecryptService, tlsClientIDExtractor network.TLSClientIDExtractor) (*TLSDecryptServiceWrapper, error)

NewTLSDecryptServiceWrapper return new service wrapper which use clientID from TLS certificates

func (*TLSDecryptServiceWrapper) Decrypt

func (wrapper *TLSDecryptServiceWrapper) Decrypt(ctx context.Context, request *DecryptRequest) (*DecryptResponse, error)

Decrypt encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) DecryptSearchable

DecryptSearchable encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) DecryptSym

func (wrapper *TLSDecryptServiceWrapper) DecryptSym(ctx context.Context, request *DecryptSymRequest) (*DecryptSymResponse, error)

DecryptSym encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) DecryptSymSearchable

DecryptSymSearchable encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) Detokenize

func (wrapper *TLSDecryptServiceWrapper) Detokenize(ctx context.Context, request *TokenizeRequest) (*TokenizeResponse, error)

Detokenize encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) Encrypt

func (wrapper *TLSDecryptServiceWrapper) Encrypt(ctx context.Context, request *EncryptRequest) (*EncryptResponse, error)

Encrypt encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) EncryptSearchable

EncryptSearchable encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) EncryptSym

func (wrapper *TLSDecryptServiceWrapper) EncryptSym(ctx context.Context, request *EncryptSymRequest) (*EncryptSymResponse, error)

EncryptSym encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) EncryptSymSearchable

EncryptSymSearchable encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) GenerateQueryHash

func (wrapper *TLSDecryptServiceWrapper) GenerateQueryHash(ctx context.Context, request *QueryHashRequest) (*QueryHashResponse, error)

GenerateQueryHash encrypt with clientID from connection info

func (*TLSDecryptServiceWrapper) Tokenize

func (wrapper *TLSDecryptServiceWrapper) Tokenize(ctx context.Context, request *TokenizeRequest) (*TokenizeResponse, error)

Tokenize encrypt with clientID from connection info

type TokenizatorClient

type TokenizatorClient interface {
	Tokenize(ctx context.Context, in *TokenizeRequest, opts ...grpc.CallOption) (*TokenizeResponse, error)
	Detokenize(ctx context.Context, in *TokenizeRequest, opts ...grpc.CallOption) (*TokenizeResponse, error)
}

TokenizatorClient is the client API for Tokenizator 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.

type TokenizatorServer

type TokenizatorServer interface {
	Tokenize(context.Context, *TokenizeRequest) (*TokenizeResponse, error)
	Detokenize(context.Context, *TokenizeRequest) (*TokenizeResponse, error)
	// contains filtered or unexported methods
}

TokenizatorServer is the server API for Tokenizator service. All implementations must embed UnimplementedTokenizatorServer for forward compatibility

type TokenizeRequest

type TokenizeRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Types that are assignable to Value:
	//	*TokenizeRequest_StrValue
	//	*TokenizeRequest_EmailValue
	//	*TokenizeRequest_Int32Value
	//	*TokenizeRequest_Int64Value
	//	*TokenizeRequest_BytesValue
	Value isTokenizeRequest_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*TokenizeRequest) Descriptor deprecated

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

Deprecated: Use TokenizeRequest.ProtoReflect.Descriptor instead.

func (*TokenizeRequest) GetBytesValue

func (x *TokenizeRequest) GetBytesValue() []byte

func (*TokenizeRequest) GetClientId

func (x *TokenizeRequest) GetClientId() []byte

func (*TokenizeRequest) GetEmailValue

func (x *TokenizeRequest) GetEmailValue() string

func (*TokenizeRequest) GetInt32Value

func (x *TokenizeRequest) GetInt32Value() int32

func (*TokenizeRequest) GetInt64Value

func (x *TokenizeRequest) GetInt64Value() int64

func (*TokenizeRequest) GetStrValue

func (x *TokenizeRequest) GetStrValue() string

func (*TokenizeRequest) GetValue

func (m *TokenizeRequest) GetValue() isTokenizeRequest_Value

func (*TokenizeRequest) ProtoMessage

func (*TokenizeRequest) ProtoMessage()

func (*TokenizeRequest) ProtoReflect

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

func (*TokenizeRequest) Reset

func (x *TokenizeRequest) Reset()

func (*TokenizeRequest) String

func (x *TokenizeRequest) String() string

type TokenizeRequest_BytesValue

type TokenizeRequest_BytesValue struct {
	BytesValue []byte `protobuf:"bytes,7,opt,name=bytes_value,json=bytesValue,proto3,oneof"`
}

type TokenizeRequest_EmailValue

type TokenizeRequest_EmailValue struct {
	EmailValue string `protobuf:"bytes,4,opt,name=email_value,json=emailValue,proto3,oneof"`
}

type TokenizeRequest_Int32Value

type TokenizeRequest_Int32Value struct {
	Int32Value int32 `protobuf:"varint,5,opt,name=int32_value,json=int32Value,proto3,oneof"`
}

type TokenizeRequest_Int64Value

type TokenizeRequest_Int64Value struct {
	Int64Value int64 `protobuf:"varint,6,opt,name=int64_value,json=int64Value,proto3,oneof"`
}

type TokenizeRequest_StrValue

type TokenizeRequest_StrValue struct {
	StrValue string `protobuf:"bytes,3,opt,name=str_value,json=strValue,proto3,oneof"`
}

type TokenizeResponse

type TokenizeResponse struct {

	// Types that are assignable to Response:
	//	*TokenizeResponse_StrToken
	//	*TokenizeResponse_EmailToken
	//	*TokenizeResponse_Int32Token
	//	*TokenizeResponse_Int64Token
	//	*TokenizeResponse_BytesToken
	Response isTokenizeResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*TokenizeResponse) Descriptor deprecated

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

Deprecated: Use TokenizeResponse.ProtoReflect.Descriptor instead.

func (*TokenizeResponse) GetBytesToken

func (x *TokenizeResponse) GetBytesToken() []byte

func (*TokenizeResponse) GetEmailToken

func (x *TokenizeResponse) GetEmailToken() string

func (*TokenizeResponse) GetInt32Token

func (x *TokenizeResponse) GetInt32Token() int32

func (*TokenizeResponse) GetInt64Token

func (x *TokenizeResponse) GetInt64Token() int64

func (*TokenizeResponse) GetResponse

func (m *TokenizeResponse) GetResponse() isTokenizeResponse_Response

func (*TokenizeResponse) GetStrToken

func (x *TokenizeResponse) GetStrToken() string

func (*TokenizeResponse) ProtoMessage

func (*TokenizeResponse) ProtoMessage()

func (*TokenizeResponse) ProtoReflect

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

func (*TokenizeResponse) Reset

func (x *TokenizeResponse) Reset()

func (*TokenizeResponse) String

func (x *TokenizeResponse) String() string

type TokenizeResponse_BytesToken

type TokenizeResponse_BytesToken struct {
	BytesToken []byte `protobuf:"bytes,5,opt,name=bytes_token,json=bytesToken,proto3,oneof"`
}

type TokenizeResponse_EmailToken

type TokenizeResponse_EmailToken struct {
	EmailToken string `protobuf:"bytes,2,opt,name=email_token,json=emailToken,proto3,oneof"`
}

type TokenizeResponse_Int32Token

type TokenizeResponse_Int32Token struct {
	Int32Token int32 `protobuf:"varint,3,opt,name=int32_token,json=int32Token,proto3,oneof"`
}

type TokenizeResponse_Int64Token

type TokenizeResponse_Int64Token struct {
	Int64Token int64 `protobuf:"varint,4,opt,name=int64_token,json=int64Token,proto3,oneof"`
}

type TokenizeResponse_StrToken

type TokenizeResponse_StrToken struct {
	StrToken string `protobuf:"bytes,1,opt,name=str_token,json=strToken,proto3,oneof"`
}

type TranslatorService

TranslatorService implements gRPC service

func NewTranslatorService

func NewTranslatorService(service common.ITranslatorService, translatorData *common.TranslatorData) (*TranslatorService, error)

NewTranslatorService return new TranslatorService instance

func (*TranslatorService) Decrypt

func (service *TranslatorService) Decrypt(ctx context.Context, request *DecryptRequest) (*DecryptResponse, error)

Decrypt decrypts AcraStruct from gRPC request and returns decrypted data or error.

func (*TranslatorService) DecryptSearchable

DecryptSearchable decrypt AcraStruct and verify hash

func (*TranslatorService) DecryptSym

func (service *TranslatorService) DecryptSym(ctx context.Context, request *DecryptSymRequest) (*DecryptSymResponse, error)

DecryptSym decrypts AcraBlock

func (*TranslatorService) DecryptSymSearchable

DecryptSymSearchable AcraBlock and verify hash

func (*TranslatorService) Detokenize

func (service *TranslatorService) Detokenize(ctx context.Context, request *TokenizeRequest) (*TokenizeResponse, error)

Detokenize data from request

func (*TranslatorService) Encrypt

func (service *TranslatorService) Encrypt(ctx context.Context, request *EncryptRequest) (*EncryptResponse, error)

Encrypt encrypt data from gRPC request and returns AcraStruct or error.

func (*TranslatorService) EncryptSearchable

EncryptSearchable encrypt data with AcraStruct and calculate hash for searching

func (*TranslatorService) EncryptSym

func (service *TranslatorService) EncryptSym(ctx context.Context, request *EncryptSymRequest) (*EncryptSymResponse, error)

EncryptSym encrypts data using AcraBlock

func (*TranslatorService) EncryptSymSearchable

EncryptSymSearchable encrypts data using AcraBlock and calculate searchable hash

func (*TranslatorService) GenerateQueryHash

func (service *TranslatorService) GenerateQueryHash(ctx context.Context, request *QueryHashRequest) (*QueryHashResponse, error)

GenerateQueryHash generates searchable hash for data

func (*TranslatorService) Tokenize

func (service *TranslatorService) Tokenize(ctx context.Context, request *TokenizeRequest) (*TokenizeResponse, error)

Tokenize data from request

type UnimplementedReaderServer

type UnimplementedReaderServer struct {
}

UnimplementedReaderServer must be embedded to have forward compatible implementations.

func (UnimplementedReaderServer) Decrypt

type UnimplementedReaderSymServer

type UnimplementedReaderSymServer struct {
}

UnimplementedReaderSymServer must be embedded to have forward compatible implementations.

func (UnimplementedReaderSymServer) DecryptSym

type UnimplementedSearchableEncryptionServer

type UnimplementedSearchableEncryptionServer struct {
}

UnimplementedSearchableEncryptionServer must be embedded to have forward compatible implementations.

func (UnimplementedSearchableEncryptionServer) DecryptSearchable

func (UnimplementedSearchableEncryptionServer) EncryptSearchable

func (UnimplementedSearchableEncryptionServer) GenerateQueryHash

type UnimplementedTokenizatorServer

type UnimplementedTokenizatorServer struct {
}

UnimplementedTokenizatorServer must be embedded to have forward compatible implementations.

func (UnimplementedTokenizatorServer) Detokenize

func (UnimplementedTokenizatorServer) Tokenize

type UnimplementedWriterServer

type UnimplementedWriterServer struct {
}

UnimplementedWriterServer must be embedded to have forward compatible implementations.

func (UnimplementedWriterServer) Encrypt

type UnimplementedWriterSymServer

type UnimplementedWriterSymServer struct {
}

UnimplementedWriterSymServer must be embedded to have forward compatible implementations.

func (UnimplementedWriterSymServer) EncryptSym

type UnsafeReaderServer

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

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

type UnsafeReaderSymServer

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

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

type UnsafeSearchableEncryptionServer

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

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

type UnsafeTokenizatorServer

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

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

type UnsafeWriterServer

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

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

type UnsafeWriterSymServer

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

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

type WriterClient

type WriterClient interface {
	Encrypt(ctx context.Context, in *EncryptRequest, opts ...grpc.CallOption) (*EncryptResponse, error)
}

WriterClient is the client API for Writer 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 NewWriterClient

func NewWriterClient(cc grpc.ClientConnInterface) WriterClient

type WriterServer

type WriterServer interface {
	Encrypt(context.Context, *EncryptRequest) (*EncryptResponse, error)
	// contains filtered or unexported methods
}

WriterServer is the server API for Writer service. All implementations must embed UnimplementedWriterServer for forward compatibility

type WriterSymClient

type WriterSymClient interface {
	EncryptSym(ctx context.Context, in *EncryptSymRequest, opts ...grpc.CallOption) (*EncryptSymResponse, error)
}

WriterSymClient is the client API for WriterSym 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 NewWriterSymClient

func NewWriterSymClient(cc grpc.ClientConnInterface) WriterSymClient

type WriterSymServer

type WriterSymServer interface {
	EncryptSym(context.Context, *EncryptSymRequest) (*EncryptSymResponse, error)
	// contains filtered or unexported methods
}

WriterSymServer is the server API for WriterSym service. All implementations must embed UnimplementedWriterSymServer for forward compatibility

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL