writer

Documentation

Index

• func ConvertJSONPBToProtobuf(data []byte, writeOpts *opts.WriteOptions, fds *dpb.FileDescriptorSet) ([]byte, error)
• func GenerateWriteValue(writeOpts *opts.WriteOptions, fds *dpb.FileDescriptorSet) ([]*records.WriteRecord, error)

Functions

func ConvertJSONPBToProtobuf

func ConvertJSONPBToProtobuf(data []byte, writeOpts *opts.WriteOptions, fds *dpb.FileDescriptorSet) ([]byte, error)

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

func GenerateWriteValue

func GenerateWriteValue(writeOpts *opts.WriteOptions, fds *dpb.FileDescriptorSet) ([]*records.WriteRecord, error)

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