Versions in this module Expand all Collapse all v1 v1.12.0 Dec 10, 2021 v1.11.2 Nov 25, 2021 Changes in this version + const MetadataEncoding + const MetadataEncodingBinary + const MetadataEncodingJSON + const MetadataEncodingNil + const MetadataEncodingProto + const MetadataEncodingProtoJSON + var ErrEncodingIsNotSet = errors.New("payload encoding metadata is not set") + var ErrEncodingIsNotSupported = errors.New("payload encoding is not supported") + var ErrMetadataIsNotSet = errors.New("metadata is not set") + var ErrTypeIsNotByteSlice = errors.New("type is not *[]byte") + var ErrTypeNotImplementProtoMessage = errors.New("type doesn't implement proto.Message") + var ErrUnableToDecode = errors.New("unable to decode") + var ErrUnableToEncode = errors.New("unable to encode") + var ErrUnableToFindConverter = errors.New("unable to find converter") + var ErrUnableToSetValue = errors.New("unable to set value") + var ErrValuePtrIsNotPointer = errors.New("not a pointer type") + var ErrValuePtrMustConcreteType = errors.New("must be a concrete type, not interface") + type ByteSlicePayloadConverter struct + func NewByteSlicePayloadConverter() *ByteSlicePayloadConverter + func (c *ByteSlicePayloadConverter) Encoding() string + func (c *ByteSlicePayloadConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (c *ByteSlicePayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (c *ByteSlicePayloadConverter) ToString(payload *commonpb.Payload) string + type CompositeDataConverter struct + func (dc *CompositeDataConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (dc *CompositeDataConverter) FromPayloads(payloads *commonpb.Payloads, valuePtrs ...interface{}) error + func (dc *CompositeDataConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (dc *CompositeDataConverter) ToPayloads(values ...interface{}) (*commonpb.Payloads, error) + func (dc *CompositeDataConverter) ToString(payload *commonpb.Payload) string + func (dc *CompositeDataConverter) ToStrings(payloads *commonpb.Payloads) []string + type DataConverter interface + FromPayload func(payload *commonpb.Payload, valuePtr interface{}) error + FromPayloads func(payloads *commonpb.Payloads, valuePtrs ...interface{}) error + ToPayload func(value interface{}) (*commonpb.Payload, error) + ToPayloads func(value ...interface{}) (*commonpb.Payloads, error) + ToString func(input *commonpb.Payload) string + ToStrings func(input *commonpb.Payloads) []string + func GetDefaultDataConverter() DataConverter + func NewCompositeDataConverter(payloadConverters ...PayloadConverter) DataConverter + type EncodedValue interface + Get func(valuePtr interface{}) error + HasValue func() bool + type EncodedValues interface + Get func(valuePtr ...interface{}) error + HasValues func() bool + type EncodingDataConverter struct + func NewEncodingDataConverter(parent DataConverter, encoders ...PayloadEncoder) *EncodingDataConverter + func (e *EncodingDataConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (e *EncodingDataConverter) FromPayloads(payloads *commonpb.Payloads, valuePtrs ...interface{}) error + func (e *EncodingDataConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (e *EncodingDataConverter) ToPayloads(value ...interface{}) (*commonpb.Payloads, error) + func (e *EncodingDataConverter) ToString(input *commonpb.Payload) string + func (e *EncodingDataConverter) ToStrings(input *commonpb.Payloads) []string + type JSONPayloadConverter struct + func NewJSONPayloadConverter() *JSONPayloadConverter + func (c *JSONPayloadConverter) Encoding() string + func (c *JSONPayloadConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (c *JSONPayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (c *JSONPayloadConverter) ToString(payload *commonpb.Payload) string + type NilPayloadConverter struct + func NewNilPayloadConverter() *NilPayloadConverter + func (c *NilPayloadConverter) Encoding() string + func (c *NilPayloadConverter) FromPayload(_ *commonpb.Payload, valuePtr interface{}) error + func (c *NilPayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (c *NilPayloadConverter) ToString(*commonpb.Payload) string + type PayloadConverter interface + Encoding func() string + FromPayload func(payload *commonpb.Payload, valuePtr interface{}) error + ToPayload func(value interface{}) (*commonpb.Payload, error) + ToString func(*commonpb.Payload) string + type PayloadEncoder interface + Decode func(*commonpb.Payload) error + Encode func(*commonpb.Payload) error + func NewZlibEncoder(options ZlibEncoderOptions) PayloadEncoder + type ProtoJSONPayloadConverter struct + func NewProtoJSONPayloadConverter() *ProtoJSONPayloadConverter + func (c *ProtoJSONPayloadConverter) Encoding() string + func (c *ProtoJSONPayloadConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (c *ProtoJSONPayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (c *ProtoJSONPayloadConverter) ToString(payload *commonpb.Payload) string + type ProtoPayloadConverter struct + func NewProtoPayloadConverter() *ProtoPayloadConverter + func (c *ProtoPayloadConverter) Encoding() string + func (c *ProtoPayloadConverter) FromPayload(payload *commonpb.Payload, valuePtr interface{}) error + func (c *ProtoPayloadConverter) ToPayload(value interface{}) (*commonpb.Payload, error) + func (c *ProtoPayloadConverter) ToString(payload *commonpb.Payload) string + type ZlibEncoderOptions struct + AlwaysEncode bool
Go to main page