codec

Documentation

Index

• func DecodeAkkaMessage(msg *akka.AkkaProtocolMessage) (interface{}, string, error)
• func EncodeAkkaMessage(rawMsg proto.Message, recipientPath, senderPath, manifest string, ...) (*akka.AkkaProtocolMessage, error)
• type Option
  • func WithMessageContainerSerializer() Option
  • func WithSelectionEnvelopePattern(pattern []*akka.Selection) Option
• type Options

Functions

func DecodeAkkaMessage

func DecodeAkkaMessage(msg *akka.AkkaProtocolMessage) (interface{}, string, error)

func EncodeAkkaMessage

func EncodeAkkaMessage(rawMsg proto.Message, recipientPath, senderPath, manifest string, opts ...Option) (*akka.AkkaProtocolMessage, error)

Types

type Option

type Option func(*Options)

func WithMessageContainerSerializer

func WithMessageContainerSerializer() Option

func WithSelectionEnvelopePattern

func WithSelectionEnvelopePattern(pattern []*akka.Selection) Option

type Options

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