seawa

Documentation

Index

• Variables
• type SeaWatcher
  • func NewSeaWatcher(apiToken string, gb *gloomberg.Gloomberg) *SeaWatcher
  • func (sw *SeaWatcher) ActiveSubscriptions() map[osmodels.EventType]map[string]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) PublishSendSlugs()
  • func (sw *SeaWatcher) Run()
  • func (sw *SeaWatcher) SubscribeForSlug(eventType osmodels.EventType, slug string) bool
  • func (sw *SeaWatcher) UnubscribeForSlug(eventType osmodels.EventType, slug string) bool

Variables

var (
	AvailableEventTypes = []osmodels.EventType{osmodels.ItemListed, osmodels.ItemReceivedBid, osmodels.ItemMetadataUpdated} // , osmodels.CollectionOffer} //, osmodels.ItemMetadataUpdated} // ItemMetadataUpdated, ItemCancelled

)

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[osmodels.EventType]map[string]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) PublishSendSlugs

func (sw *SeaWatcher) PublishSendSlugs()

func (*SeaWatcher) Run

func (sw *SeaWatcher) Run()

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

func (*SeaWatcher) SubscribeForSlug

func (sw *SeaWatcher) SubscribeForSlug(eventType osmodels.EventType, slug string) bool

func (*SeaWatcher) UnubscribeForSlug

func (sw *SeaWatcher) UnubscribeForSlug(eventType osmodels.EventType, slug string) bool