relay

Documentation

Index

• type Client
• type Dispatcher
  • func NewDispatcher() *Dispatcher
  • func (d *Dispatcher) Dispatch(user string, payload []byte)
  • func (d *Dispatcher) Register(user string, client Client) *User
  • func (d *Dispatcher) Run()
• type NotificationTask
  • func NewNotificationTask(id uint64, user string, payload []byte) *NotificationTask
• type User
  • func NewUser(name string) *User
  • func (u *User) Ack(id uint64)
  • func (u *User) Dispatch(payload json.RawMessage) error
  • func (u *User) Join(client Client)
  • func (u *User) Leave(client Client)
  • func (u *User) Run()

Types

type Client

type Client interface {
	String() string

	Hello()

	TrySend(msg *NotificationTask) bool

	Disconnect()
}

type Dispatcher

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

func NewDispatcher

func NewDispatcher() *Dispatcher

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(user string, payload []byte)

func (*Dispatcher) Register

func (d *Dispatcher) Register(user string, client Client) *User

func (*Dispatcher) Run

func (d *Dispatcher) Run()

type NotificationTask

type NotificationTask struct {
	Id      uint64
	User    string
	Sent    *time.Time
	Payload []byte
}

func NewNotificationTask

func NewNotificationTask(id uint64, user string, payload []byte) *NotificationTask

type User

type User struct {
	Name string
	// contains filtered or unexported fields
}

func NewUser

func NewUser(name string) *User

func (*User) Ack

func (u *User) Ack(id uint64)

func (*User) Dispatch

func (u *User) Dispatch(payload json.RawMessage) error

func (*User) Join

func (u *User) Join(client Client)

func (*User) Leave

func (u *User) Leave(client Client)

func (*User) Run

func (u *User) Run()