processor

Documentation

Index

• Constants
• func NewService(queue *nats.EncodedConn, storage Storage) (processing.ProcessingServer, error)
• type Client
  • func (c Client) Do(command Command) (*processing.Response, error)
• type Command
  • func (c Command) Execute() (*processing.Response, error)
  • func (c Command) IsMatch() (bool, error)
• type CommandEvent
• type Processor
  • func New(logger zerolog.Logger, queue *nats.EncodedConn, ...) Processor
  • func (p Processor) Start() error
  • func (p Processor) Stop()
• type Storage
  • func NewStorage(url string) (Storage, error)
  • func (s Storage) Close()
  • func (s Storage) Command(id string) (Command, error)
  • func (s Storage) CommandEvents(id string) ([]CommandEvent, error)
  • func (s Storage) MessageReply(id string) (*processing.MessageReply, error)
  • func (s Storage) SaveCommand(c Command) error
  • func (s Storage) SaveCommandEvent(e CommandEvent) error
  • func (s Storage) SaveMessageReply(r processing.MessageReply) error

Constants

const (
	ProcessorQueueGroup  = "processor"
	ReplyReceivedSubject = "processor.reply.received"
)

const (
	DatabaseName               = "processor"
	CommandCollectionName      = "commands"
	CommandEventCollectionName = "commandevents"
	ReplyCollectionName        = "replies"
)

const (
	RequestReceivedSubject = "request.received"
)

Functions

func NewService

func NewService(queue *nats.EncodedConn, storage Storage) (processing.ProcessingServer, error)

Types

type Client

type Client struct{}

func (Client) Do

func (c Client) Do(command Command) (*processing.Response, error)

type Command

type Command struct {
	Id      string                    `json:"id"`
	Request processing.MessageRequest `json:"request"`
	Intent  intent.Intent             `json:"intent"`
}

func (Command) Execute

func (c Command) Execute() (*processing.Response, error)

func (Command) IsMatch

func (c Command) IsMatch() (bool, error)

type CommandEvent

type CommandEvent struct {
	CommandId   string `json:"commandId"`
	Description string `json:"description"`
	Type        string `json:"type"`
	Timestamp   int64  `json:"timestamp"`
}

type Processor

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

func New

func New(logger zerolog.Logger, queue *nats.EncodedConn, registry intent.IntentRegistryClient, storage Storage) Processor

func (Processor) Start

func (p Processor) Start() error

func (Processor) Stop

func (p Processor) Stop()

type Storage

type Storage struct {
	Session                *mgo.Session
	CommandCollection      *mgo.Collection
	CommandEventCollection *mgo.Collection
	ReplyCollection        *mgo.Collection
}

func NewStorage

func NewStorage(url string) (Storage, error)

func (Storage) Close

func (s Storage) Close()

func (Storage) Command

func (s Storage) Command(id string) (Command, error)

func (Storage) CommandEvents

func (s Storage) CommandEvents(id string) ([]CommandEvent, error)

func (Storage) MessageReply

func (s Storage) MessageReply(id string) (*processing.MessageReply, error)

func (Storage) SaveCommand

func (s Storage) SaveCommand(c Command) error

func (Storage) SaveCommandEvent

func (s Storage) SaveCommandEvent(e CommandEvent) error

func (Storage) SaveMessageReply

func (s Storage) SaveMessageReply(r processing.MessageReply) error