seawa

Documentation

Index

• Variables
• type MgmtAction
  • func (a MgmtAction) String() string
• type MgmtEvent
• type SeaWatcher
  • func NewStreamWatcher(apiToken string, rdb *redis.Client) *SeaWatcher
  • func (sw *SeaWatcher) ActiveSubscriptions() map[osmodels.EventType]map[string]func()
  • func (sw *SeaWatcher) EventChannel() chan map[string]interface{}
  • 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.ItemSold, osmodels.ItemReceivedOffer} // ItemMetadataUpdated, ItemCancelled

)

Types

type MgmtAction

type MgmtAction int64

const (
	// client actions.
	Subscribe MgmtAction = iota
	Unsubscribe

	// SendSlugs is used to request the slugs/events to subscribe to from the clients.
	SendSlugs
)

func (MgmtAction) String

func (a MgmtAction) String() string

type MgmtEvent

type MgmtEvent struct {
	Action MgmtAction           `json:"action"`
	Events []osmodels.EventType `json:"events"`
	Slugs  []string             `json:"slugs"`
}

type SeaWatcher

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

func NewStreamWatcher

func NewStreamWatcher(apiToken string, rdb *redis.Client) *SeaWatcher

func (*SeaWatcher) ActiveSubscriptions

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

func (*SeaWatcher) EventChannel

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

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