slack

Documentation

Index

• Constants
• type RetryConfig
• type SlackAdapter
  • func NewSlackAdapter() *SlackAdapter
  • func (a *SlackAdapter) Connect(ctx context.Context, botToken, appToken string) error
  • func (a *SlackAdapter) Disconnect() error
  • func (a *SlackAdapter) GetChannelMembers(ctx context.Context, channelID string) ([]user.User, error)
  • func (a *SlackAdapter) GetChannels(ctx context.Context) ([]channel.Channel, error)
  • func (a *SlackAdapter) GetMessages(ctx context.Context, channelID string, limit int, cursor string) ([]message.Message, string, error)
  • func (a *SlackAdapter) GetThreadReplies(ctx context.Context, channelID, threadTS string) (message.Message, []message.Message, error)
  • func (a *SlackAdapter) PostMessage(ctx context.Context, channelID, text string) error
  • func (a *SlackAdapter) PostThreadReply(ctx context.Context, channelID, threadTS, text string) error
  • func (a *SlackAdapter) SubscribeEvents(ctx context.Context) (<-chan port.SlackEvent, error)

Constants

const (
	DefaultMaxRetries = 3
	DefaultMaxBackoff = 30 * time.Second
)

Types

type RetryConfig

type RetryConfig struct {
	MaxRetries int
	MaxBackoff time.Duration
}

type SlackAdapter

type SlackAdapter struct {
	// contains filtered or unexported fields
}

func NewSlackAdapter

func NewSlackAdapter() *SlackAdapter

func (*SlackAdapter) Connect

func (a *SlackAdapter) Connect(ctx context.Context, botToken, appToken string) error

func (*SlackAdapter) Disconnect

func (a *SlackAdapter) Disconnect() error

func (*SlackAdapter) GetChannelMembers

func (a *SlackAdapter) GetChannelMembers(ctx context.Context, channelID string) ([]user.User, error)

func (*SlackAdapter) GetChannels

func (a *SlackAdapter) GetChannels(ctx context.Context) ([]channel.Channel, error)

func (*SlackAdapter) GetMessages

func (a *SlackAdapter) GetMessages(ctx context.Context, channelID string, limit int, cursor string) ([]message.Message, string, error)

func (*SlackAdapter) GetThreadReplies

func (a *SlackAdapter) GetThreadReplies(ctx context.Context, channelID, threadTS string) (message.Message, []message.Message, error)

func (*SlackAdapter) PostMessage

func (a *SlackAdapter) PostMessage(ctx context.Context, channelID, text string) error

func (*SlackAdapter) PostThreadReply

func (a *SlackAdapter) PostThreadReply(ctx context.Context, channelID, threadTS, text string) error

func (*SlackAdapter) SubscribeEvents

func (a *SlackAdapter) SubscribeEvents(ctx context.Context) (<-chan port.SlackEvent, error)