Documentation ¶
Index ¶
- func NewMessage(ctx context.Context, rpc string, data interface{}) (*protocol.Message, error)
- type Config
- type EngagementUpdate
- type FanOut
- type NatsMessage
- type Pusher
- func (p *Pusher) DeleteCard(ctx context.Context, session *model.Session, id globalid.ID) error
- func (p *Pusher) NewCard(ctx context.Context, session *model.Session, card *model.CardResponse) error
- func (p *Pusher) NewNotification(ctx context.Context, session *model.Session, notif *model.ExportedNotification) error
- func (p *Pusher) UpdateCard(ctx context.Context, session *model.Session, card *model.CardResponse) error
- func (p *Pusher) UpdateCoinBalance(ctx context.Context, userID globalid.ID, newBalances *model.CoinBalances) error
- func (p *Pusher) UpdateEngagement(ctx context.Context, session *model.Session, cardID globalid.ID) error
- func (p *Pusher) UpdateNotification(ctx context.Context, session *model.Session, notif *model.ExportedNotification) error
- func (p *Pusher) UpdateUser(ctx context.Context, session *model.Session, user *model.ExportedUser) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type EngagementUpdate ¶
type EngagementUpdate struct { CardID globalid.ID `json:"cardID"` Engagement *model.Engagement `json:"engagement"` }
type FanOut ¶
type FanOut struct {
// contains filtered or unexported fields
}
func (*FanOut) ListenToAll ¶
func (*FanOut) ListenToUserMessage ¶
func (fa *FanOut) ListenToUserMessage(m *NatsMessage)
type NatsMessage ¶
type Pusher ¶
type Pusher struct {
// contains filtered or unexported fields
}
func (*Pusher) DeleteCard ¶
func (*Pusher) NewNotification ¶
func (*Pusher) UpdateCard ¶
func (*Pusher) UpdateCoinBalance ¶
func (*Pusher) UpdateEngagement ¶
func (*Pusher) UpdateNotification ¶
func (*Pusher) UpdateUser ¶
Click to show internal directories.
Click to hide internal directories.