atcclient

package

v0.4.1 Latest Latest Go to latest Published: May 13, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Details

View Source

const (
	RetryInterval = 30 * time.Second
	LoadInterval  = 30 * time.Second
)

This section is empty.

func AddLoad(value float32)

func SubLoad(value float32)

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

func New(cc *grpc.ClientConn, tlsConfig *tls.Config) (*ATCClient, error)

func (c *ATCClient) ClientAssign(ctx context.Context, req *roxypb.ClientAssignRequest) (chan []*roxypb.Event, chan error, error)

func (c *ATCClient) Close() error

func (c *ATCClient) Dial(ctx context.Context, addr *net.TCPAddr) (*grpc.ClientConn, roxypb.AirTrafficControlClient, error)

func (c *ATCClient) Find(ctx context.Context, serviceName string, shardID uint32, useCache bool) (*net.TCPAddr, error)

func (c *ATCClient) Lookup(ctx context.Context, serviceName string) (*roxypb.LookupResponse, error)

func (c *ATCClient) ServerAnnounce(ctx context.Context, req *roxypb.ServerAnnounceRequest, loadFn LoadFunc) (context.CancelFunc, chan error, error)

type LoadFunc func() float32

var DefaultLoadFunc LoadFunc = defaultLoadFunc