kateway

Documentation

Index

• type WatchAppError
  • func (this *WatchAppError) Init(ctx monitor.Context)
  • func (this *WatchAppError) Run()
• type WatchKateway
  • func (this *WatchKateway) Init(ctx monitor.Context)
  • func (this *WatchKateway) Run()
• type WatchPubsub
  • func (this *WatchPubsub) Init(ctx monitor.Context)
  • func (this *WatchPubsub) Run()
• type WatchSub
  • func (this *WatchSub) Init(ctx monitor.Context)
  • func (this *WatchSub) Run()
• type WatchTopics
  • func (this *WatchTopics) Init(ctx monitor.Context)
  • func (this *WatchTopics) Run()

Types

type WatchAppError

type WatchAppError struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Wg     *sync.WaitGroup
}

WatchAppError monitors app err log to find all pubsub related err.

func (*WatchAppError) Init

func (this *WatchAppError) Init(ctx monitor.Context)

func (*WatchAppError) Run

func (this *WatchAppError) Run()

type WatchKateway

type WatchKateway struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
}

WatchKateway monitors aliveness of kateway cluster.

func (*WatchKateway) Init

func (this *WatchKateway) Init(ctx monitor.Context)

func (*WatchKateway) Run

func (this *WatchKateway) Run()

type WatchPubsub

type WatchPubsub struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

WatchPubsub monitors aliveness of kateway cluster.

func (*WatchPubsub) Init

func (this *WatchPubsub) Init(ctx monitor.Context)

func (*WatchPubsub) Run

func (this *WatchPubsub) Run()

type WatchSub

type WatchSub struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
	// contains filtered or unexported fields
}

WatchSub monitors Sub status of kateway cluster.

func (*WatchSub) Init

func (this *WatchSub) Init(ctx monitor.Context)

func (*WatchSub) Run

func (this *WatchSub) Run()

type WatchTopics

type WatchTopics struct {
	Zkzone *zk.ZkZone
	Stop   <-chan struct{}
	Tick   time.Duration
	Wg     *sync.WaitGroup
}

WatchTopics monitors count of PubSub topics.

func (*WatchTopics) Init

func (this *WatchTopics) Init(ctx monitor.Context)

func (*WatchTopics) Run

func (this *WatchTopics) Run()