events

Documentation

Index

• func AsStreamWriter(id int, receiver chan *Message) fasthttp.StreamWriter
• func CloseReceiver(id int)
• func NewReceiver(topics ...Topic) (int, chan *Message)
• func SendEvent(topic Topic, data any)
• type ElectionEndedData
• type Message
  • func (m *Message) ToSSE() ([]byte, error)
• type Topic
• type UserDeletedData
• type UserElectionStandData
• type UserElectionWithdrawData
• type UserRestrictedData

Functions

func AsStreamWriter

func AsStreamWriter(id int, receiver chan *Message) fasthttp.StreamWriter

func CloseReceiver

func CloseReceiver(id int)

func NewReceiver

func NewReceiver(topics ...Topic) (int, chan *Message)

func SendEvent

func SendEvent(topic Topic, data any)

Types

type ElectionEndedData

type ElectionEndedData struct {
	Election *database.Election `json:"election"`
	Result   string             `json:"result,omitempty"`
}

type Message

type Message struct {
	Topic Topic
	Data  any
}

func (*Message) ToSSE

func (m *Message) ToSSE() ([]byte, error)

type Topic

type Topic string

const (
	TopicElectionStarted Topic = "election-start"
	TopicElectionEnded   Topic = "election-end"
	TopicVoteReceived    Topic = "vote-received"

	TopicUserElectionStand    Topic = "user-stand"
	TopicUserElectionWithdraw Topic = "user-withdraw"
	TopicUserRestricted       Topic = "user-restrict"
	TopicUserDeleted          Topic = "user-delete"
)

type UserDeletedData

type UserDeletedData struct {
	UserID       string `json:"user"`
	ActingUserID string `json:"actingUserID"`
}

type UserElectionStandData

type UserElectionStandData struct {
	User     *database.User     `json:"user"`
	Election *database.Election `json:"election"`
}

type UserElectionWithdrawData

type UserElectionWithdrawData struct {
	User         *database.User     `json:"user"`
	Election     *database.Election `json:"election"`
	ActingUserID string             `json:"actingUserID,omitempty"`
}

type UserRestrictedData

type UserRestrictedData struct {
	User         *database.User `json:"user"`
	ActingUserID string         `json:"actingUserID"`
}