slack

Documentation

Index

• func NewState(limiter *rate.Limiter) *state
• func NewThreadedClient(client SlackClient, s *state) *threadedClient
• func SendMessageRateLimited(client SlackClient, ctx context.Context, limiter *rate.Limiter, ...) (ts, channelID string, err error)
• type DeliveryPolicy
  • func (p DeliveryPolicy) FromString(policy string) DeliveryPolicy
  • func (p DeliveryPolicy) MarshalJSON() ([]byte, error)
  • func (p DeliveryPolicy) String() string
  • func (p *DeliveryPolicy) UnmarshalJSON(b []byte) error
• type SlackClient

Functions

func NewState

func NewState(limiter *rate.Limiter) *state

func NewThreadedClient

func NewThreadedClient(client SlackClient, s *state) *threadedClient

func SendMessageRateLimited

func SendMessageRateLimited(client SlackClient, ctx context.Context, limiter *rate.Limiter, recipient string, options ...sl.MsgOption) (ts, channelID string, err error)

Types

type DeliveryPolicy

type DeliveryPolicy int

const (
	Post DeliveryPolicy = iota
	PostAndUpdate
	Update
)

func (DeliveryPolicy) FromString

func (p DeliveryPolicy) FromString(policy string) DeliveryPolicy

func (DeliveryPolicy) MarshalJSON

func (p DeliveryPolicy) MarshalJSON() ([]byte, error)

func (DeliveryPolicy) String

func (p DeliveryPolicy) String() string

func (*DeliveryPolicy) UnmarshalJSON

func (p *DeliveryPolicy) UnmarshalJSON(b []byte) error

type SlackClient

type SlackClient interface {
	SendMessageContext(ctx context.Context, channelID string, options ...sl.MsgOption) (string, string, string, error)
}