wrp

package

Go to main page

Versions in this module

v1

v1.3.1

Sep 4, 2019

v1.3.0

Aug 29, 2019

v1.2.0

Jul 16, 2019

v1.1.0

Jul 15, 2019

Changes in this version

type Message

+ func (msg *Message) FindEventStringSubMatch() string

type MessageType

+ const UnknownMessageType

type SimpleRequestResponse

+ func (msg *SimpleRequestResponse) FindEventStringSubMatch() string

+ type Unknown struct

+ Type MessageType

+ func (msg *Unknown) BeforeEncode() error

+ func (x *Unknown) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Unknown) CodecEncodeSelf(e *codec1978.Encoder)

v1.0.0

Mar 15, 2019

Changes in this version

+ const HeadersArrHeader

+ const IncludeSpansHeader

+ const MsgTypeHeader

+ const PathHeader

+ const RDRHeader

+ const SourceHeader

+ const SpansHeader

+ const StatusHeader

+ const TransactionUuidHeader

+ var ErrInvalidMsgType = errors.New("Invalid Message Type")

+ func MustEncode(message interface{}, f Format) []byte

+ type CRUD struct

+ ContentType string

+ Destination string

+ Headers []string

+ IncludeSpans *bool

+ Metadata map[string]string

+ PartnerIDs []string

+ Path string

+ Payload []byte

+ RequestDeliveryResponse *int64

+ Source string

+ Spans [][]string

+ Status *int64

+ TransactionUUID string

+ Type MessageType

+ func (msg *CRUD) From() string

+ func (msg *CRUD) IsTransactionPart() bool

+ func (msg *CRUD) MessageType() MessageType

+ func (msg *CRUD) Response(newSource string, requestDeliveryResponse int64) Routable

+ func (msg *CRUD) SetIncludeSpans(value bool) *CRUD

+ func (msg *CRUD) SetRequestDeliveryResponse(value int64) *CRUD

+ func (msg *CRUD) SetStatus(value int64) *CRUD

+ func (msg *CRUD) To() string

+ func (msg *CRUD) TransactionKey() string

+ func (x *CRUD) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *CRUD) CodecEncodeSelf(e *codec1978.Encoder)

+ type Decoder interface

+ Decode func(interface{}) error

+ Reset func(io.Reader)

+ ResetBytes func([]byte)

+ func NewDecoder(input io.Reader, f Format) Decoder

+ func NewDecoderBytes(input []byte, f Format) Decoder

+ type EncodeListener interface

+ BeforeEncode func() error

+ type Encoder interface

+ Encode func(interface{}) error

+ Reset func(io.Writer)

+ ResetBytes func(*[]byte)

+ func NewEncoder(output io.Writer, f Format) Encoder

+ func NewEncoderBytes(output *[]byte, f Format) Encoder

+ type Format int

+ const JSON

+ const Msgpack

+ func AllFormats() []Format

+ func FormatFromContentType(contentType string, fallback ...Format) (Format, error)

+ func (f Format) ContentType() string

+ func (i Format) String() string

+ type Message struct

+ Accept string

+ ContentType string

+ Destination string

+ Headers []string

+ IncludeSpans *bool

+ Metadata map[string]string

+ PartnerIDs []string

+ Path string

+ Payload []byte

+ RequestDeliveryResponse *int64

+ ServiceName string

+ Source string

+ Spans [][]string

+ Status *int64

+ TransactionUUID string

+ Type MessageType

+ URL string

+ func TranscodeMessage(target Encoder, source Decoder) (msg *Message, err error)

+ func (msg *Message) From() string

+ func (msg *Message) IsTransactionPart() bool

+ func (msg *Message) MessageType() MessageType

+ func (msg *Message) Response(newSource string, requestDeliveryResponse int64) Routable

+ func (msg *Message) SetIncludeSpans(value bool) *Message

+ func (msg *Message) SetRequestDeliveryResponse(value int64) *Message

+ func (msg *Message) SetStatus(value int64) *Message

+ func (msg *Message) To() string

+ func (msg *Message) TransactionKey() string

+ func (x *Message) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *Message) CodecEncodeSelf(e *codec1978.Encoder)

+ type MessageType int64

+ const CreateMessageType

+ const DeleteMessageType

+ const RetrieveMessageType

+ const ServiceAliveMessageType

+ const ServiceRegistrationMessageType

+ const SimpleEventMessageType

+ const SimpleRequestResponseMessageType

+ const UpdateMessageType

+ func StringToMessageType(value string) (MessageType, error)

+ func (i MessageType) String() string

+ func (mt MessageType) FriendlyName() string

+ func (mt MessageType) SupportsTransaction() bool

+ type Routable interface

+ From func() string

+ IsTransactionPart func() bool

+ Response func(newSource string, requestDeliveryResponse int64) Routable

+ To func() string

+ TransactionKey func() string

+ type ServiceAlive struct

+ Type MessageType

+ func (msg *ServiceAlive) BeforeEncode() error

+ func (x *ServiceAlive) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ServiceAlive) CodecEncodeSelf(e *codec1978.Encoder)

+ type ServiceRegistration struct

+ ServiceName string

+ Type MessageType

+ URL string

+ func (msg *ServiceRegistration) BeforeEncode() error

+ func (x *ServiceRegistration) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *ServiceRegistration) CodecEncodeSelf(e *codec1978.Encoder)

+ type SimpleEvent struct

+ ContentType string

+ Destination string

+ Headers []string

+ Metadata map[string]string

+ PartnerIDs []string

+ Payload []byte

+ Source string

+ Type MessageType

+ func (msg *SimpleEvent) BeforeEncode() error

+ func (msg *SimpleEvent) From() string

+ func (msg *SimpleEvent) IsTransactionPart() bool

+ func (msg *SimpleEvent) MessageType() MessageType

+ func (msg *SimpleEvent) Response(newSource string, requestDeliveryResponse int64) Routable

+ func (msg *SimpleEvent) To() string

+ func (msg *SimpleEvent) TransactionKey() string

+ func (x *SimpleEvent) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SimpleEvent) CodecEncodeSelf(e *codec1978.Encoder)

+ type SimpleRequestResponse struct

+ Accept string

+ ContentType string

+ Destination string

+ Headers []string

+ IncludeSpans *bool

+ Metadata map[string]string

+ PartnerIDs []string

+ Payload []byte

+ RequestDeliveryResponse *int64

+ Source string

+ Spans [][]string

+ Status *int64

+ TransactionUUID string

+ Type MessageType

+ func (msg *SimpleRequestResponse) BeforeEncode() error

+ func (msg *SimpleRequestResponse) From() string

+ func (msg *SimpleRequestResponse) IsTransactionPart() bool

+ func (msg *SimpleRequestResponse) MessageType() MessageType

+ func (msg *SimpleRequestResponse) Response(newSource string, requestDeliveryResponse int64) Routable

+ func (msg *SimpleRequestResponse) SetIncludeSpans(value bool) *SimpleRequestResponse

+ func (msg *SimpleRequestResponse) SetRequestDeliveryResponse(value int64) *SimpleRequestResponse

+ func (msg *SimpleRequestResponse) SetStatus(value int64) *SimpleRequestResponse

+ func (msg *SimpleRequestResponse) To() string

+ func (msg *SimpleRequestResponse) TransactionKey() string

+ func (x *SimpleRequestResponse) CodecDecodeSelf(d *codec1978.Decoder)

+ func (x *SimpleRequestResponse) CodecEncodeSelf(e *codec1978.Encoder)

+ type Typed interface

+ MessageType func() MessageType

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