observer

Documentation

Index

• Variables
• type ChatsObserver
  • func NewObserver(logger log.Logger) ChatsObserver
• type Observer
  • func (o *Observer) Deregister(chatId, userId int64)
  • func (o *Observer) Publish(chatId int64, msg *v1.NewMessage)
  • func (o *Observer) Register(chatId, userId int64, channel chan *v1.NewMessage)

Variables

var ProviderSet = wire.NewSet(NewObserver)

ProviderSet is observer providers.

Types

type ChatsObserver

type ChatsObserver interface {
	Register(int64, int64, chan *v1.NewMessage)
	Deregister(int64, int64)
	Publish(int64, *v1.NewMessage)
}

func NewObserver

func NewObserver(logger log.Logger) ChatsObserver

type Observer

type Observer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Observer) Deregister

func (o *Observer) Deregister(chatId, userId int64)

func (*Observer) Publish

func (o *Observer) Publish(chatId int64, msg *v1.NewMessage)

func (*Observer) Register

func (o *Observer) Register(chatId, userId int64, channel chan *v1.NewMessage)