Documentation ¶
Index ¶
Constants ¶
View Source
const FRAMEWORK_ERROR_INVOKE_ERROR = "INVOKE_ERROR"
View Source
const FRAMEWORK_ERROR_NO_RECEIVERS_AVAILABLE = "NO_RECEIVERS_AVAILABLE"
View Source
const FRAMEWORK_ERROR_PARAMETER_REDIRECT_DESTINATION = "REDIRECT_DESTINATION"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicInvoker ¶
type DynamicInvoker struct {
// contains filtered or unexported fields
}
func NewDynamicInvoker ¶
func NewDynamicInvoker(transportInvoker TransportInvoker, backoff backoff.BackOff, registry actorregistry.ActorRegistryFetcher) DynamicInvoker
func (*DynamicInvoker) Invoke ¶
func (invoker *DynamicInvoker) Invoke(request *invoker.Request) (variant.Assignable, *actionerror.Error)
type PlacementCache ¶
type PlacementCache struct {
// contains filtered or unexported fields
}
func NewPlacementCache ¶
func NewPlacementCache() *PlacementCache
func (PlacementCache) Delete ¶
func (cache PlacementCache) Delete(prepared [8]byte)
func (PlacementCache) Get ¶
func (cache PlacementCache) Get(prepared [8]byte) *string
type TransportInvoker ¶
type TransportInvoker interface {
Invoke(req *TransportHandlerInvokeRequest) *invoker.Response
}
TransportInvoker makes it possible to invoke a request to one specific transport receiver.
Click to show internal directories.
Click to hide internal directories.