eventstream

Documentation

Index

• type AccountUpdatedPayload
• type AccountWitnessVotedPayload
• type CommentPublishedPayload
• type CommentVotedPayload
• type Event
• type Manager
  • func NewManager() *Manager
  • func (manager *Manager) Bind(serverCtx *context.Context, group *echo.Group)
  • func (manager *Manager) Close() error
  • func (manager *Manager) DispatchAccountUpdatedEvent(userId string, _ bson.Raw, event *events.AccountUpdated) error
  • func (manager *Manager) DispatchAccountWitnessVotedEvent(userId string, _ bson.Raw, event *events.AccountWitnessVoted) error
  • func (manager *Manager) DispatchCommentPublishedEvent(userId string, _ bson.Raw, event *events.CommentPublished) error
  • func (manager *Manager) DispatchCommentVotedEvent(userId string, _ bson.Raw, event *events.CommentVoted) error
  • func (manager *Manager) DispatchStoryPublishedEvent(userId string, _ bson.Raw, event *events.StoryPublished) error
  • func (manager *Manager) DispatchStoryVotedEvent(userId string, _ bson.Raw, event *events.StoryVoted) error
  • func (manager *Manager) DispatchTransferMadeEvent(userId string, _ bson.Raw, event *events.TransferMade) error
  • func (manager *Manager) DispatchUserFollowStatusChangedEvent(userId string, _ bson.Raw, event *events.UserFollowStatusChanged) error
  • func (manager *Manager) DispatchUserMentionedEvent(userId string, _ bson.Raw, event *events.UserMentioned) error
• type StoryPublishedPayload
• type StoryVotedPayload
• type TransferMadePayload
• type UserFollowStatusChangedPayload
• type UserMentionedPayload

Types

type AccountUpdatedPayload

type AccountUpdatedPayload struct {
	Account string `json:"account"`
}

type AccountWitnessVotedPayload

type AccountWitnessVotedPayload struct {
	Account string `json:"account"`
	Witness string `json:"witness"`
	Approve bool   `json:"approve"`
}

type CommentPublishedPayload

type CommentPublishedPayload struct {
	Author         string `json:"author"`
	URL            string `json:"url"`
	ParentAuthor   string `json:"parentAuthor"`
	ParentPermlink string `json:"parentPermlink"`
	Content        string `json:"content,omitempty"`
	ReadMore       bool   `json:"more,omitempty"`
}

type CommentVotedPayload

type CommentVotedPayload struct {
	Voter              string `json:"voter"`
	VoteWeight         string `json:"voteWeight"`
	Author             string `json:"author"`
	Permlink           string `json:"permlink"`
	URL                string `json:"url"`
	TotalPayout        string `json:"totalPayout"`
	PendingPayout      string `json:"pendingPayout"`
	TotalPendingPayout string `json:"totalPendingPayout"`
}

type Event

type Event struct {
	Kind    string      `json:"kind"`
	Payload interface{} `json:"payload,omitempty"`
}

type Manager

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

func NewManager

func NewManager() *Manager

func (*Manager) Bind

func (manager *Manager) Bind(serverCtx *context.Context, group *echo.Group)

func (*Manager) Close

func (manager *Manager) Close() error

func (*Manager) DispatchAccountUpdatedEvent

func (manager *Manager) DispatchAccountUpdatedEvent(
	userId string,
	_ bson.Raw,
	event *events.AccountUpdated,
) error

func (*Manager) DispatchAccountWitnessVotedEvent

func (manager *Manager) DispatchAccountWitnessVotedEvent(
	userId string,
	_ bson.Raw,
	event *events.AccountWitnessVoted,
) error

func (*Manager) DispatchCommentPublishedEvent

func (manager *Manager) DispatchCommentPublishedEvent(
	userId string,
	_ bson.Raw,
	event *events.CommentPublished,
) error

func (*Manager) DispatchCommentVotedEvent

func (manager *Manager) DispatchCommentVotedEvent(
	userId string,
	_ bson.Raw,
	event *events.CommentVoted,
) error

func (*Manager) DispatchStoryPublishedEvent

func (manager *Manager) DispatchStoryPublishedEvent(
	userId string,
	_ bson.Raw,
	event *events.StoryPublished,
) error

func (*Manager) DispatchStoryVotedEvent

func (manager *Manager) DispatchStoryVotedEvent(
	userId string,
	_ bson.Raw,
	event *events.StoryVoted,
) error

func (*Manager) DispatchTransferMadeEvent

func (manager *Manager) DispatchTransferMadeEvent(
	userId string,
	_ bson.Raw,
	event *events.TransferMade,
) error

func (*Manager) DispatchUserFollowStatusChangedEvent

func (manager *Manager) DispatchUserFollowStatusChangedEvent(
	userId string,
	_ bson.Raw,
	event *events.UserFollowStatusChanged,
) error

func (*Manager) DispatchUserMentionedEvent

func (manager *Manager) DispatchUserMentionedEvent(
	userId string,
	_ bson.Raw,
	event *events.UserMentioned,
) error

type StoryPublishedPayload

type StoryPublishedPayload struct {
	Author string   `json:"author"`
	Title  string   `json:"title"`
	URL    string   `json:"url"`
	Tags   []string `json:"tags"`
}

type StoryVotedPayload

type StoryVotedPayload struct {
	Voter              string `json:"voter"`
	VoteWeight         string `json:"voteWeight"`
	Author             string `json:"author"`
	Title              string `json:"title"`
	URL                string `json:"url"`
	TotalPayout        string `json:"totalPayout"`
	PendingPayout      string `json:"pendingPayout"`
	TotalPendingPayout string `json:"totalPendingPayout"`
}

type TransferMadePayload

type TransferMadePayload struct {
	From   string `json:"from"`
	To     string `json:"to"`
	Amount string `json:"amount"`
	Memo   string `json:"memo,omitempty"`
}

type UserFollowStatusChangedPayload

type UserFollowStatusChangedPayload struct {
	Follower  string `json:"follower"`
	Following string `json:"following"`
	What      string `json:"what,omitempty"`
}

type UserMentionedPayload

type UserMentionedPayload struct {
	User     string `json:"user"`
	URL      string `json:"url"`
	Author   string `json:"author"`
	Permlink string `json:"permlink"`
}