v1.2.51 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jun 13, 2020 License: MIT Imports: 8 Imported by: 0




This section is empty.


View Source
var AccountCreditedEncoder = func() encoding.Encoder { return events.AccountCredited{} }
View Source
var AccountDebitedEncoder = func() encoding.Encoder { return events.AccountDebited{} }
View Source
var AccountDetailsUpdatedEncoder = func() encoding.Encoder { return events.AccountDetailsUpdated{} }
View Source
var CustomerProfileUpdatedEncoder = func() encoding.Encoder { return events.CustomerProfileUpdated{} }
View Source
var KeyEncoder = func() encoding.Encoder { return Int64Encoder{} }
View Source
var MessageEncoder = func() encoding.Encoder { return events.MessageCreated{} }
View Source
var TransactionReceivedEncoder = func() encoding.Encoder { return TransactionEncoder{} }
View Source
var UuidKeyEncoder = func() encoding.Encoder { return UuidEncoder{} }


This section is empty.


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 added in v1.2.50

type UuidEncoder struct{}

func (UuidEncoder) Decode added in v1.2.50

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

func (UuidEncoder) Encode added in v1.2.50

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

Jump to

Keyboard shortcuts

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