bus

package

v0.0.0-...-fe78ce7 Latest Latest Go to latest Published: Jan 17, 2022 License: MIT Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/13k/night-stalker

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Bus
- func New(options Options) *Bus
type DotaSessionChangeMessage
type ErrPublishTimeout
- func (*ErrPublishTimeout) Error() string
type ErrSubscriptionExpired
- func (*ErrSubscriptionExpired) Error() string
type GCDispatcherReceivedMessage
type GCDispatcherSendMessage
type LiveMatchStatsChangeMessage
type LiveMatchesChangeMessage
type Message
type Options
type SteamEventMessage
type SteamSessionChangeMessage
type Subscription

Constants ¶

View Source

const (
	TopicSteamEvents                                      = "steam.events"
	TopicSession                                          = "session"
	TopicSessionSteam                                     = "session.steam"
	TopicSessionDota                                      = "session.dota"
	TopicLiveMatchesReplace                               = "live_matches.replace"
	TopicLiveMatchesAdd                                   = "live_matches.add"
	TopicLiveMatchesUpdate                                = "live_matches.update"
	TopicLiveMatchesRemove                                = "live_matches.remove"
	TopicPatternLiveMatchesAll                            = "live_matches.*"
	TopicLiveMatchStatsAdd                                = "live_match_stats.add"
	TopicPatternLiveMatchStatsAll                         = "live_match_stats.*"
	TopicGCDispatcherSend                                 = "gc.dispatcher.send"
	TopicGCDispatcherReceivedMatchesMinimalResponse       = "gc.dispatcher.received.matches_minimal_response"
	TopicGCDispatcherReceivedFindTopSourceTVGamesResponse = "gc.dispatcher.received.find_top_source_tv_games_response"
	TopicWebLiveMatchesReplace                            = "web.live_matches.replace"
	TopicWebLiveMatchesAdd                                = "web.live_matches.add"
	TopicWebLiveMatchesUpdate                             = "web.live_matches.update"
	TopicWebLiveMatchesRemove                             = "web.live_matches.remove"
	TopicWebPatternLiveMatchesAll                         = "web.live_matches.*"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Bus ¶

type Bus struct {
	*emitter.Emitter
	// contains filtered or unexported fields
}

func New ¶

func New(options Options) *Bus

func (*Bus) Pub ¶

func (b *Bus) Pub(message Message) error

func (*Bus) PubSync ¶

func (b *Bus) PubSync(message Message)

func (*Bus) Shutdown ¶

func (b *Bus) Shutdown()

func (*Bus) Sub ¶

func (b *Bus) Sub(topic string) *Subscription

func (*Bus) Unsub ¶

func (b *Bus) Unsub(subs ...*Subscription)

type DotaSessionChangeMessage ¶

type DotaSessionChangeMessage struct {
	*nsdota2.StateTransition

	IsReady bool
	Err     error
}

type ErrPublishTimeout ¶

type ErrPublishTimeout struct {
	Message Message
	Timeout time.Duration
}

func (*ErrPublishTimeout) Error ¶

func (*ErrPublishTimeout) Error() string

type ErrSubscriptionExpired ¶

type ErrSubscriptionExpired struct {
	Subscription *Subscription
}

func (*ErrSubscriptionExpired) Error ¶

func (*ErrSubscriptionExpired) Error() string

type GCDispatcherReceivedMessage ¶

type GCDispatcherReceivedMessage struct {
	MsgType d2pb.EDOTAGCMsg
	Message proto.Message
}

type GCDispatcherSendMessage ¶

type GCDispatcherSendMessage struct {
	MsgType d2pb.EDOTAGCMsg
	Message proto.Message
}

type LiveMatchStatsChangeMessage ¶

type LiveMatchStatsChangeMessage struct {
	Op    nspb.CollectionOp
	Stats nscol.LiveMatchStats
}

type LiveMatchesChangeMessage ¶

type LiveMatchesChangeMessage struct {
	Op       nspb.CollectionOp
	Matches  nscol.LiveMatches
	MatchIDs nscol.MatchIDs
}

type Message ¶

type Message struct {
	Topic   string
	Pattern string
	Payload interface{}
}

type Options ¶

type Options struct {
	Cap        uint
	Log        *nslog.Logger
	PubTimeout time.Duration
}

type SteamEventMessage ¶

type SteamEventMessage struct {
	Event interface{}
}

type SteamSessionChangeMessage ¶

type SteamSessionChangeMessage struct {
	*nssteam.StateTransition

	IsReady bool
	Err     error
}

type Subscription ¶

type Subscription struct {
	Topic string
	C     <-chan Message
	// contains filtered or unexported fields
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
subscribers

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL