resttunnel

type BaseResponse struct {
	Error   string      `json:"error,omitempty"`
	Success bool        `json:"success"`
	Data    interface{} `json:"data,omitempty"`
	Queued  *bool       `json:"queued,omitempty"`
	UUID    *uuid.UUID  `json:"uuid,omitempty"`
}

type ErrorResponse struct {
	Error   string    `json:"error"`
	Success bool      `json:"success"`
	Queued  bool      `json:"queued,omitempty"` // Boolean if the request has already been queued
	UUID    uuid.UUID `json:"uuid,omitempty"`
}

type MethodRouter struct {
	*mux.Router
}

type Queue struct {
	Expiration time.Time

	JobActive   *abool.AtomicBool
	JobsHandled *int64

	Bucket *bucket.Bucket

	PriorityEvents chan *structs.TunnelRequest
	Events         chan *structs.TunnelRequest
	// contains filtered or unexported fields
}

type RestTunnel struct {
	Configuration *TunnelConfiguration `json:"configuration"`

	Logger zerolog.Logger `json:"-"`

	Start time.Time `json:"uptime"`

	HTTP *fasthttp.Client `json:"-"`

	Buckets map[string]*bucket.Bucket `json:"buckets"`

	Queues map[string]*Queue `json:"queue"`

	Callbacks map[uuid.UUID]*structs.TunnelResponse `json:"callbacks"`

	// Analytics for ratelimits
	AnalyticsHit  *accumulator.Accumulator
	AnalyticsMiss *accumulator.Accumulator

	// Requests waiting and an atomic cache
	AnalyticsWaiting *accumulator.Accumulator

	// Analytics for requests and callbacks buffer
	AnalyticsRequests  *accumulator.Accumulator
	AnalyticsCallbacks *accumulator.Accumulator

	// Uses total response time and requests to calculate average
	AnalyticsAverageResponse *accumulator.Accumulator
	AverageResponse          *accumulator.Accumulator

	Router *MethodRouter
	// contains filtered or unexported fields
}

type TunnelConfiguration struct {
	Host string `json:"host" yaml:"host"`

	State struct {
		CallbackExpiration int `json:"callback_expiration" yaml:"callback_expiration"`
		QueueExpiration    int `json:"queue_expiration" yaml:"queue_expiration"`
	} `json:"state" yaml:"state"`

	ReverseRoute struct {
		Enabled bool   `json:"enabled" yaml:"enabled"`
		Host    string `json:"host" yaml:"host"`
	} `json:"reverse_route" yaml:"reverse_route"`

	Logging struct {
		ConsoleLoggingEnabled bool `json:"console_logging" yaml:"console_logging"`
		FileLoggingEnabled    bool `json:"file_logging" yaml:"file_logging"`

		EncodeAsJSON bool `json:"encode_as_json" yaml:"encode_as_json"` // Make the framework log as json

		Directory  string `json:"directory" yaml:"directory"`     // Directory to log into
		Filename   string `json:"filename" yaml:"filename"`       // Name of logfile
		MaxSize    int    `json:"max_size" yaml:"max_size"`       // Size in MB before a new file
		MaxBackups int    `json:"max_backups" yaml:"max_backups"` // Number of files to keep
		MaxAge     int    `json:"max_age" yaml:"max_age"`         // Number of days to keep a logfile
	} `json:"logging" yaml:"logging"`
}