Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidInput = errors.New("invalid input")
Functions ¶
Types ¶
type JSONArrayReader ¶
type JSONArrayReader struct {
// contains filtered or unexported fields
}
func NewJSONArrayReader ¶
func NewJSONArrayReader(r io.Reader) (*JSONArrayReader, error)
func (*JSONArrayReader) Read ¶
func (r *JSONArrayReader) Read(message any) error
func (*JSONArrayReader) ReadProtoMessage ¶
func (r *JSONArrayReader) ReadProtoMessage(message proto.Message) error
reads next json object as proto message returns io.EOF at the end of the input stream.
type JSONArrayWriter ¶
type JSONArrayWriter struct {
// contains filtered or unexported fields
}
func NewJSONArrayWriter ¶
func NewJSONArrayWriter(w io.Writer) *JSONArrayWriter
func (*JSONArrayWriter) Close ¶
func (w *JSONArrayWriter) Close() error
func (*JSONArrayWriter) Write ¶
func (w *JSONArrayWriter) Write(message any) error
func (*JSONArrayWriter) WriteProtoMessage ¶
func (w *JSONArrayWriter) WriteProtoMessage(message protoreflect.ProtoMessage) error
Source Files
Click to show internal directories.
Click to hide internal directories.