messaging

Documentation

Index

• type Message
  • func NewMessage(operationID string, error error, status string, command string, data []byte) Message
• type MessageImpl
  • func (m *MessageImpl) Deserialize(message []byte) error
  • func (m *MessageImpl) GetCommand() string
  • func (m *MessageImpl) GetData() []byte
  • func (m *MessageImpl) GetError() error
  • func (m *MessageImpl) GetOperationID() string
  • func (m *MessageImpl) GetStatus() string
  • func (m *MessageImpl) Serialize() ([]byte, error)
  • func (m *MessageImpl) SetOperationID(operationID string)
• type MessagingSystem

Types

type Message

type Message interface {
	GetError() error
	GetStatus() string
	GetCommand() string
	GetData() []byte
	GetOperationID() string
	SetOperationID(operationID string)
	Deserialize(message []byte) error
	Serialize() ([]byte, error)
}

func NewMessage

func NewMessage(operationID string, error error, status string, command string, data []byte) Message

NewMessage creates a new message

type MessageImpl

type MessageImpl struct {
	OperationID string `json:"operationID"`
	Command     string `json:"command"`
	Status      string `json:"status"`
	Error       error  `json:"error"`
	Data        []byte `json:"data"`
}

MessageImpl implements the Message interface

func (*MessageImpl) Deserialize

func (m *MessageImpl) Deserialize(message []byte) error

Deserializes a byte slice into Message

func (*MessageImpl) GetCommand

func (m *MessageImpl) GetCommand() string

GetCommand returns the command

func (*MessageImpl) GetData

func (m *MessageImpl) GetData() []byte

GetData returns the data

func (*MessageImpl) GetError

func (m *MessageImpl) GetError() error

GetError returns the error

func (*MessageImpl) GetOperationID

func (m *MessageImpl) GetOperationID() string

Get the operation ID

func (*MessageImpl) GetStatus

func (m *MessageImpl) GetStatus() string

GetStatus returns the status

func (*MessageImpl) Serialize

func (m *MessageImpl) Serialize() ([]byte, error)

Serializes a Message into a byte slice

func (*MessageImpl) SetOperationID

func (m *MessageImpl) SetOperationID(operationID string)

Set the operation ID

type MessagingSystem

type MessagingSystem interface {
	Publish(ctx context.Context, data Message) error
	Subscribe(ctx context.Context) (<-chan Message, context.CancelFunc, error)
	Close(ctx context.Context) error
}

Interface for messaging systems