pulsar

Documentation

Index

• Constants
• type PulsarConfig
  • func (pc PulsarConfig) BuildClient() (pulsar.Client, error)
• type Topic
  • func (t Topic) BuildTopic() string

Constants

const (
	PublicTenant          = "public"
	GexNamespace          = "trade"
	MatchSourceTopic      = "match_source"
	MatchResultTopic      = "match_result"
	MatchResultAccountSub = "MatchResultAccountSub"
	MatchSourceSub        = "match_source_sub"
	MatchResultOrderSub   = "MatchResultOrderSub"
	MatchResultKlineSub   = "MatchResultKlineSub"
	MatchResultTickerSub  = "MatchResultTickerSub"
	MatchResultMatchSub   = "MatchResultMatchSub"
)

Types

type PulsarConfig

type PulsarConfig struct {
	Hosts []string `json:"hosts" yaml:"Hosts"`
}

func (PulsarConfig) BuildClient

func (pc PulsarConfig) BuildClient() (pulsar.Client, error)

type Topic

type Topic struct {
	Tenant    string
	Namespace string
	Topic     string
}

func (Topic) BuildTopic

func (t Topic) BuildTopic() string