Documentation
¶
Index ¶
- func GetConvertWriter(ctx api.StreamContext, format string, schemaId string, ...) (message.ConvertWriter, error)
- func GetMerger(ctx api.StreamContext, format string, schemaId string, ...) (modules.Merger, error)
- func GetOrCreateConverter(ctx api.StreamContext, format string, schemaId string, ...) (c message.Converter, err error)
- func NewStackWriter(_ api.StreamContext, converter message.Converter) (message.ConvertWriter, error)
- type StackWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetConvertWriter ¶ added in v2.2.0
func GetConvertWriter(ctx api.StreamContext, format string, schemaId string, schema map[string]*ast.JsonStreamField, props map[string]any) (message.ConvertWriter, error)
func GetOrCreateConverter ¶
func NewStackWriter ¶ added in v2.2.0
func NewStackWriter(_ api.StreamContext, converter message.Converter) (message.ConvertWriter, error)
Types ¶
type StackWriter ¶ added in v2.2.0
type StackWriter struct {
// contains filtered or unexported fields
}
func (*StackWriter) Flush ¶ added in v2.2.0
func (w *StackWriter) Flush(ctx api.StreamContext) ([]byte, error)
func (*StackWriter) New ¶ added in v2.2.0
func (w *StackWriter) New(ctx api.StreamContext) error
func (*StackWriter) Write ¶ added in v2.2.0
func (w *StackWriter) Write(ctx api.StreamContext, d any) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.