keeper

package

v0.2.0 Latest Latest Go to latest Published: Jan 25, 2022 License: MIT Imports: 9 Imported by: 0

Details

MIT License

This section is empty.

This section is empty.

This section is empty.

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

func New(ctx context.Context, url string, logger logging.Logger) *Keeper

func (k *Keeper) GetTaskInfo(batchId string) (map[string]interface{}, error)

func (k *Keeper) List() []interface{}

func (k *Keeper) Stop()

func (k *Keeper) Unwatch(batchId string) error

func (k *Keeper) Watch(name, batchId, balanceEndpoint, minBalance, topupBalance, interval string, cb func(action *topup.TopupAction) error) error