pullapi

type Authorizer func(r *http.Request) bool

type DequeueParams struct {
	Batch       int
	MaxWait     time.Duration
	HasMaxWait  bool
	LeaseTTL    time.Duration
	HasLeaseTTL bool
}

type DequeueResult struct {
	Items []queue.Envelope
}

type Handler interface {
	ServeHTTP(w http.ResponseWriter, r *http.Request)
}

type LeaseBatchResult struct {
	Succeeded int
	Conflicts []queue.LeaseBatchConflict
}

type OpError struct {
	StatusCode int
	Code       string
	Detail     string
}

type Server struct {
	Store                queue.Store
	Target               string
	ResolveRoute         func(endpoint string) (route string, ok bool)
	Authorize            Authorizer
	ObserveDequeue       func(route string, statusCode int, items []queue.Envelope)
	ObserveAck           func(route string, statusCode int, leaseID string, leaseExpired bool)
	ObserveNack          func(route string, statusCode int, leaseID string, leaseExpired bool)
	ObserveExtend        func(route string, statusCode int, leaseID string, extendBy time.Duration, leaseExpired bool)
	DefaultLeaseTTL      time.Duration
	MaxBatch             int
	MaxLeaseBatch        int
	MaxLeaseTTL          time.Duration
	DefaultMaxWait       time.Duration
	MaxWait              time.Duration
	SSEKeepalive         time.Duration
	SSEMaxConnection     time.Duration
	ObserveSSEConnect    func(route string)
	ObserveSSEDisconnect func(route string, statusCode int, messagesSent int, duration time.Duration)

	RecentLeaseOpTTL time.Duration
	RecentLeaseOpCap int
	// contains filtered or unexported fields
}