kongo

type Customer struct {
	// The date when the customer was registered.
	CreatedAt Time `json:"created_at"`

	// Field for storing an existing unique ID for the consumer. You must send either this field or username with the request.
	CustomId string `json:"custom_id,omitempty"`

	// The identification of customer registered.
	Id string `json:"id"`

	// The unique username of the consumer. You must send either this field or custom_id with the request.
	Username string `json:"username,omitempty"`
}

type Customers interface {
	// Create creates a new customer.
	Create(customer *Customer) (*Customer, *http.Response, error)

	// CreateWithContext creates a new customer.
	CreateWithContext(ctx context.Context, customer *Customer) (*Customer, *http.Response, error)

	// Delete deletes registered customer by ID or Username.
	Delete(idOrUsername string) (*http.Response, error)

	// DeleteWithContext deletes registered customer by ID or Username.
	DeleteWithContext(ctx context.Context, idOrUsername string) (*http.Response, error)

	// Get retrieves registered customer by ID or username.
	Get(idOrUsername string) (*Customer, *http.Response, error)

	// GetWithContext retrieves registered customer by ID or username.
	GetWithContext(ctx context.Context, idOrUsername string) (*Customer, *http.Response, error)

	// List retrieves a list of registered customers.
	List(options *ListCustomersOptions) ([]*Customer, *http.Response, error)

	// ListWithContext retrieves a list of registered customers.
	ListWithContext(ctx context.Context, options *ListCustomersOptions) ([]*Customer, *http.Response, error)

	// Update updates a customer registered by ID or Username.
	Update(idOrUsername string, customer *Customer) (*Customer, *http.Response, error)

	// UpdateWithContext updates a customer registered by ID or Username.
	UpdateWithContext(ctx context.Context, idOrUsername string, customer *Customer) (*Customer, *http.Response, error)
}

type CustomersRoot struct {
	// List of customers.
	Customers []*Customer `json:"data"`
}

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

type ErrorResponse struct {
	// HTTP response that caused this error
	Response *http.Response

	// Error message based on http status code
	Message string `json:"message, omitempty"`
}

type Kongo struct {

	// Kong server base URL.
	BaseURL *url.URL

	// User agent for client
	UserAgent string

	// Node api service
	Node Node

	// Services api service
	Services Services

	// Routes api service
	Routes Routes

	// Customers api service
	Customers Customers
	// contains filtered or unexported fields
}

type ListCustomersOptions struct {
	// A filter on the list based on the consumer custom_id field.
	CustomId string `url:"custom_id, omitempty"`

	// A filter on the list based on the consumer id field.
	Id string `url:"id, omitempty"`

	// A cursor used for pagination. offset is an object identifier that defines a place in the list.
	Offset string `url:"offset, omitempty"`

	// A limit on the number of objects to be returned per page. Defaults is 100 and max is 100.
	Size int `url:"size, omitempty"`

	// A filter on the list based on the consumer username field.
	Username string `url:"username, omitempty"`
}

type ListRoutesOptions struct {
	// A cursor used for pagination. offset is an object identifier that defines a place in the list.
	Offset string `url:"offset, omitempty"`

	// A limit on the number of objects to be returned per page. Defaults is 100 and max is 100.
	Size int `url:"size, omitempty"`
}

type ListServicesOptions struct {
	// A cursor used for pagination. offset is an object identifier that defines a place in the list.
	Offset string `url:"offset, omitempty"`

	// A limit on the number of objects to be returned per page. Defaults is 100 and max is 100.
	Size int `url:"size, omitempty"`
}

type Node interface {
	// Info retrieves the information about the server node
	Info() (*NodeInfo, *http.Response, error)

	// InfoWithContext retrieves the information about the server node
	InfoWithContext(ctx context.Context) (*NodeInfo, *http.Response, error)

	// Status retrieves the status of the server node.
	Status() (*NodeStatus, *http.Response, error)

	// StatusWithContext retrieves the status of the server node.
	StatusWithContext(ctx context.Context) (*NodeStatus, *http.Response, error)
}

type NodeInfo struct {
	Configuration *NodeInfoConfiguration `json:"configuration"`
	Hostname      string                 `json:"hostname"`
	LuaVersion    string                 `json:"lua_version"`
	Plugins       *NodeInfoPlugins       `json:"plugins"`
	PrngSeeds     map[string]int         `json:"prng_seeds"`
	Tagline       string                 `json:"tagline"`
	Timers        *NodeInfoTimers        `json:"timers"`
	Version       string                 `json:"version"`
}

type NodeInfoConfiguration struct {
	AdminAcessLog                 string              `json:"admin_access_log"`
	AdminErrorLog                 string              `json:"admin_error_log"`
	AdminListen                   []string            `json:"admin_listen"`
	AdminListeners                []*NodeInfoListener `json:"admin_listeners"`
	AdminSSLCertificateDefault    string              `json:"admin_ssl_cert_default"`
	AdminSSLCertificateCsrDefault string              `json:"admin_ssl_cert_csr_default"`
	AdminSSLCertificateKeyDefault string              `json:"admin_ssl_cert_key_default"`
	AdminSSLEnabled               bool                `json:"admin_ssl_enabled"`
	AnonymousReports              bool                `json:"anonymous_reports"`

	CassandraConsistency            string   `json:"cassandra_consistency"`
	CassandraContactPoints          []string `json:"cassandra_contact_points"`
	CassandraDataCenters            []string `json:"cassandra_data_centers"`
	CassandraKeyspace               string   `json:"cassandra_keyspace"`
	CassandraLBPolicy               string   `json:"cassandra_lb_policy"`
	CassandraPort                   int      `json:"cassandra_port"`
	CassandraReplicationFactor      int      `json:"cassandra_repl_factor"`
	CassandraReplicationStrategy    string   `json:"cassandra_repl_strategy"`
	CassandraSchemaConsensusTimeout int      `json:"cassandra_schema_consensus_timeout"`
	CassandraSSL                    bool     `json:"cassandra_ssl"`
	CassandraSSLVerify              bool     `json:"cassandra_ssl_verify"`
	CassandraTimeout                int      `json:"cassandra_timeout"`
	CassandraUsername               string   `json:"cassandra_username"`

	ClientBodyBufferSize           string `json:"client_body_buffer_size"`
	ClientMaxBodySize              string `json:"client_max_body_size"`
	ClientSSL                      bool   `json:"client_ssl"`
	ClientSSLCertificateCsrDefault string `json:"client_ssl_cert_csr_default"`
	ClientSSLCertificateDefault    string `json:"client_ssl_cert_default"`
	ClientSSLCertificateKeyDefault string `json:"client_ssl_cert_key_default"`

	CustomPlugins interface{} `json:"custom_plugins"`

	Database                  string `json:"database"`
	DatabaseCacheTTL          int    `json:"db_cache_ttl"`
	DatabaseUpdateFrequency   int    `json:"db_update_frequency"`
	DatabaseUpdatePropagation int    `json:"db_update_propagation"`

	DNSErrorTTL    int         `json:"dns_error_ttl"`
	DNSHostsFile   string      `json:"dns_hostsfile"`
	DNSNotFoundTTL int         `json:"dns_not_found_ttl"`
	DNSNoSync      bool        `json:"dns_no_sync"`
	DNSOrder       []string    `json:"dns_order"`
	DNSResolver    interface{} `json:"dns_resolver"`
	DNSStaleTTL    int         `json:"dns_stale_ttl"`

	ErrorDefaultType string `json:"error_default_type"`

	KongEnv string `json:"kong_env"`

	LatencyTokens bool `json:"latency_tokens"`

	LuaPackageCPath   string `json:"lua_package_cpath"`
	LuaPackagePath    string `json:"lua_package_path"`
	LuaSocketPoolSize int    `json:"lua_socket_pool_size"`
	LuaSSLVerifyDepth int    `json:"lua_ssl_verify_depth"`

	LogLevel string `json:"log_level"`

	MemoryCacheSize string `json:"mem_cache_size"`

	NginxAccessLogs      string `json:"nginx_acc_logs"`
	NginxAdminAccessLog  string `json:"nginx_admin_acc_logs"`
	NginxConf            string `json:"nginx_conf"`
	NginxDaemon          string `json:"nginx_daemon"`
	NginxErrorLogs       string `json:"nginx_err_logs"`
	NginxKongConf        string `json:"nginx_kong_conf"`
	NginxOptimizations   bool   `json:"nginx_optimizations"`
	NginxPID             string `json:"nginx_pid"`
	NginxWorkerProcesses string `json:"nginx_worker_processes"`

	Plugins map[string]bool `json:"plugins"`

	PostgresDatabase  string `json:"pg_database"`
	PostgresHost      string `json:"pg_host"`
	PostgresPort      int    `json:"pg_port"`
	PostgresSSL       bool   `json:"pg_ssl"`
	PostgresUsername  string `json:"pg_user"`
	PostgresSSLVerify bool   `json:"pg_ssl_verify"`

	Prefix string `json:"prefix"`

	ProxyAccessLog  string              `json:"proxy_access_log"`
	ProxyErrorLog   string              `json:"proxy_error_log"`
	ProxyListen     []string            `json:"proxy_listen"`
	ProxyListeners  []*NodeInfoListener `json:"proxy_listeners"`
	ProxySSLEnabled bool                `json:"proxy_ssl_enabled"`

	RealIpHeader    string `json:"real_ip_header"`
	RealIpRecursive string `json:"real_ip_recursive"`

	ServerTokens bool `json:"server_tokens"`

	SSLCertificate           string `json:"ssl_cert"`
	SSLCertificateDefault    string `json:"ssl_cert_default"`
	SSLCertificateKey        string `json:"ssl_cert_key"`
	SSLCertificateDefaultKey string `json:"ssl_cert_key_default"`
	SSLCertificateCsrDefault string `json:"ssl_cert_csr_default"`
	SSLCiphers               string `json:"ssl_ciphers"`
	SSLCipherSuite           string `json:"ssl_cipher_suite"`

	TrustedIps interface{} `json:"trusted_ips"`

	UpstreamKeepAlive int `json:"upstream_keepalive"`
}

type NodeInfoListener struct {
	SSL      bool   `json:"ssl"`
	Ip       string `json:"ip"`
	Protocol bool   `json:"protocol"`
	Port     int    `json:"port"`
	Http2    bool   `json:"http2"`
	Listener string `json:"listener"`
}

type NodeInfoPlugins struct {
	AvailableOnServer map[string]bool `json:"available_on_server"`
	EnabledInCluster  []string        `json:"enabled_in_cluster"`
}

type NodeInfoTimers struct {
	Pending int `json:"pending"`
	Running int `json:"running"`
}

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

type NodeStatus struct {
	Database *NodeStatusDatabase `json:"database"`
	Server   *NodeStatusServer   `json:"server"`
}

type NodeStatusDatabase struct {
	Reachable bool `json:"reachable, omitempty"`
}

type NodeStatusServer struct {
	ConnectionsAccepted int `json:"connections_accepted, omitempty"`
	ConnectionsActive   int `json:"connections_active, omitempty"`
	ConnectionsHandled  int `json:"connections_handled, omitempty"`
	ConnectionsReading  int `json:"connections_reading, omitempty"`
	ConnectionsWaiting  int `json:"connections_waiting, omitempty"`
	ConnectionsWriting  int `json:"connections_writing, omitempty"`
	TotalRequests       int `json:"total_requests, omitempty"`
}

type Route struct {
	// The date when the route was registered.
	CreatedAt Time `json:"created_at"`

	// A list of domain names that match this Route. At least one of hosts, paths, or methods must be set.
	Hosts []string `json:"hosts,omitempty"`

	// The identification of route registered.
	Id string `json:"id"`

	// A list of HTTP methods that match this Route. At least one of hosts, paths, or methods must be set.
	Methods []string `json:"methods,omitempty"`

	// A list of paths that match this Route. At least one of hosts, paths, or methods must be set.
	Paths []string `json:"paths,omitempty"`

	// When matching a Route via one of the hosts domain names, use the request Host header in the upstream request headers.
	PreserveHost bool `json:"preserve_host,omitempty"`

	// A list of the protocols this Route should allow. By default it is ["http", "https"].
	Protocols []string `json:"protocols"`

	// The Service this Route is associated to. This is where the Route proxies traffic to.
	Service RouteService `json:"service"`

	// When matching a Route via one of the paths, strip the matching prefix from the upstream request URL.
	StripPath bool `json:"strip_path,omitempty"`

	// The date when the route was updated.
	UpdatedAt Time `json:"updated_at"`
}

type RouteService struct {
	// Service id associated.
	Id string `json:"id"`
}

type Routes interface {
	// Create creates a new route.
	Create(route *Route) (*Route, *http.Response, error)

	// CreateWithContext creates a new route.
	CreateWithContext(ctx context.Context, route *Route) (*Route, *http.Response, error)

	// Delete deletes registered route by ID or Name.
	Delete(id string) (*http.Response, error)

	// DeleteWithContext deletes registered route by ID or Name.
	DeleteWithContext(ctx context.Context, id string) (*http.Response, error)

	// Get retrieves registered route by ID.
	Get(id string) (*Route, *http.Response, error)

	// GetWithContext retrieves registered route by ID.
	GetWithContext(ctx context.Context, id string) (*Route, *http.Response, error)

	// List retrieves a list of registered routes.
	List(options *ListRoutesOptions) ([]*Route, *http.Response, error)

	// ListWithContext retrieves a list of registered routes.
	ListWithContext(ctx context.Context, options *ListRoutesOptions) ([]*Route, *http.Response, error)

	// Update updates a route registered by ID.
	Update(id string, route *Route) (*Route, *http.Response, error)

	// UpdateWithContext updates a route registered by ID.
	UpdateWithContext(ctx context.Context, id string, route *Route) (*Route, *http.Response, error)
}

type RoutesRoot struct {
	// List of routes.
	Routes []*Route `json:"data"`
}

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

type Service struct {
	// The timeout in milliseconds for establishing a connection to the upstream server. Defaults to 60000.
	ConnectTimeout int64 `json:"connect_timeout,omitempty" groups:"create,update"`

	// The date when the service was registred
	CreatedAt Time `json:"created_at"`

	// The host of the upstream server.
	Host string `json:"host" groups:"create,update"`

	// The identification of service registred
	Id string `json:"id"`

	// The service name.
	Name string `json:"name" groups:"create,create_url,update,update_url"`

	// The path to be used in requests to the upstream server. Empty by default.
	Path string `json:"path,omitempty" groups:"create,update"`

	// The upstream server port. Defaults to 80.
	Port int `json:"port,omitempty" groups:"create,update"`

	// The protocol used to communicate with the upstream. It can be one of http (default) or https.
	Protocol string `json:"protocol" groups:"create,update"`

	// The timeout in milliseconds between two successive read operations for transmitting a request to the upstream server. Defaults to 60000.
	ReadTimeout int `json:"read_timeout,omitempty" groups:"create,update"`

	// The number of retries to execute upon failure to proxy. The default is 5.
	Retries int `json:"retries,omitempty" groups:"create,update"`

	// The date when the service was updated
	UpdatedAt Time `json:"updated_at"`

	// Shorthand attribute to set protocol, host, port and path at once. This attribute is write-only (the Admin API never "returns" the url).
	URL string `json:"url,omitempty" groups:"create_url,update_url"`

	// The timeout in milliseconds between two successive write operations for transmitting a request to the upstream server. Defaults to 60000.
	WriteTimeout int `json:"write_timeout,omitempty" groups:"create,update"`
}

type Services interface {
	// Create creates a new service
	Create(svc *Service) (*Service, *http.Response, error)

	// CreateWithContext creates a new service
	CreateWithContext(ctx context.Context, svc *Service) (*Service, *http.Response, error)

	// CreateByURLWithContext creates a new service by URL
	CreateByURL(svc *Service) (*Service, *http.Response, error)

	// CreateByURLWithContext creates a new service by URL
	CreateByURLWithContext(ctx context.Context, svc *Service) (*Service, *http.Response, error)

	// Delete deletes registred service by ID or Name
	Delete(idOrName string) (*http.Response, error)

	// DeleteWithContext deletes registred service by ID or Name
	DeleteWithContext(ctx context.Context, idOrName string) (*http.Response, error)

	// Get retrieves registred service by ID or Name
	Get(idOrName string) (*Service, *http.Response, error)

	// GetWithContext retrieves registred service by ID or Name
	GetWithContext(ctx context.Context, idOrName string) (*Service, *http.Response, error)

	// List retrieves a list of registred services
	List(options *ListServicesOptions) ([]*Service, *http.Response, error)

	// ListWithContext retrieves a list of registred services
	ListWithContext(ctx context.Context, options *ListServicesOptions) ([]*Service, *http.Response, error)

	// Update updates a service registred by ID or Name
	Update(idOrName string, svc *Service) (*Service, *http.Response, error)

	// UpdateWithContext updates a service registred by ID or Name
	UpdateWithContext(ctx context.Context, idOrName string, svc *Service) (*Service, *http.Response, error)

	// UpdateByURL updates a service registred by URL and pass the ID or Name
	UpdateByURL(idOrName string, svc *Service) (*Service, *http.Response, error)

	// UpdateByURLWithContext updates a service registred by URL and pass the ID or Name
	UpdateByURLWithContext(ctx context.Context, idOrName string, svc *Service) (*Service, *http.Response, error)
}

type ServicesRoot struct {
	Services []*Service `json:"data"`
}

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

type Time struct {
	time.Time
}