moleculer-go/moleculer

View on GitHub
serializer/serializer.go

Summary

Maintainability
A
0 mins
Test Coverage
package serializer

import (
    "io"

    "github.com/moleculer-go/moleculer"
)

type Serializer interface {
    ReaderToPayload(io.Reader) moleculer.Payload
    BytesToPayload(*[]byte) moleculer.Payload
    PayloadToBytes(moleculer.Payload) []byte
    PayloadToString(moleculer.Payload) string
    MapToString(interface{}) string
    StringToMap(string) map[string]interface{}
    PayloadToContextMap(moleculer.Payload) map[string]interface{}
    MapToPayload(*map[string]interface{}) (moleculer.Payload, error)
}

func New(broker *moleculer.BrokerDelegates) Serializer {
    return CreateJSONSerializer(broker.Logger("serializer", "json"))
}