helper

Documentation

Index

• func ClosePool()
• func Init(BlockChainMonitorUrl []string, MaxConnectionNum, InitConnectionNum int)
• type Client
  • func GetClient() *Client
  • func (c *Client) HeartBeat() error
  • func (c *Client) Release()
• type EndPoint
• type PoolFactory
  • func (f *PoolFactory) ActivateObject(ctx context.Context, object *commonPool.PooledObject) error
  • func (f *PoolFactory) DestroyObject(ctx context.Context, object *commonPool.PooledObject) error
  • func (f *PoolFactory) GetEndPoint() EndPoint
  • func (f *PoolFactory) MakeObject(ctx context.Context) (*commonPool.PooledObject, error)
  • func (f *PoolFactory) PassivateObject(ctx context.Context, object *commonPool.PooledObject) error
  • func (f *PoolFactory) ValidateObject(ctx context.Context, object *commonPool.PooledObject) bool

Functions

func ClosePool

func ClosePool()

func Init

func Init(BlockChainMonitorUrl []string, MaxConnectionNum, InitConnectionNum int)

Types

type Client

type Client struct {
	Id string
	rpcClient.Client
}

func GetClient

func GetClient() *Client

get client from pool

func (*Client) HeartBeat

func (c *Client) HeartBeat() error

func (*Client) Release

func (c *Client) Release()

release client

type EndPoint

type EndPoint struct {
	Address   string
	Available bool
}

type PoolFactory

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

func (*PoolFactory) ActivateObject

func (f *PoolFactory) ActivateObject(ctx context.Context, object *commonPool.PooledObject) error

func (*PoolFactory) DestroyObject

func (f *PoolFactory) DestroyObject(ctx context.Context, object *commonPool.PooledObject) error

func (*PoolFactory) GetEndPoint

func (f *PoolFactory) GetEndPoint() EndPoint

func (*PoolFactory) MakeObject

func (f *PoolFactory) MakeObject(ctx context.Context) (*commonPool.PooledObject, error)

func (*PoolFactory) PassivateObject

func (f *PoolFactory) PassivateObject(ctx context.Context, object *commonPool.PooledObject) error

func (*PoolFactory) ValidateObject

func (f *PoolFactory) ValidateObject(ctx context.Context, object *commonPool.PooledObject) bool