Documentation
¶
Index ¶
- Constants
- type AlertAPI
- type AlertTask
- func (a *AlertTask) Adder(taskFunc harmonytask.AddTaskFunc)
- func (a *AlertTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
- func (a *AlertTask) Do(taskID harmonytask.TaskID, stillOwned func() bool) (done bool, err error)
- func (a *AlertTask) TypeDetails() harmonytask.TaskTypeDetails
Constants ¶
View Source
const AlertMangerInterval = time.Hour
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlertAPI ¶
type AlertAPI interface {
ctladdr.NodeApi
ChainHead(context.Context) (*types.TipSet, error)
ChainGetTipSet(context.Context, types.TipSetKey) (*types.TipSet, error)
StateMinerInfo(ctx context.Context, actor address.Address, tsk types.TipSetKey) (api.MinerInfo, error)
StateMinerProvingDeadline(context.Context, address.Address, types.TipSetKey) (*dline.Info, error)
StateMinerPartitions(context.Context, address.Address, uint64, types.TipSetKey) ([]api.Partition, error)
}
type AlertTask ¶
type AlertTask struct {
// contains filtered or unexported fields
}
func NewAlertTask ¶
func (*AlertTask) Adder ¶
func (a *AlertTask) Adder(taskFunc harmonytask.AddTaskFunc)
func (*AlertTask) CanAccept ¶
func (a *AlertTask) CanAccept(ids []harmonytask.TaskID, engine *harmonytask.TaskEngine) (*harmonytask.TaskID, error)
func (*AlertTask) TypeDetails ¶
func (a *AlertTask) TypeDetails() harmonytask.TaskTypeDetails
Source Files
Click to show internal directories.
Click to hide internal directories.