seawa

Documentation

Index

• type SeaWatcher
  • func NewSeaWatcher(apiToken string, gb *gloomberg.Gloomberg) *SeaWatcher
  • func (sw *SeaWatcher) ActiveSubscriptions() map[string]map[degendb.EventType]func()
  • func (sw *SeaWatcher) DecodeCollectionOfferEvent(itemEvent map[string]interface{}) (osmodels.CollectionOfferEvent, error)
  • func (sw *SeaWatcher) DecodeItemReceivedBidEvent(itemEvent map[string]interface{}) (osmodels.ItemReceivedBidEvent, error)
  • func (sw *SeaWatcher) EventChannel() chan map[string]interface{}
  • func (sw *SeaWatcher) IsSubscribedToAllEvents(slug string) bool
  • func (sw *SeaWatcher) Pr(message string)
  • func (sw *SeaWatcher) Prf(format string, a ...interface{})
  • func (sw *SeaWatcher) PublishSendSlugs()
  • func (sw *SeaWatcher) SubscribeForSlug(slug string, eventTypes []degendb.EventType) uint64
  • func (sw *SeaWatcher) SubscribeForSlugs(slugs []string, eventTypes mapset.Set[degendb.EventType]) uint64
  • func (sw *SeaWatcher) SubscribeToPubsubMgmt()
  • func (sw *SeaWatcher) UnubscribeForSlug(slug string, _ mapset.Set[degendb.EventType]) uint64
  • func (sw *SeaWatcher) UnubscribeForSlugs(slugs []string, _ mapset.Set[degendb.EventType]) uint64
  • func (sw *SeaWatcher) WorkerMgmtChannel()

Types

type SeaWatcher

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

func NewSeaWatcher

func NewSeaWatcher(apiToken string, gb *gloomberg.Gloomberg) *SeaWatcher

func NewSeaWatcher(apiToken string, rdb rueidis.Client) *SeaWatcher {.

func (*SeaWatcher) ActiveSubscriptions

func (sw *SeaWatcher) ActiveSubscriptions() map[string]map[degendb.EventType]func()

func (sw *SeaWatcher) ActiveSubscriptions() map[string]map[osmodels.EventType]func() {.

func (*SeaWatcher) DecodeCollectionOfferEvent

func (sw *SeaWatcher) DecodeCollectionOfferEvent(itemEvent map[string]interface{}) (osmodels.CollectionOfferEvent, error)

func (*SeaWatcher) DecodeItemReceivedBidEvent

func (sw *SeaWatcher) DecodeItemReceivedBidEvent(itemEvent map[string]interface{}) (osmodels.ItemReceivedBidEvent, error)

func (*SeaWatcher) EventChannel

func (sw *SeaWatcher) EventChannel() chan map[string]interface{}

func (*SeaWatcher) IsSubscribedToAllEvents

func (sw *SeaWatcher) IsSubscribedToAllEvents(slug string) bool

func (*SeaWatcher) Pr

func (sw *SeaWatcher) Pr(message string)

Pr prints messages from seawatcher to the terminal.

func (*SeaWatcher) Prf

func (sw *SeaWatcher) Prf(format string, a ...interface{})

Prf formats and prints messages from seawatcher to the terminal.

func (*SeaWatcher) PublishSendSlugs

func (sw *SeaWatcher) PublishSendSlugs()

func (*SeaWatcher) SubscribeForSlug

func (sw *SeaWatcher) SubscribeForSlug(slug string, eventTypes []degendb.EventType) uint64

func (*SeaWatcher) SubscribeForSlugs

func (sw *SeaWatcher) SubscribeForSlugs(slugs []string, eventTypes mapset.Set[degendb.EventType]) uint64

func (*SeaWatcher) SubscribeToPubsubMgmt

func (sw *SeaWatcher) SubscribeToPubsubMgmt()

SubscribeToPubsubMgmt starts the seawatcher by subscribing to the mgmt channel and listening for new slugs to subscribe to.

func (*SeaWatcher) UnubscribeForSlug

func (sw *SeaWatcher) UnubscribeForSlug(slug string, _ mapset.Set[degendb.EventType]) uint64

func (*SeaWatcher) UnubscribeForSlugs

func (sw *SeaWatcher) UnubscribeForSlugs(slugs []string, _ mapset.Set[degendb.EventType]) uint64

func (*SeaWatcher) WorkerMgmtChannel

func (sw *SeaWatcher) WorkerMgmtChannel()