raw

package

v0.0.0-...-4e3f075 Latest Latest Go to latest Published: Sep 15, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	KeyRawData = "raw_data"
	KeyData    = "data"
	KeyOthers  = "others"
	KeyIgnore  = "ignore"
)

View Source

const PluginRaw = "raw"

This section is empty.

func NewProvider(ctx context.Context, cfg cmap.CustomMap, formatter cfgTY.FormatterScript) (providerType.Plugin, error)

type RawProvider struct {
	// contains filtered or unexported fields
}

func New(ctx context.Context, name string, formatter cfgTY.FormatterScript) (*RawProvider, error)

func (rp *RawProvider) Name() string

func (rp *RawProvider) ToMQTTMessage(sourceMessage *types.Message) (*types.Message, error)

func (rp *RawProvider) ToSourceMessage(mqttMessage *types.Message) (*types.Message, error)