rmanager

Documentation

Index

• type RequestManager
  • func GetRequestManager() *RequestManager
  • func (rm *RequestManager) AddRequest(r request.RemoteData) (<-chan interface{}, <-chan error)
  • func (rm *RequestManager) StartService()

Types

type RequestManager

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

RequestManager - Struct dedicated to managing a request queue, channel "next" is used to make the worker understand that he is ready to make a new request,

func GetRequestManager

func GetRequestManager() *RequestManager

GetRequestManager - Returns the once instance of RequestManager

func (*RequestManager) AddRequest

func (rm *RequestManager) AddRequest(r request.RemoteData) (<-chan interface{}, <-chan error)

AddRequest - Appends a request to the queue, if the worker is not running starts it and return the two channels of requestContainer to read the result or error

func (*RequestManager) StartService

func (rm *RequestManager) StartService()

StartService - Starts the worker