messaging

Documentation

Index

• Constants
• Variables
• func CompressMessage(message *Message, level int) error
• func DecodeObject(data []byte, object BankObject) error
• func DecompressMessage(message *Message) error
• func DecryptMessageFrom(ctx context.Context, to *security.Key, from security.EncryptionPublicKey, ...) error
• func EncodeObject(object BankObject) ([]byte, error)
• func EncryptMessageFor(ctx context.Context, from *security.Key, to security.EncryptionPublicKey, ...) error
• func FromMessage(message *Message, object BankObject) error
• func RequestMessage(ctx context.Context, appName string, subject string, req, resp BankObject) error
• func SignMessage(ctx context.Context, key *security.Key, message *Message) error
• func ToNats(messaging Messaging) *nats.Conn
• func VerifyMessageSignature(key security.SignaturePublicKey, message *Message) (bool, error)
• func WithMessaging(ctx context.Context, messaging Messaging) context.Context
• type BankObject
• type Message
  • func HandleRequest(ctx context.Context, appName string, message *Message, request BankObject, ...) (*Message, error)
  • func NewMessage() *Message
  • func ToMessage(from string, object BankObject) *Message
  • func (m *Message) Decode(data []byte) error
  • func (m *Message) Encode() ([]byte, error)
  • func (m *Message) IsCompressed() bool
  • func (m *Message) IsEncrypted() bool
  • func (m *Message) IsSigned() bool
  • func (m *Message) SetCompressed(compressed bool)
  • func (m *Message) SetEncrypted(encrypted bool)
  • func (m *Message) SetSigned(signed bool)
• type MessageFlag
• type MessageHandler
• type Messaging
  • func FromContext(ctx context.Context) Messaging
• type NC
• type RequestHandler

Constants

const (
	CurrentVersion = "1.0"
)

const (
	MessagingKey = "Key.MessagingKey"
)

Variables

var (
	ErrHandleRequest = errors.New("Request handle failed")
	ErrRequestFailed = errors.New("Request Failed")
)

var (
	ErrNoData               = errors.New("No Data")
	ErrInvalidMessage       = errors.New("Invalid Message")
	ErrOperationNotPermited = errors.New("Operation Not Permited")
)

var (
	ErrEncrypt      = errors.New("Failed to Encrypt")
	ErrSignature    = errors.New("Failed to Sign message")
	ErrNotSigned    = errors.New("Message Not Signed")
	ErrVerifyFailed = errors.New("Fail to verify signature")
)

Functions

func CompressMessage

func CompressMessage(message *Message, level int) error

func DecodeObject

func DecodeObject(data []byte, object BankObject) error

Decode store BankObject from bytes. Decoded with gob

func DecompressMessage

func DecompressMessage(message *Message) error

func DecryptMessageFrom

func DecryptMessageFrom(ctx context.Context, to *security.Key, from security.EncryptionPublicKey, message *Message) error

func EncodeObject

func EncodeObject(object BankObject) ([]byte, error)

encode return bytes from BankObject. Encoded with gob

func EncryptMessageFor

func EncryptMessageFor(ctx context.Context, from *security.Key, to security.EncryptionPublicKey, message *Message) error

func FromMessage

func FromMessage(message *Message, object BankObject) error

func RequestMessage

func RequestMessage(ctx context.Context, appName string, subject string, req, resp BankObject) error

func SignMessage

func SignMessage(ctx context.Context, key *security.Key, message *Message) error

func ToNats

func ToNats(messaging Messaging) *nats.Conn

func VerifyMessageSignature

func VerifyMessageSignature(key security.SignaturePublicKey, message *Message) (bool, error)

func WithMessaging

func WithMessaging(ctx context.Context, messaging Messaging) context.Context

WithMessaging returns a context with the messaging set

Types

type BankObject

type BankObject interface {
	Encode() ([]byte, error)
	Decode(data []byte) error
}

type Message

type Message struct {
	Version string // Version for compatibility
	From    string `json:",omitempty"` // From is the public key of sender
	Data    []byte `json:",omitempty"` // Data payload
	Flags   uint   `json:",omitempty"` // Flags for Compressed, Encrypted, Signed
	Error   string `json:",omitempty"` // Error in message processing
}

Message used for all communication between components

func HandleRequest

func HandleRequest(ctx context.Context, appName string, message *Message, request BankObject, handle RequestHandler) (*Message, error)

func NewMessage

func NewMessage() *Message

func ToMessage

func ToMessage(from string, object BankObject) *Message

func (*Message) Decode

func (m *Message) Decode(data []byte) error

Decode return Message from bytes. Decoded with gob

func (*Message) Encode

func (m *Message) Encode() ([]byte, error)

Encode return bytes from Message. Encoded with gob

func (*Message) IsCompressed

func (m *Message) IsCompressed() bool

func (*Message) IsEncrypted

func (m *Message) IsEncrypted() bool

func (*Message) IsSigned

func (m *Message) IsSigned() bool

func (*Message) SetCompressed

func (m *Message) SetCompressed(compressed bool)

func (*Message) SetEncrypted

func (m *Message) SetEncrypted(encrypted bool)

func (*Message) SetSigned

func (m *Message) SetSigned(signed bool)

type MessageFlag

type MessageFlag uint32

type MessageHandler

type MessageHandler func(ctx context.Context, subject string, message *Message) (*Message, error)

type Messaging

type Messaging interface {
	NC() NC

	SubscribeWorkers(ctx context.Context, subject string, workerCount int, handle MessageHandler)
	Subscribe(ctx context.Context, subject string, handle MessageHandler)

	Publish(ctx context.Context, subject string, message *Message) error

	Request(ctx context.Context, subject string, message *Message) (*Message, error)
	RequestWithTimeout(ctx context.Context, subject string, message *Message, timeout time.Duration) (*Message, error)
}

func FromContext

func FromContext(ctx context.Context) Messaging

type NC

type NC interface{}

Messaging (Nats)

type RequestHandler

type RequestHandler func(ctx context.Context, request BankObject) (BankObject, error)