slack

Documentation

Index

• Constants
• type Attachment
• type Field
• type Notifier
  • func NewNotifier(opts ...NotifierOption) *Notifier
  • func (notifier *Notifier) Close() error
  • func (notifier *Notifier) DispatchAccountUpdatedEvent(userId string, userSettings bson.Raw, event *events.AccountUpdated) error
  • func (notifier *Notifier) DispatchAccountWitnessVotedEvent(userId string, userSettings bson.Raw, event *events.AccountWitnessVoted) error
  • func (notifier *Notifier) DispatchCommentPublishedEvent(userId string, userSettings bson.Raw, event *events.CommentPublished) error
  • func (notifier *Notifier) DispatchCommentVotedEvent(userId string, userSettings bson.Raw, event *events.CommentVoted) error
  • func (notifier *Notifier) DispatchStoryPublishedEvent(userId string, userSettings bson.Raw, event *events.StoryPublished) error
  • func (notifier *Notifier) DispatchStoryVotedEvent(userId string, userSettings bson.Raw, event *events.StoryVoted) error
  • func (notifier *Notifier) DispatchTransferMadeEvent(userId string, userSettings bson.Raw, event *events.TransferMade) error
  • func (notifier *Notifier) DispatchUserFollowStatusChangedEvent(userId string, userSettings bson.Raw, event *events.UserFollowStatusChanged) error
  • func (notifier *Notifier) DispatchUserMentionedEvent(userId string, userSettings bson.Raw, event *events.UserMentioned) error
• type NotifierOption
  • func SetMaxConcurrentRequests(maxConcurrentRequests uint) NotifierOption
  • func SetWebhookTimeout(timeout time.Duration) NotifierOption
• type Payload
• type Settings
  • func UnmarshalSettings(userId string, raw bson.Raw) (*Settings, error)
  • func (settings *Settings) Validate() error

Constants

const DefaultMaxConcurrentRequests = 1000

Types

type Attachment

type Attachment struct {
	Fallback   string   `json:"fallback"`
	Color      string   `json:"color,omitempty"`
	Pretext    string   `json:"pretext,omitempty"`
	AuthorName string   `json:"author_name,omitempty"`
	AuthorLink string   `json:"author_link,omitempty"`
	AuthorIcon string   `json:"author_icon,omitempty"`
	Title      string   `json:"title,omitempty"`
	TitleLink  string   `json:"title_link,omitempty"`
	Text       string   `json:"text,omitempty"`
	Fields     []*Field `json:"fields,omitempty"`
	ImageURL   string   `json:"image_url,omitempty"`
	ThumbURL   string   `json:"thumb_url,omitempty"`
	Footer     string   `json:"footer,omitempty"`
	FooterIcon string   `json:"footer_icon,omitempty"`
	Timestamp  uint64   `json:"ts,omitempty"`
}

type Field

type Field struct {
	Title string `json:"title"`
	Value string `json:"value"`
	Short bool   `json:"short,omitempty"`
}

type Notifier

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

func NewNotifier

func NewNotifier(opts ...NotifierOption) *Notifier

func (*Notifier) Close

func (notifier *Notifier) Close() error

func (*Notifier) DispatchAccountUpdatedEvent

func (notifier *Notifier) DispatchAccountUpdatedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.AccountUpdated,
) error

func (*Notifier) DispatchAccountWitnessVotedEvent

func (notifier *Notifier) DispatchAccountWitnessVotedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.AccountWitnessVoted,
) error

func (*Notifier) DispatchCommentPublishedEvent

func (notifier *Notifier) DispatchCommentPublishedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.CommentPublished,
) error

func (*Notifier) DispatchCommentVotedEvent

func (notifier *Notifier) DispatchCommentVotedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.CommentVoted,
) error

func (*Notifier) DispatchStoryPublishedEvent

func (notifier *Notifier) DispatchStoryPublishedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.StoryPublished,
) error

func (*Notifier) DispatchStoryVotedEvent

func (notifier *Notifier) DispatchStoryVotedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.StoryVoted,
) error

func (*Notifier) DispatchTransferMadeEvent

func (notifier *Notifier) DispatchTransferMadeEvent(
	userId string,
	userSettings bson.Raw,
	event *events.TransferMade,
) error

func (*Notifier) DispatchUserFollowStatusChangedEvent

func (notifier *Notifier) DispatchUserFollowStatusChangedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.UserFollowStatusChanged,
) error

func (*Notifier) DispatchUserMentionedEvent

func (notifier *Notifier) DispatchUserMentionedEvent(
	userId string,
	userSettings bson.Raw,
	event *events.UserMentioned,
) error

type NotifierOption

type NotifierOption func(*Notifier)

func SetMaxConcurrentRequests

func SetMaxConcurrentRequests(maxConcurrentRequests uint) NotifierOption

func SetWebhookTimeout

func SetWebhookTimeout(timeout time.Duration) NotifierOption

type Payload

type Payload struct {
	Text        string        `json:"text,omitempty"`
	Attachments []*Attachment `json:"attachments,omitempty"`
}

type Settings

type Settings struct {
	WebhookURL string `bson:"webhookURL"`
}

func UnmarshalSettings

func UnmarshalSettings(userId string, raw bson.Raw) (*Settings, error)

func (*Settings) Validate

func (settings *Settings) Validate() error