util

package

v0.0.0-...-9789875 Latest Latest Go to latest Published: Mar 10, 2021 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/andrewlee302/distributed-system

Links

Open Source Insights

Documentation ¶

Overview ¶

Package util provides basic utilities.

Index ¶

Variables
func Call(network, srv, name string, args interface{}, reply interface{}) bool
func DialServer(network, addr string) *rpc.Client
func RPCCall(c *rpc.Client, name string, args interface{}, reply interface{}) bool
func RPCPoolArrayCall(pa *ResourcePoolsArray, i int, name string, args interface{}, ...) bool
func RPCPoolCall(pool *ResourcePool, name string, args interface{}, reply interface{}) bool
type Cfg
- func ParseCfg(f string) *Cfg
type Resource
type ResourcePool
- func NewResourcePool(new func() Resource, maxSize int) *ResourcePool
type ResourcePoolsArray
- func NewResourcePoolsArray(news []func() Resource, maxSizeForOne, poolNum int) *ResourcePoolsArray
type ResourcePoolsMap
- func NewResourcePoolsMap(new func(id string) func() Resource, maxSizeForOne int) *ResourcePoolsMap

Constants ¶

This section is empty.

Variables ¶

View Source

var RPCCallNs int64 = 0

debug

Functions ¶

func Call ¶

func Call(network, srv, name string, args interface{}, reply interface{}) bool

Call is the one-time RPC communication utility. No matter successfully or not, the channel will be closed.

func DialServer ¶

func DialServer(network, addr string) *rpc.Client

func RPCCall ¶

func RPCCall(c *rpc.Client, name string, args interface{}, reply interface{}) bool

RPCCall is the RPC utility for reusing. Note that if successfully, the channel won't be closed.

func RPCPoolArrayCall ¶

func RPCPoolArrayCall(pa *ResourcePoolsArray, i int, name string, args interface{}, reply interface{}) bool

func RPCPoolCall ¶

func RPCPoolCall(pool *ResourcePool, name string, args interface{}, reply interface{}) bool

Types ¶

type Cfg ¶

type Cfg struct {
	Protocol        string
	APPAddrs        []string
	CoordinatorAddr string
	KVStoreAddrs    []string
	ItemCSV         string
	UserCSV         string
	TimeoutMS       int64
}

func ParseCfg ¶

func ParseCfg(f string) *Cfg

type Resource ¶

type Resource interface {
	Close() error
}

type ResourcePool ¶

type ResourcePool struct {
	New func() Resource
	// contains filtered or unexported fields
}

func NewResourcePool ¶

func NewResourcePool(new func() Resource, maxSize int) *ResourcePool

func (*ResourcePool) Clean ¶

func (pool *ResourcePool) Clean(r Resource)

Close one resource in the pool and the active resource size decreases.

func (*ResourcePool) Get ¶

func (pool *ResourcePool) Get() Resource

Get a resource from the pool.

func (*ResourcePool) Put ¶

func (pool *ResourcePool) Put(r Resource)

Put back the available resource into the pool for the future use.

type ResourcePoolsArray ¶

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

func NewResourcePoolsArray ¶

func NewResourcePoolsArray(news []func() Resource, maxSizeForOne, poolNum int) *ResourcePoolsArray

func (ResourcePoolsArray) Clean ¶

func (array ResourcePoolsArray) Clean(i int, r Resource)

func (ResourcePoolsArray) Get ¶

func (array ResourcePoolsArray) Get(i int) Resource

func (ResourcePoolsArray) Put ¶

func (array ResourcePoolsArray) Put(i int, r Resource)

type ResourcePoolsMap ¶

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

func NewResourcePoolsMap ¶

func NewResourcePoolsMap(new func(id string) func() Resource, maxSizeForOne int) *ResourcePoolsMap

func (ResourcePoolsMap) Clean ¶

func (pm ResourcePoolsMap) Clean(id string, r Resource)

func (ResourcePoolsMap) Get ¶

func (pm ResourcePoolsMap) Get(id string) Resource

func (ResourcePoolsMap) Put ¶

func (pm ResourcePoolsMap) Put(id string, r Resource)

Source Files ¶

View all Source files

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