transaction

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

type BytesPayloads []*BytesPayload

type Endpoint struct {
	// Route to hit in the HTTP transaction
	Route string
	// Name of the endpoint for the telemetry metrics
	Name string
}

type HTTPAttemptHandler func(transaction *HTTPTransaction)

type HTTPCompletionHandler func(transaction *HTTPTransaction, statusCode int, body []byte, err error)

type HTTPTransaction struct {
	// Domain represents the domain target by the HTTPTransaction.
	Domain string
	// Endpoint is the API Endpoint used by the HTTPTransaction.
	Endpoint Endpoint
	// Headers are the HTTP headers used by the HTTPTransaction.
	Headers http.Header
	// Payload is the content delivered to the backend.
	Payload *BytesPayload
	// ErrorCount is the number of times this HTTPTransaction failed to be processed.
	ErrorCount int

	CreatedAt time.Time
	// Retryable indicates whether this transaction can be retried
	Retryable bool

	// StorableOnDisk indicates whether this transaction can be stored on disk
	StorableOnDisk bool

	// AttemptHandler will be called with a transaction before the attempting to send the request
	// This field is not restored when a transaction is deserialized from the disk (the default value is used).
	AttemptHandler HTTPAttemptHandler
	// CompletionHandler will be called with a transaction after it has been successfully sent
	// This field is not restored when a transaction is deserialized from the disk (the default value is used).
	CompletionHandler HTTPCompletionHandler

	Priority Priority

	Kind Kind
}

type Kind int

type Priority int

type SortByCreatedTimeAndPriority struct {
	HighPriorityFirst bool
}

type Transaction interface {
	Process(ctx context.Context, config config.Component, log log.Component, client *http.Client) error
	GetCreatedAt() time.Time
	GetTarget() string
	GetPriority() Priority
	GetKind() Kind
	GetEndpointName() string
	GetPayloadSize() int
	GetPointCount() int

	// This method serializes the transaction to `TransactionsSerializer`.
	// It forces a new implementation of `Transaction` to define how to
	// serialize the transaction to `TransactionsSerializer` as a `Transaction`
	// must be serializable in domainForwarder.
	SerializeTo(log.Component, TransactionsSerializer) error
}

type TransactionsSerializer interface {
	Add(transaction *HTTPTransaction) error
}