encoders

Documentation

Index

• Variables
• type Int64Encoder
  • func (Int64Encoder) Decode(data []byte) (interface{}, error)
  • func (Int64Encoder) Encode(v interface{}) ([]byte, error)
• type TransactionEncoder
  • func (t TransactionEncoder) Decode(data []byte) (interface{}, error)
  • func (t TransactionEncoder) Encode(data interface{}) ([]byte, error)
• type UuidEncoder
  • func (UuidEncoder) Decode(data []byte) (interface{}, error)
  • func (UuidEncoder) Encode(v interface{}) ([]byte, error)

Variables

var AccountCreditedEncoder = func() encoding.Encoder { return events.AccountCredited{} }

var AccountDebitedEncoder = func() encoding.Encoder { return events.AccountDebited{} }

var AccountDetailsUpdatedEncoder = func() encoding.Encoder { return events.AccountDetailsUpdated{} }

var CustomerProfileUpdatedEncoder = func() encoding.Encoder { return events.CustomerProfileUpdated{} }

var KeyEncoder = func() encoding.Encoder { return Int64Encoder{} }

var MessageEncoder = func() encoding.Encoder { return events.MessageCreated{} }

var TransactionReceivedEncoder = func() encoding.Encoder { return TransactionEncoder{} }

var UuidKeyEncoder = func() encoding.Encoder { return UuidEncoder{} }

Types

type Int64Encoder

type Int64Encoder struct{}

func (Int64Encoder) Decode

func (Int64Encoder) Decode(data []byte) (interface{}, error)

func (Int64Encoder) Encode

func (Int64Encoder) Encode(v interface{}) ([]byte, error)

type TransactionEncoder

type TransactionEncoder struct {
	ID        string      `json:"id"`
	Type      string      `json:"type"`
	Body      interface{} `json:"body"`
	Timestamp int64       `json:"timestamp"`
}

func (TransactionEncoder) Decode

func (t TransactionEncoder) Decode(data []byte) (interface{}, error)

func (TransactionEncoder) Encode

func (t TransactionEncoder) Encode(data interface{}) ([]byte, error)

type UuidEncoder

type UuidEncoder struct{}

func (UuidEncoder) Decode

func (UuidEncoder) Decode(data []byte) (interface{}, error)

func (UuidEncoder) Encode

func (UuidEncoder) Encode(v interface{}) ([]byte, error)