slacksub

Documentation

Index

• type Subscriber
  • func New(cl *pubsub.Client, topic, slackgwURL, authtoken string) *Subscriber
  • func (sub *Subscriber) Close()
  • func (sub *Subscriber) Reply(ch, s string) error
  • func (sub *Subscriber) Run()

Types

type Subscriber

type Subscriber struct {
	Client          *pubsub.Client
	Done            chan struct{}
	HTTPClient      *http.Client
	MessageCallback func(*slack.MessageEvent) error
	Msgch           chan *pubsub.Message
	SlackgwURL      string
	AuthToken       string
	Topic           string
}

func New

func New(cl *pubsub.Client, topic, slackgwURL, authtoken string) *Subscriber

func (*Subscriber) Close

func (sub *Subscriber) Close()

func (*Subscriber) Reply

func (sub *Subscriber) Reply(ch, s string) error

func (*Subscriber) Run

func (sub *Subscriber) Run()