Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Middleware ¶
type Middleware struct {
// contains filtered or unexported fields
}
Middleware manages scheduling of housekeeping tasks by intercepting gRPC requests.
func NewHousekeepingMiddleware ¶
func NewHousekeepingMiddleware(logger log.Logger, registry *protoregistry.Registry, factory localrepo.Factory, manager manager.Manager, interval int) *Middleware
NewHousekeepingMiddleware returns a new middleware.
func (*Middleware) StreamServerInterceptor ¶
func (m *Middleware) StreamServerInterceptor() grpc.StreamServerInterceptor
StreamServerInterceptor returns gRPC stream request middleware.
func (*Middleware) UnaryServerInterceptor ¶
func (m *Middleware) UnaryServerInterceptor() grpc.UnaryServerInterceptor
UnaryServerInterceptor returns gRPC unary middleware.
func (*Middleware) WaitForWorkers ¶
func (m *Middleware) WaitForWorkers()
WaitForWorkers waits for any active housekeeping tasks to finish.
Source Files
Click to show internal directories.
Click to hide internal directories.