codec

Documentation

Index

• Constants
• func BuildInvokeOutboundByErr(err *transerr.TransError) *pb.Outbound
• func BuildInvokeOutboundByPayload(payload []byte) *pb.Outbound
• func BuildTransportOutboundByErr(err *transerr.TransError) *pb.TransportOutbound
• func BuildTransportOutboundByPayload(payload []byte) *pb.TransportOutbound
• type Codec
• type Outbound
  • func BuildOutboundByErr(err *transerr.TransError) *Outbound
  • func BuildOutboundByPayload(payload []byte) *Outbound
• type ProtoCodec
  • func NewProtoCodec() *ProtoCodec
  • func (c *ProtoCodec) ContentType() string
  • func (c *ProtoCodec) Marshal(out *Outbound) ([]byte, error)
  • func (c *ProtoCodec) UnMarshal(b []byte) (*Outbound, error)

Constants

const (
	PtpSessionID    = "x-ptp-session-id"
	PtpTargetNodeID = "x-ptp-target-node-id"
	PtpSourceNodeID = "x-ptp-source-node-id"
	PtpTraceID      = "x-ptp-trace-id"
	PtpTopicID      = "x-ptp-topic"
)

header

Functions

func BuildInvokeOutboundByErr

func BuildInvokeOutboundByErr(err *transerr.TransError) *pb.Outbound

func BuildInvokeOutboundByPayload

func BuildInvokeOutboundByPayload(payload []byte) *pb.Outbound

func BuildTransportOutboundByErr

func BuildTransportOutboundByErr(err *transerr.TransError) *pb.TransportOutbound

func BuildTransportOutboundByPayload

func BuildTransportOutboundByPayload(payload []byte) *pb.TransportOutbound

Types

type Codec

type Codec interface {
	Marshal(out *Outbound) ([]byte, error)
	UnMarshal([]byte) (*Outbound, error)
	ContentType() string
}

type Outbound

type Outbound ptp.TransportOutbound

func BuildOutboundByErr

func BuildOutboundByErr(err *transerr.TransError) *Outbound

func BuildOutboundByPayload

func BuildOutboundByPayload(payload []byte) *Outbound

type ProtoCodec

type ProtoCodec struct {
}

func NewProtoCodec

func NewProtoCodec() *ProtoCodec

func (*ProtoCodec) ContentType

func (c *ProtoCodec) ContentType() string

func (*ProtoCodec) Marshal

func (c *ProtoCodec) Marshal(out *Outbound) ([]byte, error)

func (*ProtoCodec) UnMarshal

func (c *ProtoCodec) UnMarshal(b []byte) (*Outbound, error)