callregistry

Documentation

Index

• type CallSummary
• type ObjectCallResults
• type ObjectsResultCallRegistry
  • func NewObjectRequestTable() ObjectsResultCallRegistry
  • func (ort ObjectsResultCallRegistry) AddObjectCallResult(objectRef reference.Global, reqRef reference.Global, result *rms.VCallResult)
  • func (ort ObjectsResultCallRegistry) AddObjectCallResults(objectRef reference.Global, callResults ObjectCallResults) bool
  • func (ort ObjectsResultCallRegistry) GetObjectCallResults(objectRef reference.Global) (ObjectCallResults, bool)
• type PendingList
  • func (rl *PendingList) Add(ref reference.Global) bool
  • func (rl *PendingList) Count() int
  • func (rl *PendingList) CountActive() int
  • func (rl *PendingList) CountFinish() int
  • func (rl *PendingList) EarliestPulse() pulse.Number
  • func (rl *PendingList) Exist(ref reference.Global) bool
  • func (rl *PendingList) Finish(ref reference.Global) bool
  • func (rl PendingList) GetState(ref reference.Global) (bool, bool)
• type PendingTable
  • func NewRequestTable() PendingTable
  • func (rt PendingTable) GetList(flag isolation.InterferenceFlag) *PendingList
  • func (rt PendingTable) Len() int
• type WorkingList
  • func (rl *WorkingList) Count() int
  • func (rl *WorkingList) CountActive() int
  • func (rl *WorkingList) CountFinish() int
  • func (rl *WorkingList) EarliestPulse() pulse.Number
  • func (rl *WorkingList) GetState(ref reference.Global) WorkingRequestState
• type WorkingRequestState
• type WorkingTable
  • func NewWorkingTable() WorkingTable
  • func (wt WorkingTable) Add(flag isolation.InterferenceFlag, ref reference.Global) bool
  • func (wt WorkingTable) Finish(flag isolation.InterferenceFlag, ref reference.Global, result *rms.VCallResult) bool
  • func (wt WorkingTable) GetList(flag isolation.InterferenceFlag) *WorkingList
  • func (wt WorkingTable) GetResults() map[reference.Global]CallSummary
  • func (wt *WorkingTable) Len() int
  • func (wt WorkingTable) SetActive(flag isolation.InterferenceFlag, ref reference.Global) bool

Types

type CallSummary

type CallSummary struct {
	Result *rms.VCallResult
}

type ObjectCallResults

type ObjectCallResults struct {
	CallResults map[reference.Global]CallSummary
}

type ObjectsResultCallRegistry

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

ObjectsResultCallRegistry is used for store results for all processed requests per object by object reference.

func NewObjectRequestTable

func NewObjectRequestTable() ObjectsResultCallRegistry

func (ObjectsResultCallRegistry) AddObjectCallResult

func (ort ObjectsResultCallRegistry) AddObjectCallResult(objectRef reference.Global, reqRef reference.Global, result *rms.VCallResult)

func (ObjectsResultCallRegistry) AddObjectCallResults

func (ort ObjectsResultCallRegistry) AddObjectCallResults(objectRef reference.Global, callResults ObjectCallResults) bool

func (ObjectsResultCallRegistry) GetObjectCallResults

func (ort ObjectsResultCallRegistry) GetObjectCallResults(objectRef reference.Global) (ObjectCallResults, bool)

type PendingList

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

func (*PendingList) Add

func (rl *PendingList) Add(ref reference.Global) bool

Add adds reference.Global and update EarliestPulse if needed returns true if added and false if already exists

func (*PendingList) Count

func (rl *PendingList) Count() int

func (*PendingList) CountActive

func (rl *PendingList) CountActive() int

func (*PendingList) CountFinish

func (rl *PendingList) CountFinish() int

func (*PendingList) EarliestPulse

func (rl *PendingList) EarliestPulse() pulse.Number

func (*PendingList) Exist

func (rl *PendingList) Exist(ref reference.Global) bool

func (*PendingList) Finish

func (rl *PendingList) Finish(ref reference.Global) bool

func (PendingList) GetState

func (rl PendingList) GetState(ref reference.Global) (bool, bool)

returns isActive and Exist info

type PendingTable

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

func NewRequestTable

func NewRequestTable() PendingTable

func (PendingTable) GetList

func (rt PendingTable) GetList(flag isolation.InterferenceFlag) *PendingList

func (PendingTable) Len

func (rt PendingTable) Len() int

type WorkingList

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

func (*WorkingList) Count

func (rl *WorkingList) Count() int

func (*WorkingList) CountActive

func (rl *WorkingList) CountActive() int

func (*WorkingList) CountFinish

func (rl *WorkingList) CountFinish() int

func (*WorkingList) EarliestPulse

func (rl *WorkingList) EarliestPulse() pulse.Number

func (*WorkingList) GetState

func (rl *WorkingList) GetState(ref reference.Global) WorkingRequestState

type WorkingRequestState

type WorkingRequestState int

const (
	RequestUnknown WorkingRequestState = iota
	RequestStarted
	RequestProcessing
	RequestFinished
)

type WorkingTable

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

func NewWorkingTable

func NewWorkingTable() WorkingTable

func (WorkingTable) Add

func (wt WorkingTable) Add(flag isolation.InterferenceFlag, ref reference.Global) bool

Add adds reference.Global returns true if added and false if already exists

func (WorkingTable) Finish

func (wt WorkingTable) Finish(
	flag isolation.InterferenceFlag,
	ref reference.Global,
	result *rms.VCallResult,
) bool

func (WorkingTable) GetList

func (wt WorkingTable) GetList(flag isolation.InterferenceFlag) *WorkingList

func (WorkingTable) GetResults

func (wt WorkingTable) GetResults() map[reference.Global]CallSummary

func (*WorkingTable) Len

func (wt *WorkingTable) Len() int

func (WorkingTable) SetActive

func (wt WorkingTable) SetActive(flag isolation.InterferenceFlag, ref reference.Global) bool