Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Handler ¶
type Handler struct {
services.StateMachine
// contains filtered or unexported fields
}
func NewHandler ¶
type Request ¶
type Request struct {
Observations *values.List `mapstructure:"-"`
ExpiresAt time.Time
// CallbackCh is a channel to send a response back to the requester
// after the request has been processed or timed out.
CallbackCh chan capabilities.CapabilityResponse
StopCh services.StopChan
WorkflowExecutionID string
WorkflowID string
WorkflowOwner string
WorkflowName string
WorkflowDonID uint32
WorkflowDonConfigVersion uint32
ReportID string
KeyID string
}
type Response ¶
type Response struct {
WorkflowExecutionID string
capabilities.CapabilityResponse
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store stores ongoing consensus requests in an in-memory map. Note: this object is intended to be thread-safe, so any read requests should first deep-copy the returned request object via request.Copy().
func (*Store) FirstN ¶
FirstN returns up to `bathSize` requests. The method deep-copies requests before returning them.
Source Files
Click to show internal directories.
Click to hide internal directories.