message

type A6Conf interface {
	GetAll() *map[string]interface{}
	Inject(nodes interface{})
	Marshal() ([]byte, error)
	GetUpstream() Upstream
	HasNodesAttr() bool
}

type Message struct {
	Key     string
	Value   string
	Version int64
	Action  StoreEvent
	// contains filtered or unexported fields
}

type Node struct {
	Host     string      `json:"host,omitempty"`
	Port     int         `json:"port,omitempty"`
	Weight   int         `json:"weight"`
	Metadata interface{} `json:"metadata,omitempty"`
}

type Routes struct {
	Upstream Upstream               `json:"upstream"`
	All      map[string]interface{} `json:"-"`
	// contains filtered or unexported fields
}

type Services struct {
	Upstream Upstream               `json:"upstream"`
	All      map[string]interface{} `json:"-"`
	// contains filtered or unexported fields
}

type StoreEvent = int

type Upstream struct {
	Nodes            interface{}  `json:"nodes,omitempty"`
	DiscoveryType    string       `json:"discovery_type,omitempty"`
	DupDiscoveryType string       `json:"_discovery_type,omitempty"`
	DiscoveryArgs    *UpstreamArg `json:"discovery_args,omitempty"`
	DupServiceName   string       `json:"_service_name,omitempty"`
	ServiceName      string       `json:"service_name,omitempty"`
}

type UpstreamArg struct {
	NamespaceID string                 `json:"namespace_id,omitempty"`
	GroupName   string                 `json:"group_name,omitempty"`
	Metadata    map[string]interface{} `json:"metadata,omitempty"`
}

type Upstreams struct {
	Upstream

	All map[string]interface{} `json:"-"`
	// contains filtered or unexported fields
}