d2

Documentation

Index

• Variables
• func ClustersPath(cluster string) string
• func EnableD2Logging()
• func ServicesPath(service string) string
• func UrisPath(uri string) string
• type ChildUpdateCallback
• type ChildWatcher
  • func NewChildWatcher(conn *zk.Conn, root string, callback ChildUpdateCallback) (*ChildWatcher, error)
  • func (w *ChildWatcher) ChildPath(child string) string
• type Cluster
• type FixedClient
  • func NewFixedClient(name string, conn *zk.Conn) (c *FixedClient, err error)
  • func (c *FixedClient) GetHostnameForQuery(query string) (*url.URL, error)
• type OnceWg
  • func (w *OnceWg) Done()
  • func (w *OnceWg) Wait()
• type Service
• type Uri
  • func (u *Uri) UnmarshalJSON(data []byte) error
• type UriProperty

Variables

var Logger = log.New(ioutil.Discard, "[D2] ", log.Ldate|log.Ltime|log.Lmicroseconds|log.Lshortfile|log.LUTC)

Functions

func ClustersPath

func ClustersPath(cluster string) string

func EnableD2Logging

func EnableD2Logging()

func ServicesPath

func ServicesPath(service string) string

func UrisPath

func UrisPath(uri string) string

Types

type ChildUpdateCallback

type ChildUpdateCallback func(child string, data []byte, err error)

type ChildWatcher

type ChildWatcher struct {
	*zk.Conn
	Root string
	// contains filtered or unexported fields
}

func NewChildWatcher

func NewChildWatcher(conn *zk.Conn, root string, callback ChildUpdateCallback) (*ChildWatcher, error)

func (*ChildWatcher) ChildPath

func (w *ChildWatcher) ChildPath(child string) string

type Cluster

type Cluster struct {
	ClusterName         string `json:"clusterName"`
	PartitionProperties struct {
		HashAlgorithm     string `json:"hashAlgorithm"`
		PartitionCount    int    `json:"partitionCount"`
		PartitionKeyRegex string `json:"partitionKeyRegex"`
		PartitionType     string `json:"partitionType"`
	} `json:"partitionProperties"`
}

type FixedClient

type FixedClient struct {
	*zk.Conn
	// contains filtered or unexported fields
}

func NewFixedClient

func NewFixedClient(name string, conn *zk.Conn) (c *FixedClient, err error)

func (*FixedClient) GetHostnameForQuery

func (c *FixedClient) GetHostnameForQuery(query string) (*url.URL, error)

type OnceWg

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

func (*OnceWg) Done

func (w *OnceWg) Done()

func (*OnceWg) Wait

func (w *OnceWg) Wait()

type Service

type Service struct {
	Path        string
	ServiceName string `json:"serviceName"`
	ClusterName string `json:"clusterName"`
}

type Uri

type Uri struct {
	Weights       map[url.URL]float64
	ClusterName   string
	Properties    map[url.URL]UriProperty
	PartitionDesc map[url.URL]map[int]float64
}

func (*Uri) UnmarshalJSON

func (u *Uri) UnmarshalJSON(data []byte) error

type UriProperty

type UriProperty struct {
	AppName    string `json:"com.linkedin.app.name"`
	AppVersion string `json:"com.linkedin.app.version"`
}