monitor

Documentation

Index

• type Monitor
  • func NewMonitor(req *NewMonitorReq) Monitor
• type NewMonitorReq

Types

type Monitor

type Monitor interface {
	CheckLatency(ctx context.Context) (time.Duration, error)
}

func NewMonitor

func NewMonitor(req *NewMonitorReq) Monitor

type NewMonitorReq

type NewMonitorReq struct {
	Client            pulsar.Client
	LocalClusterName  string
	RemoteClusterName string
	TopicURL          *url.URL
	NumberOfMessages  int
	Prefix            string
	PayloadsSizes     []string
}