processor

Jan 28, 2019

Changes in this version

+ const JobReceivedSubject

+ const MessageRequestReceivedSubject

type Command

+ func (c Command) ProcessingRequest() *processingpb.ProcessingRequest

+ func (c Command) ShouldExecute() (bool, error)

+ type Executable interface

+ Execute func() (*processingpb.Response, error)

+ ProcessingRequest func() *processingpb.ProcessingRequest

+ ShouldExecute func() (bool, error)

+ type Job struct

+ SchedulingJob schedulingpb.Job

+ func (j Job) Execute() (*processingpb.Response, error)

+ func (j Job) ProcessingRequest() *processingpb.ProcessingRequest

+ func (j Job) ShouldExecute() (bool, error)

Jan 26, 2019

Changes in this version

+ type Repository interface

+ MessageReply func(string) (*processing.MessageReply, error)

+ Migrate func() error

+ ProcessingEvents func(string) ([]*processing.ProcessingEvent, error)

+ ProcessingRequest func(string) (*processing.ProcessingRequest, error)

+ SaveMessageReply func(*processing.MessageReply) error

+ SaveProcessingEvent func(*processing.ProcessingEvent) error

+ SaveProcessingRequest func(*processing.ProcessingRequest) error

+ func NewRepository(url string) (Repository, error)

Dec 1, 2018

Changes in this version

type Command

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

type Storage

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

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

Nov 19, 2018

Changes in this version

+ const CommandCollectionName

+ const CommandEventCollectionName

+ const CommandReceivedSubject

+ const DatabaseName

+ const ProcessorCommandQueueGroup

+ const ProcessorQueueGroup

+ const ReplyCollectionName

+ const ReplyReceivedSubject

+ const RequestReceivedSubject

+ type Client struct

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

+ type Command struct

+ Id string

+ Intent Intent

+ Request Request

+ func (c Command) Execute() (*processing.Reply, error)

+ type CommandEvent struct

+ CommandId string

+ Description string

+ Timestamp int64

+ Type string

+ type Intent struct

+ Enabled bool

+ Endpoint string

+ Help string

+ Id string

+ Name string

+ Regex string

+ Response string

+ Server string

+ func NewIntent(rc registration.Intent) Intent

+ func (i Intent) IsMatch(r Request) (bool, error)

+ type Processor struct

+ func New(logger log.Logger, queue *nats.EncodedConn, ...) Processor

+ func (p Processor) Start() error

+ func (p Processor) Stop()

+ type Request struct

+ Author User

+ Bot User

+ ChannelId string

+ Content string

+ Id string

+ Mentions []User

+ ServerId string

+ Source string

+ type Storage struct

+ CommandCollection *mgo.Collection

+ CommandEventCollection *mgo.Collection

+ ReplyCollection *mgo.Collection

+ Session *mgo.Session

+ 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) Reply(id string) (*processing.Reply, error)

+ func (s Storage) SaveCommand(c Command) error

+ func (s Storage) SaveCommandEvent(e CommandEvent) error

+ func (s Storage) SaveReply(r *processing.Reply) error

+ type User struct

+ Id string

+ Name string

Oct 21, 2018

Changes in this version

+ const RequestSubject

+ func NewLoggingService(logger log.Logger, s pb.ProcessingServer) pb.ProcessingServer

+ func NewService(queue *nats.EncodedConn) pb.ProcessingServer