core

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

type FilterContext struct {
	Service      *nacosmodel.ServiceMetadata
	Clusters     []string
	EnableOnly   bool
	HealthyOnly  bool
	SubscriberIP string
}

type InstanceFilter func(ctx *FilterContext, svcInfo *nacosmodel.ServiceInfo,
	ins []*nacosmodel.Instance, healthyCount int32) *nacosmodel.ServiceInfo

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

type Notifier interface {
	io.Closer
	Notify(d *PushData) error
	IsZombie() bool
}

type PushCenter interface {
	// AddSubscriber
	AddSubscriber(s Subscriber)
	// RemoveSubscriber
	RemoveSubscriber(s Subscriber)
	// EnablePush
	EnablePush(s Subscriber) bool
	// Type
	Type() PushType
}

type PushData struct {
	Service          *nacosmodel.ServiceMetadata
	ServiceInfo      *nacosmodel.ServiceInfo
	UDPData          interface{}
	CompressUDPData  []byte
	GRPCData         interface{}
	CompressGRPCData []byte
}

type PushType string

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

type Subscriber struct {
	Key         string
	AddrStr     string
	Agent       string
	App         string
	Ip          string
	Port        int
	NamespaceId string
	Group       string
	Service     string
	Cluster     string
	Type        PushType
}

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