expire

Documentation

Index

• type ExpireHandler
  • func New(ttl time.Duration) *ExpireHandler
  • func (e *ExpireHandler) DropExpired() modules.BatchHandlerFunc

Types

type ExpireHandler

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

func New

func New(ttl time.Duration) *ExpireHandler

New returns an ExpireHandler which contains a BatchHandlerFunc to track and drop AiOperations that have been in the mempool for longer than the TTL duration.

func (*ExpireHandler) DropExpired

func (e *ExpireHandler) DropExpired() modules.BatchHandlerFunc

DropExpired returns a BatchHandlerFunc that will drop AiOperations from the mempool if it has been around for longer than the TTL duration.