psi

Documentation

Index

• Variables
• type Protocol
  • func (p Protocol) String() string
• type Receiver
  • func NewReceiver(protocol Protocol, rw io.ReadWriter) (Receiver, error)
• type Sender
  • func NewSender(protocol Protocol, rw io.ReadWriter) (Sender, error)

Variables

var ErrUnsupportedPSIProtocol = errors.New("unsupported PSI protocol")

Types

type Protocol

type Protocol byte

Protocol is the matching protocol enumeration

const (
	ProtocolUnsupported Protocol = iota
	ProtocolDHPSI
	ProtocolNPSI
	ProtocolBPSI
	ProtocolKKRTPSI
)

func (Protocol) String

func (p Protocol) String() string

type Receiver

type Receiver interface {
	Intersect(ctx context.Context, n int64, identifiers <-chan []byte) ([][]byte, error)
}

Receiver side of the PSI operation

func NewReceiver

func NewReceiver(protocol Protocol, rw io.ReadWriter) (Receiver, error)

type Sender

type Sender interface {
	Send(ctx context.Context, n int64, identifiers <-chan []byte) error
}

Sender is the sender side of the PSI operation

func NewSender

func NewSender(protocol Protocol, rw io.ReadWriter) (Sender, error)