protobinaryserializer

package

v0.1.5 Latest Latest Go to latest Published: Apr 13, 2026 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(
	NewSerializer,
	wire.Bind(new(protosource.Serializer), new(*Serializer)),
)

ProviderSet provides a protobinaryserializer and binds it to protosource.Serializer.

func MarshalEvent(event protosource.Event) ([]byte, error)

func UnmarshalEvent(data []byte) (protosource.Event, error)

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

func NewDecoder(r io.Reader) *Decoder

func (d *Decoder) ReadEvent() (protosource.Event, error)

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

func NewEncoder(w io.Writer) *Encoder

func (e *Encoder) WriteBase64(b64 string) (int, error)

This is a convenience method for working with dynamo data without deserializing.

func (e *Encoder) WriteEvent(event protosource.Event) (int, error)

type Serializer struct{}

func NewSerializer() *Serializer

func (s *Serializer) MarshalEvent(event protosource.Event) (*recordv1.Record, error)

func (s *Serializer) MarshalEventAsData(event protosource.Event) ([]byte, error)

func (s *Serializer) UnmarshalEvent(record *recordv1.Record) (protosource.Event, error)

func (s *Serializer) UnmarshalEventFromData(data []byte) (protosource.Event, error)