writer

Documentation

Index

• func ConvertJSONPBToProtobuf(data []byte, envelope, payload *dynamic.Message, payloadFieldID int32) ([]byte, error)
• func GenerateWriteValue(writeOpts *opts.WriteOptions, mds map[pb.MDType]*desc.MessageDescriptor) ([]*records.WriteRecord, error)

Functions

func ConvertJSONPBToProtobuf

func ConvertJSONPBToProtobuf(data []byte, envelope, payload *dynamic.Message, payloadFieldID int32) ([]byte, error)

ConvertJSONPBToProtobuf converts input data from jsonpb -> protobuf -> bytes

func GenerateWriteValue

func GenerateWriteValue(writeOpts *opts.WriteOptions, mds map[pb.MDType]*desc.MessageDescriptor) ([]*records.WriteRecord, error)

GenerateWriteValue generates a slice of WriteRecords that can be passed to backends to perform a write.