v1

type CaCertificate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec CaCertificateSpec `json:"spec,omitempty"`
}

type CaCertificateClient interface {
	CaCertificateReader
	CaCertificateWriter
	CaCertificateStatusWriter
}

type CaCertificateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []CaCertificate `json:"items"`
}

type CaCertificateReader interface {
	// Get retrieves a CaCertificate for the given object key
	GetCaCertificate(ctx context.Context, key client.ObjectKey) (*CaCertificate, error)

	// List retrieves list of CaCertificates for a given namespace and list options.
	ListCaCertificate(ctx context.Context, opts ...client.ListOption) (*CaCertificateList, error)
}

type CaCertificateSlice []*CaCertificate

type CaCertificateSpec struct {
	CommonInfo              *v1.CommonInfo     `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	CertificateInfo         *v11.Certificate   `protobuf:"bytes,2,opt,name=certificateInfo,proto3" json:"certificateInfo,omitempty"`
	Ca                      string             `protobuf:"bytes,3,opt,name=ca,proto3" json:"ca,omitempty"`
	Crl                     string             `protobuf:"bytes,4,opt,name=crl,proto3" json:"crl,omitempty"`
	AllowExpiredCertificate bool               `protobuf:"varint,5,opt,name=allowExpiredCertificate,proto3" json:"allowExpiredCertificate,omitempty"`
	TlsParameters           *v11.TlsParameters `protobuf:"bytes,6,opt,name=tlsParameters,proto3" json:"tlsParameters,omitempty"`
	// Set Application Level Protocol Negotiation
	// If empty, defaults to ["h2", "http/1.1"].
	AlpnProtocols []string `protobuf:"bytes,7,rep,name=alpnProtocols,proto3" json:"alpnProtocols,omitempty"`
	// contains filtered or unexported fields
}

type CaCertificateStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given CaCertificate object.
	UpdateCaCertificateStatus(ctx context.Context, obj *CaCertificate, opts ...client.UpdateOption) error

	// Patch patches the given CaCertificate object's subresource.
	PatchCaCertificateStatus(ctx context.Context, obj *CaCertificate, patch client.Patch, opts ...client.PatchOption) error
}

type CaCertificateTransitionFunction func(existing, desired *CaCertificate) error

type CaCertificateWriter interface {
	// Create saves the CaCertificate object.
	CreateCaCertificate(ctx context.Context, obj *CaCertificate, opts ...client.CreateOption) error

	// Delete deletes the CaCertificate object.
	DeleteCaCertificate(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given CaCertificate object.
	UpdateCaCertificate(ctx context.Context, obj *CaCertificate, opts ...client.UpdateOption) error

	// Patch patches the given CaCertificate object.
	PatchCaCertificate(ctx context.Context, obj *CaCertificate, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all CaCertificate objects matching the given options.
	DeleteAllOfCaCertificate(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the CaCertificate object.
	UpsertCaCertificate(ctx context.Context, obj *CaCertificate, transitionFuncs ...CaCertificateTransitionFunction) error
}

type Certificate struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec CertificateSpec `json:"spec,omitempty"`
}

type CertificateClient interface {
	CertificateReader
	CertificateWriter
	CertificateStatusWriter
}

type CertificateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Certificate `json:"items"`
}

type CertificateReader interface {
	// Get retrieves a Certificate for the given object key
	GetCertificate(ctx context.Context, key client.ObjectKey) (*Certificate, error)

	// List retrieves list of Certificates for a given namespace and list options.
	ListCertificate(ctx context.Context, opts ...client.ListOption) (*CertificateList, error)
}

type CertificateSlice []*Certificate

type CertificateSpec struct {
	CommonInfo       *v1.CommonInfo   `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	CertificateInfo  *v11.Certificate `protobuf:"bytes,2,opt,name=certificateInfo,proto3" json:"certificateInfo,omitempty"`
	CertificateChain string           `protobuf:"bytes,3,opt,name=certificateChain,proto3" json:"certificateChain,omitempty"`
	PrivateKey       string           `protobuf:"bytes,4,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// The password to decrypt the TLS private key. If this field is not set, it is assumed that the TLS private key is not password encrypted.
	Password      string             `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	TlsParameters *v11.TlsParameters `protobuf:"bytes,6,opt,name=tlsParameters,proto3" json:"tlsParameters,omitempty"`
	// Set Application Level Protocol Negotiation
	// If empty, defaults to ["h2", "http/1.1"].
	AlpnProtocols []string `protobuf:"bytes,7,rep,name=alpnProtocols,proto3" json:"alpnProtocols,omitempty"`
	// contains filtered or unexported fields
}

type CertificateStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Certificate object.
	UpdateCertificateStatus(ctx context.Context, obj *Certificate, opts ...client.UpdateOption) error

	// Patch patches the given Certificate object's subresource.
	PatchCertificateStatus(ctx context.Context, obj *Certificate, patch client.Patch, opts ...client.PatchOption) error
}

type CertificateTransitionFunction func(existing, desired *Certificate) error

type CertificateWriter interface {
	// Create saves the Certificate object.
	CreateCertificate(ctx context.Context, obj *Certificate, opts ...client.CreateOption) error

	// Delete deletes the Certificate object.
	DeleteCertificate(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Certificate object.
	UpdateCertificate(ctx context.Context, obj *Certificate, opts ...client.UpdateOption) error

	// Patch patches the given Certificate object.
	PatchCertificate(ctx context.Context, obj *Certificate, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Certificate objects matching the given options.
	DeleteAllOfCertificate(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Certificate object.
	UpsertCertificate(ctx context.Context, obj *Certificate, transitionFuncs ...CertificateTransitionFunction) error
}

type Clientset interface {
	// clienset for the gate.xdmybl.io/v1/v1 APIs
	CaCertificates() CaCertificateClient
	// clienset for the gate.xdmybl.io/v1/v1 APIs
	Certificates() CertificateClient
	// clienset for the gate.xdmybl.io/v1/v1 APIs
	Upstreams() UpstreamClient
	// clienset for the gate.xdmybl.io/v1/v1 APIs
	Gateways() GatewayClient
	// clienset for the gate.xdmybl.io/v1/v1 APIs
	Filters() FilterClient
}

type ConnPoll struct {
	MaxRequestsPerConnection uint32 `protobuf:"varint,1,opt,name=maxRequestsPerConnection,proto3" json:"maxRequestsPerConnection,omitempty"`
	// 访问该集群的最大发连接数，默认值-1 (2^32-1 = 4294967295)。
	MaxConnections int64 `protobuf:"varint,2,opt,name=maxConnections,proto3" json:"maxConnections,omitempty"`
	MaxRequests    int64 `protobuf:"varint,3,opt,name=maxRequests,proto3" json:"maxRequests,omitempty"`
	// 最大阻塞的请求数，默认值-1(2^32-1)。
	MaxPendingRequests    int64  `protobuf:"varint,4,opt,name=maxPendingRequests,proto3" json:"maxPendingRequests,omitempty"`
	OutboundSourceAddress string `protobuf:"bytes,5,opt,name=outboundSourceAddress,proto3" json:"outboundSourceAddress,omitempty"`
	// contains filtered or unexported fields
}

type DirectionAction struct {
	StatusCode uint32 `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Body       string `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type Filter struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec FilterSpec `json:"spec,omitempty"`
}

type FilterClient interface {
	FilterReader
	FilterWriter
	FilterStatusWriter
}

type FilterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Filter `json:"items"`
}

type FilterReader interface {
	// Get retrieves a Filter for the given object key
	GetFilter(ctx context.Context, key client.ObjectKey) (*Filter, error)

	// List retrieves list of Filters for a given namespace and list options.
	ListFilter(ctx context.Context, opts ...client.ListOption) (*FilterList, error)
}

type FilterSlice []*Filter

type FilterSpec struct {

	// common fields
	CommonInfo *v1.CommonInfo `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	// 必为其中一种类型, 目前计划先支持两种, Tcp Http 协议的处理
	//
	// Types that are assignable to FilterType:
	//
	//	*FilterSpec_Hcm
	//	*FilterSpec_TcpProxy
	FilterType isFilterSpec_FilterType `protobuf_oneof:"filter_type"`
	// contains filtered or unexported fields
}

type FilterSpec_Hcm struct {
	Hcm *HttpConnectionManager `protobuf:"bytes,2,opt,name=hcm,proto3,oneof"`
}

type FilterSpec_TcpProxy struct {
	TcpProxy *TcpProxy `protobuf:"bytes,3,opt,name=tcp_proxy,json=tcpProxy,proto3,oneof"`
}

type FilterStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Filter object.
	UpdateFilterStatus(ctx context.Context, obj *Filter, opts ...client.UpdateOption) error

	// Patch patches the given Filter object's subresource.
	PatchFilterStatus(ctx context.Context, obj *Filter, patch client.Patch, opts ...client.PatchOption) error
}

type FilterTransitionFunction func(existing, desired *Filter) error

type FilterWriter interface {
	// Create saves the Filter object.
	CreateFilter(ctx context.Context, obj *Filter, opts ...client.CreateOption) error

	// Delete deletes the Filter object.
	DeleteFilter(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Filter object.
	UpdateFilter(ctx context.Context, obj *Filter, opts ...client.UpdateOption) error

	// Patch patches the given Filter object.
	PatchFilter(ctx context.Context, obj *Filter, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Filter objects matching the given options.
	DeleteAllOfFilter(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Filter object.
	UpsertFilter(ctx context.Context, obj *Filter, transitionFuncs ...FilterTransitionFunction) error
}

type ForwardAction struct {
	WeightClusterLs []*WeightCluster `protobuf:"bytes,1,rep,name=weight_cluster_ls,json=weightClusterLs,proto3" json:"weight_cluster_ls,omitempty"`
	Timeout         uint32           `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type Gateway struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec GatewaySpec `json:"spec,omitempty"`
}

type GatewayClient interface {
	GatewayReader
	GatewayWriter
	GatewayStatusWriter
}

type GatewayList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Gateway `json:"items"`
}

type GatewayListener struct {

	// validate: ipv4 or ipv6, default 0.0.0.0
	BindAddress string `protobuf:"bytes,1,opt,name=bind_address,json=bindAddress,proto3" json:"bind_address,omitempty"`
	// validate: port value
	BindPort uint32 `protobuf:"varint,2,opt,name=bind_port,json=bindPort,proto3" json:"bind_port,omitempty"`
	// is bind to os port , default false
	BindToPort bool     `protobuf:"varint,3,opt,name=bind_to_port,json=bindToPort,proto3" json:"bind_to_port,omitempty"`
	FilterName []string `protobuf:"bytes,4,rep,name=filter_name,json=filterName,proto3" json:"filter_name,omitempty"`
	// listener option
	Options  *ListenerOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"`
	Metadata *v1.GateMetadata `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

type GatewayReader interface {
	// Get retrieves a Gateway for the given object key
	GetGateway(ctx context.Context, key client.ObjectKey) (*Gateway, error)

	// List retrieves list of Gateways for a given namespace and list options.
	ListGateway(ctx context.Context, opts ...client.ListOption) (*GatewayList, error)
}

type GatewaySlice []*Gateway

type GatewaySpec struct {
	CommonInfo *v1.CommonInfo `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	// validate: max and min item.
	Listeners []*GatewayListener `protobuf:"bytes,2,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

type GatewayStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Gateway object.
	UpdateGatewayStatus(ctx context.Context, obj *Gateway, opts ...client.UpdateOption) error

	// Patch patches the given Gateway object's subresource.
	PatchGatewayStatus(ctx context.Context, obj *Gateway, patch client.Patch, opts ...client.PatchOption) error
}

type GatewayTransitionFunction func(existing, desired *Gateway) error

type GatewayWriter interface {
	// Create saves the Gateway object.
	CreateGateway(ctx context.Context, obj *Gateway, opts ...client.CreateOption) error

	// Delete deletes the Gateway object.
	DeleteGateway(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Gateway object.
	UpdateGateway(ctx context.Context, obj *Gateway, opts ...client.UpdateOption) error

	// Patch patches the given Gateway object.
	PatchGateway(ctx context.Context, obj *Gateway, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Gateway objects matching the given options.
	DeleteAllOfGateway(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Gateway object.
	UpsertGateway(ctx context.Context, obj *Gateway, transitionFuncs ...GatewayTransitionFunction) error
}

type HeaderMatch struct {
	Exact    string `protobuf:"bytes,1,opt,name=exact,proto3" json:"exact,omitempty"`
	Prefix   string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Regex    string `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	Contains string `protobuf:"bytes,4,opt,name=contains,proto3" json:"contains,omitempty"`
	Invert   bool   `protobuf:"varint,5,opt,name=invert,proto3" json:"invert,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckSpecifier struct {
	Type            HealthCheckSpecifier_Type `protobuf:"varint,1,opt,name=type,proto3,enum=gate.xdmybl.io.HealthCheckSpecifier_Type" json:"type,omitempty"`
	TcpHealthCheck  *TcpHealthCheck           `protobuf:"bytes,2,opt,name=tcpHealthCheck,proto3" json:"tcpHealthCheck,omitempty"`
	HttpHealthCheck *HttpHealthCheck          `protobuf:"bytes,3,opt,name=httpHealthCheck,proto3" json:"httpHealthCheck,omitempty"`
	// contains filtered or unexported fields
}

type HealthCheckSpecifier_Type int32

type HttpConnectionManager struct {

	// 对应 Envoy route_config_name
	RouteConfig   *RouteConfig  `protobuf:"bytes,1,opt,name=route_config,json=routeConfig,proto3" json:"route_config,omitempty"`
	HttpFilter    []*HttpFilter `protobuf:"bytes,2,rep,name=http_filter,json=httpFilter,proto3" json:"http_filter,omitempty"`
	MergeSlashes  bool          `protobuf:"varint,3,opt,name=merge_slashes,json=mergeSlashes,proto3" json:"merge_slashes,omitempty"`
	SkipXffAppend bool          `protobuf:"varint,4,opt,name=skip_xff_append,json=skipXffAppend,proto3" json:"skip_xff_append,omitempty"`
	// contains filtered or unexported fields
}

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

type HttpHealthCheck struct {
	Host             string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Path             string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Method           string   `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	ExpectedStatuses []uint32 `protobuf:"varint,4,rep,packed,name=expectedStatuses,proto3" json:"expectedStatuses,omitempty"`
	ClientType       string   `protobuf:"bytes,5,opt,name=ClientType,proto3" json:"ClientType,omitempty"`
	// contains filtered or unexported fields
}

type ListenerOptions struct {

	// Soft limit on size of the listener's new connection read and write buffers. If unspecified, defaults to 1MiB
	// For more info, check out the [Envoy docs](https://www.envoyproxy.io/docs/envoy/v1.14.1/api-v2/api/v2/listener.proto)
	PerConnectionBufferLimitBytes uint32 `protobuf:"varint,1,opt,name=perConnectionBufferLimitBytes,proto3" json:"perConnectionBufferLimitBytes,omitempty"`
	// contains filtered or unexported fields
}

type MulticlusterCaCertificateClient interface {
	// Cluster returns a CaCertificateClient for the given cluster
	Cluster(cluster string) (CaCertificateClient, error)
}

type MulticlusterCertificateClient interface {
	// Cluster returns a CertificateClient for the given cluster
	Cluster(cluster string) (CertificateClient, error)
}

type MulticlusterClientset interface {
	// Cluster returns a Clientset for the given cluster
	Cluster(cluster string) (Clientset, error)
}

type MulticlusterFilterClient interface {
	// Cluster returns a FilterClient for the given cluster
	Cluster(cluster string) (FilterClient, error)
}

type MulticlusterGatewayClient interface {
	// Cluster returns a GatewayClient for the given cluster
	Cluster(cluster string) (GatewayClient, error)
}

type MulticlusterUpstreamClient interface {
	// Cluster returns a UpstreamClient for the given cluster
	Cluster(cluster string) (UpstreamClient, error)
}

type RedirectAction struct {
	HostRedirect  string `protobuf:"bytes,1,opt,name=host_redirect,json=hostRedirect,proto3" json:"host_redirect,omitempty"`
	ResponseCode  uint32 `protobuf:"varint,2,opt,name=response_code,json=responseCode,proto3" json:"response_code,omitempty"`
	HttpsRedirect bool   `protobuf:"varint,3,opt,name=https_redirect,json=httpsRedirect,proto3" json:"https_redirect,omitempty"`
	StripQuery    bool   `protobuf:"varint,4,opt,name=strip_query,json=stripQuery,proto3" json:"strip_query,omitempty"`
	PortRedirect  uint32 `protobuf:"varint,5,opt,name=port_redirect,json=portRedirect,proto3" json:"port_redirect,omitempty"`
	// contains filtered or unexported fields
}

type Route struct {
	Id   uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to RouteActionType:
	//
	//	*Route_ForwardAction
	//	*Route_RedirectAction
	//	*Route_DirectionAction
	RouteActionType    isRoute_RouteActionType `protobuf_oneof:"route_action_type"`
	Match              *RouteMatch             `protobuf:"bytes,6,opt,name=match,proto3" json:"match,omitempty"`
	HeaderManipulation *v1.HeaderManipulation  `protobuf:"bytes,7,opt,name=header_manipulation,json=headerManipulation,proto3" json:"header_manipulation,omitempty"`
	// contains filtered or unexported fields
}

type RouteConfig struct {
	Name               string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	VhostLs            []*VHost               `protobuf:"bytes,2,rep,name=vhost_ls,json=vhostLs,proto3" json:"vhost_ls,omitempty"`
	HeaderManipulation *v1.HeaderManipulation `protobuf:"bytes,3,opt,name=header_manipulation,json=headerManipulation,proto3" json:"header_manipulation,omitempty"`
	// contains filtered or unexported fields
}

type RouteMatch struct {

	// :path  prefix
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// :path exact
	Path    string         `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Regex   string         `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	Headers []*HeaderMatch `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

type Route_DirectionAction struct {
	DirectionAction *DirectionAction `protobuf:"bytes,5,opt,name=direction_action,json=directionAction,proto3,oneof"`
}

type Route_ForwardAction struct {
	ForwardAction *ForwardAction `protobuf:"bytes,3,opt,name=forward_action,json=forwardAction,proto3,oneof"`
}

type Route_RedirectAction struct {
	RedirectAction *RedirectAction `protobuf:"bytes,4,opt,name=redirect_action,json=redirectAction,proto3,oneof"`
}

type SslCertificateSpec struct {
	CommonInfo       *v1.CommonInfo   `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	CertificateInfo  *v11.Certificate `protobuf:"bytes,2,opt,name=certificateInfo,proto3" json:"certificateInfo,omitempty"`
	CertificateChain string           `protobuf:"bytes,3,opt,name=certificateChain,proto3" json:"certificateChain,omitempty"`
	PrivateKey       string           `protobuf:"bytes,4,opt,name=privateKey,proto3" json:"privateKey,omitempty"`
	// The password to decrypt the TLS private key. If this field is not set, it is assumed that the TLS private key is not password encrypted.
	Password      string             `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	TlsParameters *v11.TlsParameters `protobuf:"bytes,6,opt,name=tlsParameters,proto3" json:"tlsParameters,omitempty"`
	// Set Application Level Protocol Negotiation
	// If empty, defaults to ["h2", "http/1.1"].
	AlpnProtocols []string `protobuf:"bytes,7,rep,name=alpnProtocols,proto3" json:"alpnProtocols,omitempty"`
	// contains filtered or unexported fields
}

type TcpHealthCheck struct {
	SendPayload    string   `protobuf:"bytes,1,opt,name=sendPayload,proto3" json:"sendPayload,omitempty"`
	ReceivePayload []string `protobuf:"bytes,2,rep,name=receivePayload,proto3" json:"receivePayload,omitempty"`
	// contains filtered or unexported fields
}

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

type Upstream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec UpstreamSpec `json:"spec,omitempty"`
}

type UpstreamClient interface {
	UpstreamReader
	UpstreamWriter
	UpstreamStatusWriter
}

type UpstreamList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Upstream `json:"items"`
}

type UpstreamReader interface {
	// Get retrieves a Upstream for the given object key
	GetUpstream(ctx context.Context, key client.ObjectKey) (*Upstream, error)

	// List retrieves list of Upstreams for a given namespace and list options.
	ListUpstream(ctx context.Context, opts ...client.ListOption) (*UpstreamList, error)
}

type UpstreamSlice []*Upstream

type UpstreamSpec struct {
	CommonInfo        *v1.CommonInfo        `protobuf:"bytes,1,opt,name=commonInfo,proto3" json:"commonInfo,omitempty"`
	LbAlg             UpstreamSpec_LbPolicy `protobuf:"varint,2,opt,name=lbAlg,proto3,enum=gate.xdmybl.io.UpstreamSpec_LbPolicy" json:"lbAlg,omitempty"`
	SslConfigurations *v11.TlsClient        `protobuf:"bytes,3,opt,name=sslConfigurations,proto3" json:"sslConfigurations,omitempty"`
	ConnPoll          *ConnPoll             `protobuf:"bytes,4,opt,name=connPoll,proto3" json:"connPoll,omitempty"`
	// health check interval
	HcInterval uint32 `protobuf:"varint,5,opt,name=hcInterval,proto3" json:"hcInterval,omitempty"`
	HcTimeout  uint32 `protobuf:"varint,6,opt,name=hcTimeout,proto3" json:"hcTimeout,omitempty"`
	// hc 健康阈值
	HcHealthyThreshold   uint32                `protobuf:"varint,7,opt,name=hcHealthyThreshold,proto3" json:"hcHealthyThreshold,omitempty"`
	HcUnhealthyThreshold uint32                `protobuf:"varint,8,opt,name=hcUnhealthyThreshold,proto3" json:"hcUnhealthyThreshold,omitempty"`
	HcSpecifier          *HealthCheckSpecifier `protobuf:"bytes,9,opt,name=hcSpecifier,proto3" json:"hcSpecifier,omitempty"`
	StatefulSession      *v1.StatefulSession   `protobuf:"bytes,10,opt,name=statefulSession,proto3" json:"statefulSession,omitempty"`
	Endpoints            []*v1.Endpoint        `protobuf:"bytes,11,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

type UpstreamSpec_LbPolicy int32

type UpstreamStatusWriter interface {
	// Update updates the fields corresponding to the status subresource for the
	// given Upstream object.
	UpdateUpstreamStatus(ctx context.Context, obj *Upstream, opts ...client.UpdateOption) error

	// Patch patches the given Upstream object's subresource.
	PatchUpstreamStatus(ctx context.Context, obj *Upstream, patch client.Patch, opts ...client.PatchOption) error
}

type UpstreamTransitionFunction func(existing, desired *Upstream) error

type UpstreamWriter interface {
	// Create saves the Upstream object.
	CreateUpstream(ctx context.Context, obj *Upstream, opts ...client.CreateOption) error

	// Delete deletes the Upstream object.
	DeleteUpstream(ctx context.Context, key client.ObjectKey, opts ...client.DeleteOption) error

	// Update updates the given Upstream object.
	UpdateUpstream(ctx context.Context, obj *Upstream, opts ...client.UpdateOption) error

	// Patch patches the given Upstream object.
	PatchUpstream(ctx context.Context, obj *Upstream, patch client.Patch, opts ...client.PatchOption) error

	// DeleteAllOf deletes all Upstream objects matching the given options.
	DeleteAllOfUpstream(ctx context.Context, opts ...client.DeleteAllOfOption) error

	// Create or Update the Upstream object.
	UpsertUpstream(ctx context.Context, obj *Upstream, transitionFuncs ...UpstreamTransitionFunction) error
}

type VHost struct {
	RouteLs []*Route `protobuf:"bytes,1,rep,name=route_ls,json=routeLs,proto3" json:"route_ls,omitempty"`
	Domains []string `protobuf:"bytes,2,rep,name=domains,proto3" json:"domains,omitempty"`
	// contains filtered or unexported fields
}

type WeightCluster struct {
	ClusterName []string `protobuf:"bytes,1,rep,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	TotalWeight uint32   `protobuf:"varint,2,opt,name=total_weight,json=totalWeight,proto3" json:"total_weight,omitempty"`
	// contains filtered or unexported fields
}

type WeightedUpstreamList struct {
	Weight             uint32                 `protobuf:"varint,1,opt,name=weight,proto3" json:"weight,omitempty"`
	UpstreamRef        *v1.ResourceRef        `protobuf:"bytes,2,opt,name=upstreamRef,proto3" json:"upstreamRef,omitempty"`
	HeaderManipulation *v1.HeaderManipulation `protobuf:"bytes,3,opt,name=headerManipulation,proto3" json:"headerManipulation,omitempty"`
	// contains filtered or unexported fields
}