Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Encoder ¶
type Encoder interface {
EncodeTo(output *pbsubstreamsrpc.MapModuleOutput, writer writer.Writer) error
}
type EncoderFunc ¶
type EncoderFunc func(output *pbsubstreamsrpc.MapModuleOutput, writer writer.Writer) error
func (EncoderFunc) EncodeTo ¶
func (f EncoderFunc) EncodeTo(output *pbsubstreamsrpc.MapModuleOutput, writer writer.Writer) error
type LinesEncoder ¶
type LinesEncoder struct {
}
func NewLineEncoder ¶
func NewLineEncoder() *LinesEncoder
func (*LinesEncoder) EncodeTo ¶
func (l *LinesEncoder) EncodeTo(output *pbsubstreamsrpc.MapModuleOutput, writer writer.Writer) error
type ProtoToJson ¶
type ProtoToJson struct {
// contains filtered or unexported fields
}
func NewProtoToJson ¶
func NewProtoToJson(fiedPath string, outputModuleDesc protoreflect.MessageDescriptor) (*ProtoToJson, error)
func (*ProtoToJson) EncodeTo ¶
func (p *ProtoToJson) EncodeTo(output *pbsubstreamsrpc.MapModuleOutput, writer writer.Writer) error
Source Files
Click to show internal directories.
Click to hide internal directories.