polling

Documentation

Index

• type BackoffPolling
  • func (b *BackoffPolling) Poll(context context.Context, RId string) (<-chan interface{}, error)
  • func (b *BackoffPolling) StartJob(info api.JobInfo) error
  • func (b *BackoffPolling) TaskUpdate(info api.TaskInfo) error

Types

type BackoffPolling

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

func (*BackoffPolling) Poll

func (b *BackoffPolling) Poll(context context.Context, RId string) (<-chan interface{}, error)

func (*BackoffPolling) StartJob

func (b *BackoffPolling) StartJob(info api.JobInfo) error

func (*BackoffPolling) TaskUpdate

func (b *BackoffPolling) TaskUpdate(info api.TaskInfo) error