document

type CircuitBreaker interface {
	Success()
	Failure()
	State() CircuitState
}

type CircuitState int

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

type ClientOptions struct {
	BaseURL     string
	Timeout     time.Duration
	Route       string
	TraceLevel  int
	Compression Compression
	Speedtest   bool
	NowFunc     func() time.Time
}

type Compression int

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

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

type Document struct {
	Id        Id
	Condition string
	Body      []byte
	Operation Operation
	Create    bool
	// contains filtered or unexported fields
}

type Feeder interface{ Send(Document) Result }

type Generator struct {
	Size     int
	Deadline time.Time
	// contains filtered or unexported fields
}

type Id struct {
	Type         string
	Namespace    string
	Number       *int64
	Group        string
	UserSpecific string
	// contains filtered or unexported fields
}

type Operation int

type Queue[T any] struct {
	// contains filtered or unexported fields
}

type Result struct {
	Err        error
	Id         Id
	Trace      string
	Body       []byte
	Status     Status
	HTTPStatus int
	Latency    time.Duration
	BytesSent  int64
	BytesRecv  int64
}

type Stats struct {
	// Number of operations passed to the feeder by the user, not counting retries.
	Operations int64
	// Number of responses received, grouped by the HTTP status code. Requests that do not receive a response (i.e. no
	// status code) are not counted.
	ResponsesByCode map[int]int64
	// Number of requests made, including retries.
	Requests int64
	// Number of responses received.
	Responses int64
	// Number of transport layer errors.
	Errors int64
	// Number of requests currently in-flight.
	Inflight int64
	// Sum of response latency
	TotalLatency time.Duration
	// Lowest recorded response latency
	MinLatency time.Duration
	// Highest recorded response latency
	MaxLatency time.Duration
	// Total bytes sent
	BytesSent int64
	// Total bytes received
	BytesRecv int64
}

type Status int

type Throttler interface {
	// Sent notifies the the throttler that a document has been sent.
	Sent()
	// Success notifies the throttler that document operation succeeded.
	Success()
	// Throttled notifies the throttler that a throttling event occured while count documents were in-flight.
	Throttled(count int64)
	// TargetInflight returns the ideal number of documents to have in-flight now.
	TargetInflight() int64
}