message

Documentation

Overview

Package message is a service to process and return Agent Base messages

Index

• type Service
  • func NewMessageService(id uuid.UUID) (*Service, error)
  • func (s *Service) Construct(msg messages.Base) (data []byte, err error)
  • func (s *Service) Handle(id uuid.UUID, data []byte) (rdata []byte, err error)

Types

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service is a structure with methods that execute the service functions for Agent messages

func NewMessageService

func NewMessageService(id uuid.UUID) (*Service, error)

NewMessageService is a factory to create and return a ListenerService

func (*Service) Construct

func (s *Service) Construct(msg messages.Base) (data []byte, err error)

Construct takes a Base message and executes the appropriate Listener's Transforms (encoding/encryption) on the input Base message and returns the Base message as bytes

func (*Service) Handle

func (s *Service) Handle(id uuid.UUID, data []byte) (rdata []byte, err error)

Handle is the primary entry function that processes incoming raw data Agent traffic. The raw data is decoded/decrypted by either Listener or Agent's secret key depending on if the Agent completed authentication. Delegate messages are handled here. Once completed, this function checks for return messages that belong to the input Agent and returns them along with any delegate messages.