client

type Action struct {
	Partition    bool
	PartitionKey int
	Do           func(ctx context.Context, resource *Resource) error
	Recover      func(ctx context.Context, resource *Resource, err error) (wait time.Duration, ok bool)
	HandleFail   func(ctx context.Context, err error)
	MaxTimeOut   time.Duration // zero is useless
	MinTimeOut   time.Duration // zero is useless
}

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

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

type ExecuteResult struct {
	Try     int
	Recover int
	Err     error
}

type Refresher func(last interface{}) (new interface{}, err error)

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

type ResourcePool interface {
	Get(ctx context.Context, partition bool, partitionKey int) (*Resource, error)
}