backend_pool

package
Version: v0.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2018 License: Apache-2.0, Apache-2.0 Imports: 8 Imported by: 76

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SafeRpcConnPools

type SafeRpcConnPools struct {
	sync.RWMutex
	M           map[string]*connp.ConnPool
	MaxConns    int
	MaxIdle     int
	ConnTimeout int
	CallTimeout int
}

ConnPools Manager

func CreateSafeJsonrpcConnPools

func CreateSafeJsonrpcConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *SafeRpcConnPools

func CreateSafeRpcConnPools

func CreateSafeRpcConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *SafeRpcConnPools

func (*SafeRpcConnPools) Call

func (this *SafeRpcConnPools) Call(addr, method string, args interface{}, resp interface{}) error

同步发送, 完成发送或超时后 才能返回

func (*SafeRpcConnPools) Destroy

func (this *SafeRpcConnPools) Destroy()

func (*SafeRpcConnPools) Get

func (this *SafeRpcConnPools) Get(address string) (*connp.ConnPool, bool)

func (*SafeRpcConnPools) Proc

func (this *SafeRpcConnPools) Proc() []string

type TsdbClient

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

TSDB

func (TsdbClient) Close

func (t TsdbClient) Close() error

func (TsdbClient) Closed

func (t TsdbClient) Closed() bool

func (TsdbClient) Name

func (t TsdbClient) Name() string

type TsdbConnPoolHelper

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

func NewTsdbConnPoolHelper

func NewTsdbConnPoolHelper(address string, maxConns, maxIdle, connTimeout, callTimeout int) *TsdbConnPoolHelper

func (*TsdbConnPoolHelper) Destroy

func (t *TsdbConnPoolHelper) Destroy()

func (*TsdbConnPoolHelper) Send

func (t *TsdbConnPoolHelper) Send(data []byte) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL