executor

Documentation

Index

• type Executor
  • func NewExecutor(conn *connection.Connection, log logger.Logger, connID string, ...) *Executor
  • func (e *Executor) CleanUp()
  • func (e *Executor) Leave(br pubsub.PubSub, topics []string) error
  • func (e *Executor) Set(br pubsub.PubSub, topics []string) error
  • func (e *Executor) StartCommandLoop() error
• type Response

Types

type Executor

type Executor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewExecutor

func NewExecutor(conn *connection.Connection, log logger.Logger,
	connID string, pubsubs map[string]pubsub.PubSub, av validator.AccessValidatorFn, r *http.Request) *Executor

NewExecutor creates protected connection and starts command loop

func (*Executor) CleanUp

func (e *Executor) CleanUp()

func (*Executor) Leave

func (e *Executor) Leave(br pubsub.PubSub, topics []string) error

func (*Executor) Set

func (e *Executor) Set(br pubsub.PubSub, topics []string) error

func (*Executor) StartCommandLoop

func (e *Executor) StartCommandLoop() error

type Response

type Response struct {
	Topic   string   `json:"topic"`
	Payload []string `json:"payload"`
}