Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncExecutor ¶
type AsyncExecutor struct {
// contains filtered or unexported fields
}
AsyncExecutor handles async request processing
func New ¶
func New(connManager *connection.Manager, requestQueue store.RequestQueue, logger *log.Logger) *AsyncExecutor
New creates a new async executor
func (*AsyncExecutor) ProcessRequest ¶
func (e *AsyncExecutor) ProcessRequest(ctx context.Context, asyncReq *store.AsyncRequest) error
ProcessRequest processes a single async request
func (*AsyncExecutor) ProcessWithRetry ¶
func (e *AsyncExecutor) ProcessWithRetry(ctx context.Context, asyncReq *store.AsyncRequest) error
ProcessWithRetry processes a request with retry logic
func (*AsyncExecutor) RegisterHandler ¶
func (e *AsyncExecutor) RegisterHandler(action string, handler streamer.Handler) error
RegisterHandler registers an async handler
Source Files
Click to show internal directories.
Click to hide internal directories.