executor

Jan 12, 2022

Changes in this version

+ type Executor struct

+ func NewExecutor(conn *connection.Connection, log *zap.Logger, connID string, ...) *Executor

+ func (e *Executor) CleanUp()

+ func (e *Executor) Leave(topics []string) error

+ func (e *Executor) Set(topics []string) error

+ func (e *Executor) StartCommandLoop() error

+ type Response struct

+ Payload []string

+ Topic string