plugins

Documentation

Index

• type RedirectPlugin
  • func (rp *RedirectPlugin) AddSub(client *Client, topic []string, qos byte, complete chan byte)
  • func (rp *RedirectPlugin) DeleteSub(client *Client, topic []string, complete chan bool)
  • func (rp *RedirectPlugin) Initialise() error
  • func (rp *RedirectPlugin) Run()
• type Secrets
• type TwitterPlugin
  • func (tp *TwitterPlugin) AddSub(client *Client, subscription []string, qos byte, complete chan byte)
  • func (tp *TwitterPlugin) DeleteSub(client *Client, topic []string, complete chan bool)
  • func (tp *TwitterPlugin) Initialise() error
  • func (tp *TwitterPlugin) Run()

Types

type RedirectPlugin

type RedirectPlugin struct {
	sync.RWMutex
	Redirects map[string]string
	// contains filtered or unexported fields
}

func (*RedirectPlugin) AddSub

func (rp *RedirectPlugin) AddSub(client *Client, topic []string, qos byte, complete chan byte)

func (*RedirectPlugin) DeleteSub

func (rp *RedirectPlugin) DeleteSub(client *Client, topic []string, complete chan bool)

func (*RedirectPlugin) Initialise

func (rp *RedirectPlugin) Initialise() error

func (*RedirectPlugin) Run

func (rp *RedirectPlugin) Run()

type Secrets

type Secrets struct {
	ConsumerKey    string `json:"consumerKey,omitempty"`
	ConsumerSecret string `json:"consumerSecret,omitempty"`
	AccessToken    string `json:"accessToken,omitempty"`
	AccessSecret   string `json:"accessSecret,omitempty"`
}

type TwitterPlugin

type TwitterPlugin struct {
	sync.RWMutex

	Subscribed map[*Client]byte
	// contains filtered or unexported fields
}

func (*TwitterPlugin) AddSub

func (tp *TwitterPlugin) AddSub(client *Client, subscription []string, qos byte, complete chan byte)

func (*TwitterPlugin) DeleteSub

func (tp *TwitterPlugin) DeleteSub(client *Client, topic []string, complete chan bool)

func (*TwitterPlugin) Initialise

func (tp *TwitterPlugin) Initialise() error

func (*TwitterPlugin) Run

func (tp *TwitterPlugin) Run()