serializer

Documentation

Index

• Constants
• type AnalyticsSerializer
  • func NewAnalyticsSerializer(serializerType string) AnalyticsSerializer
• type MsgpSerializer
  • func (serializer *MsgpSerializer) Decode(analyticsData interface{}, record *analytics.AnalyticsRecord) error
  • func (serializer *MsgpSerializer) Encode(record *analytics.AnalyticsRecord) ([]byte, error)
  • func (serializer *MsgpSerializer) GetSuffix() string
• type ProtobufSerializer
  • func (pb *ProtobufSerializer) Decode(analyticsData interface{}, record *analytics.AnalyticsRecord) error
  • func (pb *ProtobufSerializer) Encode(record *analytics.AnalyticsRecord) ([]byte, error)
  • func (pb *ProtobufSerializer) GetSuffix() string
  • func (pb *ProtobufSerializer) TransformSingleProtoToAnalyticsRecord(rec analyticsproto.AnalyticsRecord, record *analytics.AnalyticsRecord) error
  • func (pb *ProtobufSerializer) TransformSingleRecordToProto(rec analytics.AnalyticsRecord) analyticsproto.AnalyticsRecord

Constants

const MSGP_SERIALIZER = "msgpack"

const PROTOBUF_SERIALIZER = "protobuf"

Types

type AnalyticsSerializer

type AnalyticsSerializer interface {
	Encode(record *analytics.AnalyticsRecord) ([]byte, error)
	Decode(analyticsData interface{}, record *analytics.AnalyticsRecord) error
	GetSuffix() string
}

func NewAnalyticsSerializer

func NewAnalyticsSerializer(serializerType string) AnalyticsSerializer

type MsgpSerializer

type MsgpSerializer struct {
}

func (*MsgpSerializer) Decode

func (serializer *MsgpSerializer) Decode(analyticsData interface{}, record *analytics.AnalyticsRecord) error

func (*MsgpSerializer) Encode

func (serializer *MsgpSerializer) Encode(record *analytics.AnalyticsRecord) ([]byte, error)

func (*MsgpSerializer) GetSuffix

func (serializer *MsgpSerializer) GetSuffix() string

type ProtobufSerializer

type ProtobufSerializer struct {
}

func (*ProtobufSerializer) Decode

func (pb *ProtobufSerializer) Decode(analyticsData interface{}, record *analytics.AnalyticsRecord) error

func (*ProtobufSerializer) Encode

func (pb *ProtobufSerializer) Encode(record *analytics.AnalyticsRecord) ([]byte, error)

func (*ProtobufSerializer) GetSuffix

func (pb *ProtobufSerializer) GetSuffix() string

func (*ProtobufSerializer) TransformSingleProtoToAnalyticsRecord

func (pb *ProtobufSerializer) TransformSingleProtoToAnalyticsRecord(rec analyticsproto.AnalyticsRecord, record *analytics.AnalyticsRecord) error

func (*ProtobufSerializer) TransformSingleRecordToProto

func (pb *ProtobufSerializer) TransformSingleRecordToProto(rec analytics.AnalyticsRecord) analyticsproto.AnalyticsRecord