connection

Documentation

Index

• Variables
• func GetConnection(ctx context.Context) (*grpc.ClientConn, error)
• func LookupRegion(r string) bool
• type Stats
• type StatsHandler
  • func (h *StatsHandler) GetStats(now time.Time) (s Stats)
  • func (h *StatsHandler) HandleConn(ctx context.Context, _ stats.ConnStats)
  • func (h *StatsHandler) HandleRPC(ctx context.Context, s stats.RPCStats)
  • func (h *StatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context
  • func (h *StatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context

Variables

var (
	IDC     = atomic.Value{} //string
	Region  = atomic.Value{} //string
	NetMode = atomic.Value{} //string
)

var (
	DefaultStatsHandler = StatsHandler{
		// contains filtered or unexported fields
	}
)

Functions

func GetConnection

func GetConnection(ctx context.Context) (*grpc.ClientConn, error)

func LookupRegion

func LookupRegion(r string) bool

Types

type Stats

type Stats struct {
	RxSpeed float64
	TxSpeed float64
}

type StatsHandler

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

func (*StatsHandler) GetStats

func (h *StatsHandler) GetStats(now time.Time) (s Stats)

func (*StatsHandler) HandleConn

func (h *StatsHandler) HandleConn(ctx context.Context, _ stats.ConnStats)

func (*StatsHandler) HandleRPC

func (h *StatsHandler) HandleRPC(ctx context.Context, s stats.RPCStats)

func (*StatsHandler) TagConn

func (h *StatsHandler) TagConn(ctx context.Context, _ *stats.ConnTagInfo) context.Context

func (*StatsHandler) TagRPC

func (h *StatsHandler) TagRPC(ctx context.Context, info *stats.RPCTagInfo) context.Context