pubsub

Documentation

Index

• type BaseSubscriber
  • func (bs *BaseSubscriber) GetKey() Key
  • func (bs *BaseSubscriber) OnSubscribe(key Key)
• type IBaseSubscriber
• type IPublisher
• type ISubscriber
• type Key
• type KeyData
• type Publisher
  • func (pub *Publisher) Publish(topic TopicType, ctx ...any)
  • func (pub *Publisher) Subscribe(topic TopicType, sub ISubscriber) bool
  • func (pub *Publisher) UnSubscribe(topic TopicType)
  • func (pub *Publisher) UnSubscribeKey(key Key)
• type SubscriberSet
• type TopicSet
• type TopicType

Types

type BaseSubscriber

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

func (*BaseSubscriber) GetKey

func (bs *BaseSubscriber) GetKey() Key

func (*BaseSubscriber) OnSubscribe

func (bs *BaseSubscriber) OnSubscribe(key Key)

type IBaseSubscriber

type IBaseSubscriber interface {
	OnSubscribe(key Key)
	GetKey() Key
}

type IPublisher

type IPublisher interface {
	Publish(topic TopicType, ctx ...any)
	Subscribe(topic TopicType, sub ISubscriber)
	UnSubscribe(topic TopicType)
	UnSubscribeKey(key Key)
}

type ISubscriber

type ISubscriber interface {
	IBaseSubscriber
	OnEvent(ctx ...any)
}

type Key

type Key uint64

type KeyData

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

type Publisher

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

func (*Publisher) Publish

func (pub *Publisher) Publish(topic TopicType, ctx ...any)

func (*Publisher) Subscribe

func (pub *Publisher) Subscribe(topic TopicType, sub ISubscriber) bool

func (*Publisher) UnSubscribe

func (pub *Publisher) UnSubscribe(topic TopicType)

func (*Publisher) UnSubscribeKey

func (pub *Publisher) UnSubscribeKey(key Key)

type SubscriberSet

type SubscriberSet map[Key]KeyData

type TopicSet

type TopicSet map[TopicType]*list.List

type TopicType

type TopicType int