Versions in this module Expand all Collapse all v2 v2.1.0 Apr 17, 2023 v2.0.0 Nov 15, 2022 Changes in this version + type Codec struct + KType beam.EncodedType + VType beam.EncodedType + func NewCodec(kType, vType reflect.Type) *Codec + func (codec *Codec) Decode(p Pair) (k, v interface{}, err error) + func (codec *Codec) Encode(k, v interface{}) (Pair, error) + func (codec *Codec) Setup() error + type DecodeFn struct + KType beam.EncodedType + VType beam.EncodedType + func NewDecodeFn(kT, vT typex.FullType) *DecodeFn + func (fn *DecodeFn) ProcessElement(c Pair) (beam.T, beam.V) + func (fn *DecodeFn) Setup() + type EncodeFn struct + KType beam.EncodedType + VType beam.EncodedType + func NewEncodeFn(kT, vT typex.FullType) *EncodeFn + func (fn *EncodeFn) ProcessElement(k beam.T, v beam.V) Pair + func (fn *EncodeFn) Setup() + type Pair struct + K []byte + V []byte Other modules containing this package github.com/google/differential-privacy/privacy-on-beam github.com/google/differential-privacy/privacy-on-beam/v3