message

package
v2.0.0-alpha.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 29, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FormatBinary    = "binary"
	FormatJson      = "json"
	FormatProtobuf  = "protobuf"
	FormatDelimited = "delimited"
	FormatCustom    = "custom"

	DefaultField = "self"
	MetaKey      = "__meta"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ColumnSetter

type ColumnSetter interface {
	SetColumns([]string)
}

type Compressor

type Compressor interface {
	Compress([]byte) ([]byte, error)
}

Compressor compresses and decompresses bytes

type Converter

type Converter interface {
	Encode(ctx api.StreamContext, d any) ([]byte, error)
	Decode(ctx api.StreamContext, b []byte) (any, error)
}

Converter converts bytes & map or []map according to the schema

type ConverterProvider

type ConverterProvider func(schemaFileName string, SchemaMessageName string, delimiter string, logicalSchema map[string]*ast.JsonStreamField) (Converter, error)

ConverterProvider The format, schema information are passed in by stream options The columns information is defined in the source side, like file source

type Decompressor

type Decompressor interface {
	Decompress([]byte) ([]byte, error)
}

type Encryptor

type Encryptor interface {
	Encrypt([]byte) []byte
}

Encryptor encrypts bytes

type SchemaProvider

type SchemaProvider interface {
	GetSchemaJson() string
}

type SchemaResetAbleConverter

type SchemaResetAbleConverter interface {
	ResetSchema(schema map[string]*ast.JsonStreamField)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL