client_conn

Documentation

Index

• Constants
• Variables
• func Blue(msg string) string
• func Green(msg string) string
• func RPCClientDialOptionAppend(opts []grpc.DialOption)
• func Red(msg string) string
• func Yellow(msg string) string
• type ConnClient
  • func NewConnClient(serviceName string) (*ConnClient, error)
  • func (c *ConnClient) GetConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (c *ConnClient) GetEndpoints(ctx context.Context) (endpoints []string, err error)

Constants

const (
	FormatRed    = "\033[31m%s\033[0m"
	FormatGreen  = "\033[32m%s\033[0m"
	FormatYellow = "\033[33m%s\033[0m"
	FormatBlue   = "\033[34m%s\033[0m"
)

const Name = "kelvins-balancer"

Variables

var (
	Debug bool
)

Functions

func Blue

func Blue(msg string) string

func Green

func Green(msg string) string

func RPCClientDialOptionAppend

func RPCClientDialOptionAppend(opts []grpc.DialOption)

RPCClientDialOptionAppend only executed at boot load, so no locks are used

func Red

func Red(msg string) string

func Yellow

func Yellow(msg string) string

Types

type ConnClient

type ConnClient struct {
	ServerName string
}

func NewConnClient

func NewConnClient(serviceName string) (*ConnClient, error)

func (*ConnClient) GetConn

func (c *ConnClient) GetConn(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

GetConn return a valid connection as much as possible

func (*ConnClient) GetEndpoints

func (c *ConnClient) GetEndpoints(ctx context.Context) (endpoints []string, err error)

GetEndpoints the returned endpoint list may have invalid nodes