meshv1alpha1

package
v0.16.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 29, 2024 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BalanceInboundConnections_name = map[int32]string{
		0: "BALANCE_INBOUND_CONNECTIONS_DEFAULT",
		1: "BALANCE_INBOUND_CONNECTIONS_EXACT",
	}
	BalanceInboundConnections_value = map[string]int32{
		"BALANCE_INBOUND_CONNECTIONS_DEFAULT": 0,
		"BALANCE_INBOUND_CONNECTIONS_EXACT":   1,
	}
)

Enum value maps for BalanceInboundConnections.

View Source 
var (
	ProxyMode_name = map[int32]string{
		0: "PROXY_MODE_DEFAULT",
		1: "PROXY_MODE_TRANSPARENT",
		2: "PROXY_MODE_DIRECT",
	}
	ProxyMode_value = map[string]int32{
		"PROXY_MODE_DEFAULT":     0,
		"PROXY_MODE_TRANSPARENT": 1,
		"PROXY_MODE_DIRECT":      2,
	}
)

Enum value maps for ProxyMode.

View Source 
var (
	MeshGatewayMode_name = map[int32]string{
		0: "MESH_GATEWAY_MODE_UNSPECIFIED",
		1: "MESH_GATEWAY_MODE_NONE",
		2: "MESH_GATEWAY_MODE_LOCAL",
		3: "MESH_GATEWAY_MODE_REMOTE",
	}
	MeshGatewayMode_value = map[string]int32{
		"MESH_GATEWAY_MODE_UNSPECIFIED": 0,
		"MESH_GATEWAY_MODE_NONE":        1,
		"MESH_GATEWAY_MODE_LOCAL":       2,
		"MESH_GATEWAY_MODE_REMOTE":      3,
	}
)

Enum value maps for MeshGatewayMode.

View Source 
var File_pbmesh_v1alpha1_connection_proto protoreflect.FileDescriptor
View Source 
var File_pbmesh_v1alpha1_expose_proto protoreflect.FileDescriptor
View Source 
var File_pbmesh_v1alpha1_proxy_proto protoreflect.FileDescriptor
View Source 
var File_pbmesh_v1alpha1_routing_proto protoreflect.FileDescriptor
View Source 
var File_pbmesh_v1alpha1_upstreams_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BalanceInboundConnections 

type BalanceInboundConnections int32
const (
	// buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX
	BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_DEFAULT BalanceInboundConnections = 0
	BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_EXACT   BalanceInboundConnections = 1
)

func (BalanceInboundConnections) Descriptor 

func (BalanceInboundConnections) Descriptor() protoreflect.EnumDescriptor

func (BalanceInboundConnections) Enum 

func (x BalanceInboundConnections) Enum() *BalanceInboundConnections

func (BalanceInboundConnections) EnumDescriptor deprecated 

func (BalanceInboundConnections) EnumDescriptor() ([]byte, []int)

Deprecated: Use BalanceInboundConnections.Descriptor instead.

func (BalanceInboundConnections) Number 

func (x BalanceInboundConnections) Number() protoreflect.EnumNumber

func (BalanceInboundConnections) String 

func (x BalanceInboundConnections) String() string

func (BalanceInboundConnections) Type 

func (BalanceInboundConnections) Type() protoreflect.EnumType

type BootstrapConfig 

type BootstrapConfig struct {
	StatsdUrl           string   `protobuf:"bytes,1,opt,name=statsd_url,json=statsdUrl,proto3" json:"statsd_url,omitempty"`
	DogstatsdUrl        string   `protobuf:"bytes,2,opt,name=dogstatsd_url,json=dogstatsdUrl,proto3" json:"dogstatsd_url,omitempty"`
	StatsTags           []string `protobuf:"bytes,3,rep,name=stats_tags,json=statsTags,proto3" json:"stats_tags,omitempty"`
	PrometheusBindAddr  string   `protobuf:"bytes,4,opt,name=prometheus_bind_addr,json=prometheusBindAddr,proto3" json:"prometheus_bind_addr,omitempty"`
	StatsBindAddr       string   `protobuf:"bytes,5,opt,name=stats_bind_addr,json=statsBindAddr,proto3" json:"stats_bind_addr,omitempty"`
	ReadyBindAddr       string   `protobuf:"bytes,6,opt,name=ready_bind_addr,json=readyBindAddr,proto3" json:"ready_bind_addr,omitempty"`
	OverrideJsonTpl     string   `protobuf:"bytes,7,opt,name=override_json_tpl,json=overrideJsonTpl,proto3" json:"override_json_tpl,omitempty"`
	StaticClustersJson  string   `protobuf:"bytes,8,opt,name=static_clusters_json,json=staticClustersJson,proto3" json:"static_clusters_json,omitempty"`
	StaticListenersJson string   `protobuf:"bytes,9,opt,name=static_listeners_json,json=staticListenersJson,proto3" json:"static_listeners_json,omitempty"`
	StatsSinksJson      string   `protobuf:"bytes,10,opt,name=stats_sinks_json,json=statsSinksJson,proto3" json:"stats_sinks_json,omitempty"`
	StatsConfigJson     string   `protobuf:"bytes,11,opt,name=stats_config_json,json=statsConfigJson,proto3" json:"stats_config_json,omitempty"`
	StatsFlushInterval  string   `protobuf:"bytes,12,opt,name=stats_flush_interval,json=statsFlushInterval,proto3" json:"stats_flush_interval,omitempty"`
	TracingConfigJson   string   `protobuf:"bytes,13,opt,name=tracing_config_json,json=tracingConfigJson,proto3" json:"tracing_config_json,omitempty"`
	// contains filtered or unexported fields
}

BootstrapConfig is equivalent to configuration defined in our docs.

func (*BootstrapConfig) Descriptor deprecated 

func (*BootstrapConfig) Descriptor() ([]byte, []int)

Deprecated: Use BootstrapConfig.ProtoReflect.Descriptor instead.

func (*BootstrapConfig) GetDogstatsdUrl 

func (x *BootstrapConfig) GetDogstatsdUrl() string

func (*BootstrapConfig) GetOverrideJsonTpl 

func (x *BootstrapConfig) GetOverrideJsonTpl() string

func (*BootstrapConfig) GetPrometheusBindAddr 

func (x *BootstrapConfig) GetPrometheusBindAddr() string

func (*BootstrapConfig) GetReadyBindAddr 

func (x *BootstrapConfig) GetReadyBindAddr() string

func (*BootstrapConfig) GetStaticClustersJson 

func (x *BootstrapConfig) GetStaticClustersJson() string

func (*BootstrapConfig) GetStaticListenersJson 

func (x *BootstrapConfig) GetStaticListenersJson() string

func (*BootstrapConfig) GetStatsBindAddr 

func (x *BootstrapConfig) GetStatsBindAddr() string

func (*BootstrapConfig) GetStatsConfigJson 

func (x *BootstrapConfig) GetStatsConfigJson() string

func (*BootstrapConfig) GetStatsFlushInterval 

func (x *BootstrapConfig) GetStatsFlushInterval() string

func (*BootstrapConfig) GetStatsSinksJson 

func (x *BootstrapConfig) GetStatsSinksJson() string

func (*BootstrapConfig) GetStatsTags 

func (x *BootstrapConfig) GetStatsTags() []string

func (*BootstrapConfig) GetStatsdUrl 

func (x *BootstrapConfig) GetStatsdUrl() string

func (*BootstrapConfig) GetTracingConfigJson 

func (x *BootstrapConfig) GetTracingConfigJson() string

func (*BootstrapConfig) MarshalBinary 

func (msg *BootstrapConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*BootstrapConfig) ProtoMessage 

func (*BootstrapConfig) ProtoMessage()

func (*BootstrapConfig) ProtoReflect 

func (x *BootstrapConfig) ProtoReflect() protoreflect.Message

func (*BootstrapConfig) Reset 

func (x *BootstrapConfig) Reset()

func (*BootstrapConfig) String 

func (x *BootstrapConfig) String() string

func (*BootstrapConfig) UnmarshalBinary 

func (msg *BootstrapConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ConnectionConfig 

type ConnectionConfig struct {
	ConnectTimeoutMs uint64 `protobuf:"varint,2,opt,name=connect_timeout_ms,json=connectTimeoutMs,proto3" json:"connect_timeout_ms,omitempty"`
	RequestTimeoutMs uint64 `protobuf:"varint,3,opt,name=request_timeout_ms,json=requestTimeoutMs,proto3" json:"request_timeout_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionConfig) Descriptor deprecated 

func (*ConnectionConfig) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.

func (*ConnectionConfig) GetConnectTimeoutMs 

func (x *ConnectionConfig) GetConnectTimeoutMs() uint64

func (*ConnectionConfig) GetRequestTimeoutMs 

func (x *ConnectionConfig) GetRequestTimeoutMs() uint64

func (*ConnectionConfig) MarshalBinary 

func (msg *ConnectionConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ConnectionConfig) ProtoMessage 

func (*ConnectionConfig) ProtoMessage()

func (*ConnectionConfig) ProtoReflect 

func (x *ConnectionConfig) ProtoReflect() protoreflect.Message

func (*ConnectionConfig) Reset 

func (x *ConnectionConfig) Reset()

func (*ConnectionConfig) String 

func (x *ConnectionConfig) String() string

func (*ConnectionConfig) UnmarshalBinary 

func (msg *ConnectionConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type DynamicConfig 

type DynamicConfig struct {

	// mode indicates the proxy's mode. This will default to 'transparent'.
	Mode             ProxyMode         `protobuf:"varint,1,opt,name=mode,proto3,enum=hashicorp.consul.mesh.v1alpha1.ProxyMode" json:"mode,omitempty"`
	TransparentProxy *TransparentProxy `protobuf:"bytes,2,opt,name=transparent_proxy,json=transparentProxy,proto3" json:"transparent_proxy,omitempty"`
	// local_connection is the configuration that should be used
	// to connect to the local application provided per-port.
	// The map keys should correspond to port names on the workload.
	LocalConnection map[string]*ConnectionConfig `` /* 194-byte string literal not displayed */
	// inbound_connections configures inbound connections to the proxy.
	InboundConnections  *InboundConnectionsConfig `protobuf:"bytes,4,opt,name=inbound_connections,json=inboundConnections,proto3" json:"inbound_connections,omitempty"`
	MeshGatewayMode     MeshGatewayMode           `` /* 161-byte string literal not displayed */
	ExposeConfig        *ExposeConfig             `protobuf:"bytes,6,opt,name=expose_config,json=exposeConfig,proto3" json:"expose_config,omitempty"`
	PublicListenerJson  string                    `protobuf:"bytes,7,opt,name=public_listener_json,json=publicListenerJson,proto3" json:"public_listener_json,omitempty"`
	ListenerTracingJson string                    `protobuf:"bytes,8,opt,name=listener_tracing_json,json=listenerTracingJson,proto3" json:"listener_tracing_json,omitempty"`
	LocalClusterJson    string                    `protobuf:"bytes,9,opt,name=local_cluster_json,json=localClusterJson,proto3" json:"local_cluster_json,omitempty"`
	// deprecated:
	// local_workload_address, local_workload_port, and local_workload_socket_path
	// are deprecated and are only needed for migration of existing resources.
	//
	// Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
	LocalWorkloadAddress string `protobuf:"bytes,10,opt,name=local_workload_address,json=localWorkloadAddress,proto3" json:"local_workload_address,omitempty"`
	// Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
	LocalWorkloadPort uint32 `protobuf:"varint,11,opt,name=local_workload_port,json=localWorkloadPort,proto3" json:"local_workload_port,omitempty"`
	// Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
	LocalWorkloadSocketPath string `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DynamicConfig) Descriptor deprecated 

func (*DynamicConfig) Descriptor() ([]byte, []int)

Deprecated: Use DynamicConfig.ProtoReflect.Descriptor instead.

func (*DynamicConfig) GetExposeConfig 

func (x *DynamicConfig) GetExposeConfig() *ExposeConfig

func (*DynamicConfig) GetInboundConnections 

func (x *DynamicConfig) GetInboundConnections() *InboundConnectionsConfig

func (*DynamicConfig) GetListenerTracingJson 

func (x *DynamicConfig) GetListenerTracingJson() string

func (*DynamicConfig) GetLocalClusterJson 

func (x *DynamicConfig) GetLocalClusterJson() string

func (*DynamicConfig) GetLocalConnection 

func (x *DynamicConfig) GetLocalConnection() map[string]*ConnectionConfig

func (*DynamicConfig) GetLocalWorkloadAddress deprecated 

func (x *DynamicConfig) GetLocalWorkloadAddress() string

Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.

func (*DynamicConfig) GetLocalWorkloadPort deprecated 

func (x *DynamicConfig) GetLocalWorkloadPort() uint32

Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.

func (*DynamicConfig) GetLocalWorkloadSocketPath deprecated 

func (x *DynamicConfig) GetLocalWorkloadSocketPath() string

Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.

func (*DynamicConfig) GetMeshGatewayMode 

func (x *DynamicConfig) GetMeshGatewayMode() MeshGatewayMode

func (*DynamicConfig) GetMode 

func (x *DynamicConfig) GetMode() ProxyMode

func (*DynamicConfig) GetPublicListenerJson 

func (x *DynamicConfig) GetPublicListenerJson() string

func (*DynamicConfig) GetTransparentProxy 

func (x *DynamicConfig) GetTransparentProxy() *TransparentProxy

func (*DynamicConfig) MarshalBinary 

func (msg *DynamicConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*DynamicConfig) ProtoMessage 

func (*DynamicConfig) ProtoMessage()

func (*DynamicConfig) ProtoReflect 

func (x *DynamicConfig) ProtoReflect() protoreflect.Message

func (*DynamicConfig) Reset 

func (x *DynamicConfig) Reset()

func (*DynamicConfig) String 

func (x *DynamicConfig) String() string

func (*DynamicConfig) UnmarshalBinary 

func (msg *DynamicConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ExposeConfig 

type ExposeConfig struct {
	ExposePaths []*ExposePath `protobuf:"bytes,1,rep,name=expose_paths,json=exposePaths,proto3" json:"expose_paths,omitempty"`
	// contains filtered or unexported fields
}

func (*ExposeConfig) Descriptor deprecated 

func (*ExposeConfig) Descriptor() ([]byte, []int)

Deprecated: Use ExposeConfig.ProtoReflect.Descriptor instead.

func (*ExposeConfig) GetExposePaths 

func (x *ExposeConfig) GetExposePaths() []*ExposePath

func (*ExposeConfig) MarshalBinary 

func (msg *ExposeConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ExposeConfig) ProtoMessage 

func (*ExposeConfig) ProtoMessage()

func (*ExposeConfig) ProtoReflect 

func (x *ExposeConfig) ProtoReflect() protoreflect.Message

func (*ExposeConfig) Reset 

func (x *ExposeConfig) Reset()

func (*ExposeConfig) String 

func (x *ExposeConfig) String() string

func (*ExposeConfig) UnmarshalBinary 

func (msg *ExposeConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ExposePath 

type ExposePath struct {
	ListenerPort  uint32            `protobuf:"varint,1,opt,name=listener_port,json=listenerPort,proto3" json:"listener_port,omitempty"`
	Path          string            `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	LocalPathPort uint32            `protobuf:"varint,3,opt,name=local_path_port,json=localPathPort,proto3" json:"local_path_port,omitempty"`
	Protocol      v1alpha1.Protocol `protobuf:"varint,4,opt,name=protocol,proto3,enum=hashicorp.consul.catalog.v1alpha1.Protocol" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*ExposePath) Descriptor deprecated 

func (*ExposePath) Descriptor() ([]byte, []int)

Deprecated: Use ExposePath.ProtoReflect.Descriptor instead.

func (*ExposePath) GetListenerPort 

func (x *ExposePath) GetListenerPort() uint32

func (*ExposePath) GetLocalPathPort 

func (x *ExposePath) GetLocalPathPort() uint32

func (*ExposePath) GetPath 

func (x *ExposePath) GetPath() string

func (*ExposePath) GetProtocol 

func (x *ExposePath) GetProtocol() v1alpha1.Protocol

func (*ExposePath) MarshalBinary 

func (msg *ExposePath) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ExposePath) ProtoMessage 

func (*ExposePath) ProtoMessage()

func (*ExposePath) ProtoReflect 

func (x *ExposePath) ProtoReflect() protoreflect.Message

func (*ExposePath) Reset 

func (x *ExposePath) Reset()

func (*ExposePath) String 

func (x *ExposePath) String() string

func (*ExposePath) UnmarshalBinary 

func (msg *ExposePath) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type InboundConnectionsConfig 

type InboundConnectionsConfig struct {
	MaxInboundConnections     uint64                    `` /* 128-byte string literal not displayed */
	BalanceInboundConnections BalanceInboundConnections `` /* 202-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InboundConnectionsConfig) Descriptor deprecated 

func (*InboundConnectionsConfig) Descriptor() ([]byte, []int)

Deprecated: Use InboundConnectionsConfig.ProtoReflect.Descriptor instead.

func (*InboundConnectionsConfig) GetBalanceInboundConnections 

func (x *InboundConnectionsConfig) GetBalanceInboundConnections() BalanceInboundConnections

func (*InboundConnectionsConfig) GetMaxInboundConnections 

func (x *InboundConnectionsConfig) GetMaxInboundConnections() uint64

func (*InboundConnectionsConfig) MarshalBinary 

func (msg *InboundConnectionsConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*InboundConnectionsConfig) ProtoMessage 

func (*InboundConnectionsConfig) ProtoMessage()

func (*InboundConnectionsConfig) ProtoReflect 

func (x *InboundConnectionsConfig) ProtoReflect() protoreflect.Message

func (*InboundConnectionsConfig) Reset 

func (x *InboundConnectionsConfig) Reset()

func (*InboundConnectionsConfig) String 

func (x *InboundConnectionsConfig) String() string

func (*InboundConnectionsConfig) UnmarshalBinary 

func (msg *InboundConnectionsConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type MeshGatewayMode 

type MeshGatewayMode int32
const (
	// MESH_GATEWAY_MODE_UNSPECIFIED represents no specific mode and should be
	// used to indicate that a the decision on the mode will be made by other
	// configuration or default settings.
	MeshGatewayMode_MESH_GATEWAY_MODE_UNSPECIFIED MeshGatewayMode = 0
	// MESH_GATEWAY_MODE_NONE is the mode to use when traffic should not be
	// routed through any gateway but instead be routed directly to the
	// destination.
	MeshGatewayMode_MESH_GATEWAY_MODE_NONE MeshGatewayMode = 1
	// MESH_GATEWAY_MODE_LOCAL is the mode to use when traffic should be routed
	// to the local gateway. The local gateway will then ensure that the
	// connection is proxied correctly to its final destination. This mode will
	// most often be needed for workloads that are prevented from making outbound
	// requests outside of their local network/environment. In this case a
	// gateway will sit at the edge of sit at the edge of the network and will
	// proxy outbound connections potentially to other gateways in remote
	// environments.
	MeshGatewayMode_MESH_GATEWAY_MODE_LOCAL MeshGatewayMode = 2
	// MESH_GATEWAY_MODE_REMOTE is the mode to use when traffic should be routed
	// to a remote mesh gateway. This mode will most often be used when workloads
	// can make outbound requests destined for a remote network/environment but
	// where the remote network/environment will not allow direct addressing. The
	// mesh gateway in the remote environment will sit at the edge and proxy
	// requests into that environment.
	MeshGatewayMode_MESH_GATEWAY_MODE_REMOTE MeshGatewayMode = 3
)

func (MeshGatewayMode) Descriptor 

func (MeshGatewayMode) Descriptor() protoreflect.EnumDescriptor

func (MeshGatewayMode) Enum 

func (x MeshGatewayMode) Enum() *MeshGatewayMode

func (MeshGatewayMode) EnumDescriptor deprecated 

func (MeshGatewayMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use MeshGatewayMode.Descriptor instead.

func (MeshGatewayMode) Number 

func (x MeshGatewayMode) Number() protoreflect.EnumNumber

func (MeshGatewayMode) String 

func (x MeshGatewayMode) String() string

func (MeshGatewayMode) Type 

func (MeshGatewayMode) Type() protoreflect.EnumType

type PassiveHealthCheck 

type PassiveHealthCheck struct {

	// Interval between health check analysis sweeps. Each sweep may remove
	// hosts or return hosts to the pool.
	Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// MaxFailures is the count of consecutive failures that results in a host
	// being removed from the pool.
	MaxFailures uint32 `protobuf:"varint,2,opt,name=max_failures,json=maxFailures,proto3" json:"max_failures,omitempty"`
	// EnforcingConsecutive5xx is the % chance that a host will be actually ejected
	// when an outlier status is detected through consecutive 5xx.
	// This setting can be used to disable ejection or to ramp it up slowly. Defaults to 100.
	EnforcingConsecutive_5Xx uint32 `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PassiveHealthCheck) Descriptor deprecated 

func (*PassiveHealthCheck) Descriptor() ([]byte, []int)

Deprecated: Use PassiveHealthCheck.ProtoReflect.Descriptor instead.

func (*PassiveHealthCheck) GetEnforcingConsecutive_5Xx 

func (x *PassiveHealthCheck) GetEnforcingConsecutive_5Xx() uint32

func (*PassiveHealthCheck) GetInterval 

func (x *PassiveHealthCheck) GetInterval() *durationpb.Duration

func (*PassiveHealthCheck) GetMaxFailures 

func (x *PassiveHealthCheck) GetMaxFailures() uint32

func (*PassiveHealthCheck) MarshalBinary 

func (msg *PassiveHealthCheck) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*PassiveHealthCheck) ProtoMessage 

func (*PassiveHealthCheck) ProtoMessage()

func (*PassiveHealthCheck) ProtoReflect 

func (x *PassiveHealthCheck) ProtoReflect() protoreflect.Message

func (*PassiveHealthCheck) Reset 

func (x *PassiveHealthCheck) Reset()

func (*PassiveHealthCheck) String 

func (x *PassiveHealthCheck) String() string

func (*PassiveHealthCheck) UnmarshalBinary 

func (msg *PassiveHealthCheck) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PreparedQueryUpstream 

type PreparedQueryUpstream struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Datacenter string `protobuf:"bytes,2,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	// Types that are assignable to ListenAddr:
	//
	//	*PreparedQueryUpstream_Tcp
	//	*PreparedQueryUpstream_Unix
	ListenAddr     isPreparedQueryUpstream_ListenAddr `protobuf_oneof:"listen_addr"`
	UpstreamConfig *UpstreamConfig                    `protobuf:"bytes,6,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"`
	// contains filtered or unexported fields
}

func (*PreparedQueryUpstream) Descriptor deprecated 

func (*PreparedQueryUpstream) Descriptor() ([]byte, []int)

Deprecated: Use PreparedQueryUpstream.ProtoReflect.Descriptor instead.

func (*PreparedQueryUpstream) GetDatacenter 

func (x *PreparedQueryUpstream) GetDatacenter() string

func (*PreparedQueryUpstream) GetListenAddr 

func (m *PreparedQueryUpstream) GetListenAddr() isPreparedQueryUpstream_ListenAddr

func (*PreparedQueryUpstream) GetName 

func (x *PreparedQueryUpstream) GetName() string

func (*PreparedQueryUpstream) GetTcp 

func (x *PreparedQueryUpstream) GetTcp() *TCPAddress

func (*PreparedQueryUpstream) GetUnix 

func (x *PreparedQueryUpstream) GetUnix() *UnixSocketAddress

func (*PreparedQueryUpstream) GetUpstreamConfig 

func (x *PreparedQueryUpstream) GetUpstreamConfig() *UpstreamConfig

func (*PreparedQueryUpstream) MarshalBinary 

func (msg *PreparedQueryUpstream) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*PreparedQueryUpstream) ProtoMessage 

func (*PreparedQueryUpstream) ProtoMessage()

func (*PreparedQueryUpstream) ProtoReflect 

func (x *PreparedQueryUpstream) ProtoReflect() protoreflect.Message

func (*PreparedQueryUpstream) Reset 

func (x *PreparedQueryUpstream) Reset()

func (*PreparedQueryUpstream) String 

func (x *PreparedQueryUpstream) String() string

func (*PreparedQueryUpstream) UnmarshalBinary 

func (msg *PreparedQueryUpstream) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type PreparedQueryUpstream_Tcp 

type PreparedQueryUpstream_Tcp struct {
	Tcp *TCPAddress `protobuf:"bytes,4,opt,name=tcp,proto3,oneof"`
}

type PreparedQueryUpstream_Unix 

type PreparedQueryUpstream_Unix struct {
	Unix *UnixSocketAddress `protobuf:"bytes,5,opt,name=unix,proto3,oneof"`
}

type ProxyConfiguration 

type ProxyConfiguration struct {

	// Selection of workloads this proxy configuration should apply to.
	// These can be prefixes or specific workload names.
	Workloads *v1alpha1.WorkloadSelector `protobuf:"bytes,1,opt,name=workloads,proto3" json:"workloads,omitempty"`
	// dynamic_config is the configuration that could be changed
	// dynamically (i.e. without needing restart).
	DynamicConfig *DynamicConfig `protobuf:"bytes,2,opt,name=dynamic_config,json=dynamicConfig,proto3" json:"dynamic_config,omitempty"`
	// bootstrap_config is the configuration that requires proxies
	// to be restarted to be applied.
	BootstrapConfig *BootstrapConfig `protobuf:"bytes,3,opt,name=bootstrap_config,json=bootstrapConfig,proto3" json:"bootstrap_config,omitempty"`
	// deprecated: prevent usage when using v2 APIs directly.
	// needed for backwards compatibility
	//
	// Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
	OpaqueConfig *structpb.Struct `protobuf:"bytes,4,opt,name=opaque_config,json=opaqueConfig,proto3" json:"opaque_config,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyConfiguration) Descriptor deprecated 

func (*ProxyConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use ProxyConfiguration.ProtoReflect.Descriptor instead.

func (*ProxyConfiguration) GetBootstrapConfig 

func (x *ProxyConfiguration) GetBootstrapConfig() *BootstrapConfig

func (*ProxyConfiguration) GetDynamicConfig 

func (x *ProxyConfiguration) GetDynamicConfig() *DynamicConfig

func (*ProxyConfiguration) GetOpaqueConfig deprecated 

func (x *ProxyConfiguration) GetOpaqueConfig() *structpb.Struct

Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.

func (*ProxyConfiguration) GetWorkloads 

func (x *ProxyConfiguration) GetWorkloads() *v1alpha1.WorkloadSelector

func (*ProxyConfiguration) MarshalBinary 

func (msg *ProxyConfiguration) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*ProxyConfiguration) ProtoMessage 

func (*ProxyConfiguration) ProtoMessage()

func (*ProxyConfiguration) ProtoReflect 

func (x *ProxyConfiguration) ProtoReflect() protoreflect.Message

func (*ProxyConfiguration) Reset 

func (x *ProxyConfiguration) Reset()

func (*ProxyConfiguration) String 

func (x *ProxyConfiguration) String() string

func (*ProxyConfiguration) UnmarshalBinary 

func (msg *ProxyConfiguration) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type ProxyMode 

type ProxyMode int32
const (
	// ProxyModeDefault represents no specific mode and should
	// be used to indicate that a different layer of the configuration
	// chain should take precedence
	// buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX
	ProxyMode_PROXY_MODE_DEFAULT ProxyMode = 0
	// ProxyModeTransparent represents that inbound and outbound application
	// traffic is being captured and redirected through the proxy.
	ProxyMode_PROXY_MODE_TRANSPARENT ProxyMode = 1
	// ProxyModeDirect represents that the proxy's listeners must be dialed directly
	// by the local application and other proxies.
	ProxyMode_PROXY_MODE_DIRECT ProxyMode = 2
)

func (ProxyMode) Descriptor 

func (ProxyMode) Descriptor() protoreflect.EnumDescriptor

func (ProxyMode) Enum 

func (x ProxyMode) Enum() *ProxyMode

func (ProxyMode) EnumDescriptor deprecated 

func (ProxyMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ProxyMode.Descriptor instead.

func (ProxyMode) Number 

func (x ProxyMode) Number() protoreflect.EnumNumber

func (ProxyMode) String 

func (x ProxyMode) String() string

func (ProxyMode) Type 

func (ProxyMode) Type() protoreflect.EnumType

type TCPAddress 

type TCPAddress struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*TCPAddress) Descriptor deprecated 

func (*TCPAddress) Descriptor() ([]byte, []int)

Deprecated: Use TCPAddress.ProtoReflect.Descriptor instead.

func (*TCPAddress) GetIp 

func (x *TCPAddress) GetIp() string

func (*TCPAddress) GetPort 

func (x *TCPAddress) GetPort() uint32

func (*TCPAddress) MarshalBinary 

func (msg *TCPAddress) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*TCPAddress) ProtoMessage 

func (*TCPAddress) ProtoMessage()

func (*TCPAddress) ProtoReflect 

func (x *TCPAddress) ProtoReflect() protoreflect.Message

func (*TCPAddress) Reset 

func (x *TCPAddress) Reset()

func (*TCPAddress) String 

func (x *TCPAddress) String() string

func (*TCPAddress) UnmarshalBinary 

func (msg *TCPAddress) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type TransparentProxy 

type TransparentProxy struct {

	// outbound_listener_port is the port for the proxy's outbound listener.
	// This defaults to 15001.
	OutboundListenerPort uint32 `protobuf:"varint,1,opt,name=outbound_listener_port,json=outboundListenerPort,proto3" json:"outbound_listener_port,omitempty"`
	// dialed_directly indicates whether this proxy should be dialed using original destination IP
	// in the connection rather than load balance between all endpoints.
	DialedDirectly bool `protobuf:"varint,2,opt,name=dialed_directly,json=dialedDirectly,proto3" json:"dialed_directly,omitempty"`
	// contains filtered or unexported fields
}

func (*TransparentProxy) Descriptor deprecated 

func (*TransparentProxy) Descriptor() ([]byte, []int)

Deprecated: Use TransparentProxy.ProtoReflect.Descriptor instead.

func (*TransparentProxy) GetDialedDirectly 

func (x *TransparentProxy) GetDialedDirectly() bool

func (*TransparentProxy) GetOutboundListenerPort 

func (x *TransparentProxy) GetOutboundListenerPort() uint32

func (*TransparentProxy) MarshalBinary 

func (msg *TransparentProxy) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*TransparentProxy) ProtoMessage 

func (*TransparentProxy) ProtoMessage()

func (*TransparentProxy) ProtoReflect 

func (x *TransparentProxy) ProtoReflect() protoreflect.Message

func (*TransparentProxy) Reset 

func (x *TransparentProxy) Reset()

func (*TransparentProxy) String 

func (x *TransparentProxy) String() string

func (*TransparentProxy) UnmarshalBinary 

func (msg *TransparentProxy) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type UnixSocketAddress 

type UnixSocketAddress struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*UnixSocketAddress) Descriptor deprecated 

func (*UnixSocketAddress) Descriptor() ([]byte, []int)

Deprecated: Use UnixSocketAddress.ProtoReflect.Descriptor instead.

func (*UnixSocketAddress) GetMode 

func (x *UnixSocketAddress) GetMode() string

func (*UnixSocketAddress) GetPath 

func (x *UnixSocketAddress) GetPath() string

func (*UnixSocketAddress) MarshalBinary 

func (msg *UnixSocketAddress) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*UnixSocketAddress) ProtoMessage 

func (*UnixSocketAddress) ProtoMessage()

func (*UnixSocketAddress) ProtoReflect 

func (x *UnixSocketAddress) ProtoReflect() protoreflect.Message

func (*UnixSocketAddress) Reset 

func (x *UnixSocketAddress) Reset()

func (*UnixSocketAddress) String 

func (x *UnixSocketAddress) String() string

func (*UnixSocketAddress) UnmarshalBinary 

func (msg *UnixSocketAddress) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type Upstream 

type Upstream struct {
	DestinationRef  *pbresource.ID `protobuf:"bytes,1,opt,name=destination_ref,json=destinationRef,proto3" json:"destination_ref,omitempty"`
	DestinationPort string         `protobuf:"bytes,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"`
	Datacenter      string         `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"`
	// Types that are assignable to ListenAddr:
	//
	//	*Upstream_Tcp
	//	*Upstream_Unix
	ListenAddr     isUpstream_ListenAddr `protobuf_oneof:"listen_addr"`
	UpstreamConfig *UpstreamConfig       `protobuf:"bytes,7,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"`
	// contains filtered or unexported fields
}

func (*Upstream) Descriptor deprecated 

func (*Upstream) Descriptor() ([]byte, []int)

Deprecated: Use Upstream.ProtoReflect.Descriptor instead.

func (*Upstream) GetDatacenter 

func (x *Upstream) GetDatacenter() string

func (*Upstream) GetDestinationPort 

func (x *Upstream) GetDestinationPort() string

func (*Upstream) GetDestinationRef 

func (x *Upstream) GetDestinationRef() *pbresource.ID

func (*Upstream) GetListenAddr 

func (m *Upstream) GetListenAddr() isUpstream_ListenAddr

func (*Upstream) GetTcp 

func (x *Upstream) GetTcp() *TCPAddress

func (*Upstream) GetUnix 

func (x *Upstream) GetUnix() *UnixSocketAddress

func (*Upstream) GetUpstreamConfig 

func (x *Upstream) GetUpstreamConfig() *UpstreamConfig

func (*Upstream) MarshalBinary 

func (msg *Upstream) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Upstream) ProtoMessage 

func (*Upstream) ProtoMessage()

func (*Upstream) ProtoReflect 

func (x *Upstream) ProtoReflect() protoreflect.Message

func (*Upstream) Reset 

func (x *Upstream) Reset()

func (*Upstream) String 

func (x *Upstream) String() string

func (*Upstream) UnmarshalBinary 

func (msg *Upstream) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type UpstreamConfig 

type UpstreamConfig struct {
	ConnectTimeoutMs          uint64                    `protobuf:"varint,2,opt,name=connect_timeout_ms,json=connectTimeoutMs,proto3" json:"connect_timeout_ms,omitempty"`
	Limits                    *UpstreamLimits           `protobuf:"bytes,3,opt,name=limits,proto3" json:"limits,omitempty"`
	PassiveHealthCheck        *PassiveHealthCheck       `protobuf:"bytes,4,opt,name=passive_health_check,json=passiveHealthCheck,proto3" json:"passive_health_check,omitempty"`
	BalanceInboundConnections BalanceInboundConnections `` /* 201-byte string literal not displayed */
	MeshGatewayMode           MeshGatewayMode           `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpstreamConfig) Descriptor deprecated 

func (*UpstreamConfig) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamConfig.ProtoReflect.Descriptor instead.

func (*UpstreamConfig) GetBalanceInboundConnections 

func (x *UpstreamConfig) GetBalanceInboundConnections() BalanceInboundConnections

func (*UpstreamConfig) GetConnectTimeoutMs 

func (x *UpstreamConfig) GetConnectTimeoutMs() uint64

func (*UpstreamConfig) GetLimits 

func (x *UpstreamConfig) GetLimits() *UpstreamLimits

func (*UpstreamConfig) GetMeshGatewayMode 

func (x *UpstreamConfig) GetMeshGatewayMode() MeshGatewayMode

func (*UpstreamConfig) GetPassiveHealthCheck 

func (x *UpstreamConfig) GetPassiveHealthCheck() *PassiveHealthCheck

func (*UpstreamConfig) MarshalBinary 

func (msg *UpstreamConfig) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*UpstreamConfig) ProtoMessage 

func (*UpstreamConfig) ProtoMessage()

func (*UpstreamConfig) ProtoReflect 

func (x *UpstreamConfig) ProtoReflect() protoreflect.Message

func (*UpstreamConfig) Reset 

func (x *UpstreamConfig) Reset()

func (*UpstreamConfig) String 

func (x *UpstreamConfig) String() string

func (*UpstreamConfig) UnmarshalBinary 

func (msg *UpstreamConfig) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type UpstreamLimits 

type UpstreamLimits struct {

	// MaxConnections is the maximum number of connections the local proxy can
	// make to the upstream service.
	MaxConnections int32 `protobuf:"varint,1,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"`
	// MaxPendingRequests is the maximum number of requests that will be queued
	// waiting for an available connection. This is mostly applicable to HTTP/1.1
	// clusters since all HTTP/2 requests are streamed over a single
	// connection.
	MaxPendingRequests int32 `protobuf:"varint,2,opt,name=max_pending_requests,json=maxPendingRequests,proto3" json:"max_pending_requests,omitempty"`
	// MaxConcurrentRequests is the maximum number of in-flight requests that will be allowed
	// to the upstream cluster at a point in time. This is mostly applicable to HTTP/2
	// clusters since all HTTP/1.1 requests are limited by MaxConnections.
	MaxConcurrentRequests int32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

UpstreamLimits describes the limits that are associated with a specific upstream of a service instance.

func (*UpstreamLimits) Descriptor deprecated 

func (*UpstreamLimits) Descriptor() ([]byte, []int)

Deprecated: Use UpstreamLimits.ProtoReflect.Descriptor instead.

func (*UpstreamLimits) GetMaxConcurrentRequests 

func (x *UpstreamLimits) GetMaxConcurrentRequests() int32

func (*UpstreamLimits) GetMaxConnections 

func (x *UpstreamLimits) GetMaxConnections() int32

func (*UpstreamLimits) GetMaxPendingRequests 

func (x *UpstreamLimits) GetMaxPendingRequests() int32

func (*UpstreamLimits) MarshalBinary 

func (msg *UpstreamLimits) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*UpstreamLimits) ProtoMessage 

func (*UpstreamLimits) ProtoMessage()

func (*UpstreamLimits) ProtoReflect 

func (x *UpstreamLimits) ProtoReflect() protoreflect.Message

func (*UpstreamLimits) Reset 

func (x *UpstreamLimits) Reset()

func (*UpstreamLimits) String 

func (x *UpstreamLimits) String() string

func (*UpstreamLimits) UnmarshalBinary 

func (msg *UpstreamLimits) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

type Upstream_Tcp 

type Upstream_Tcp struct {
	Tcp *TCPAddress `protobuf:"bytes,4,opt,name=tcp,proto3,oneof"`
}

type Upstream_Unix 

type Upstream_Unix struct {
	Unix *UnixSocketAddress `protobuf:"bytes,5,opt,name=unix,proto3,oneof"`
}

type Upstreams 

type Upstreams struct {

	// Selection of workloads these upstreams should apply to.
	// These can be prefixes or specific workload names.
	Workloads      *v1alpha1.WorkloadSelector `protobuf:"bytes,1,opt,name=workloads,proto3" json:"workloads,omitempty"`
	Upstreams      []*Upstream                `protobuf:"bytes,2,rep,name=upstreams,proto3" json:"upstreams,omitempty"`
	PqUpstreams    []*PreparedQueryUpstream   `protobuf:"bytes,3,rep,name=pq_upstreams,json=pqUpstreams,proto3" json:"pq_upstreams,omitempty"`
	UpstreamConfig *UpstreamConfig            `protobuf:"bytes,4,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"`
	// contains filtered or unexported fields
}

func (*Upstreams) Descriptor deprecated 

func (*Upstreams) Descriptor() ([]byte, []int)

Deprecated: Use Upstreams.ProtoReflect.Descriptor instead.

func (*Upstreams) GetPqUpstreams 

func (x *Upstreams) GetPqUpstreams() []*PreparedQueryUpstream

func (*Upstreams) GetUpstreamConfig 

func (x *Upstreams) GetUpstreamConfig() *UpstreamConfig

func (*Upstreams) GetUpstreams 

func (x *Upstreams) GetUpstreams() []*Upstream

func (*Upstreams) GetWorkloads 

func (x *Upstreams) GetWorkloads() *v1alpha1.WorkloadSelector

func (*Upstreams) MarshalBinary 

func (msg *Upstreams) MarshalBinary() ([]byte, error)

MarshalBinary implements encoding.BinaryMarshaler

func (*Upstreams) ProtoMessage 

func (*Upstreams) ProtoMessage()

func (*Upstreams) ProtoReflect 

func (x *Upstreams) ProtoReflect() protoreflect.Message

func (*Upstreams) Reset 

func (x *Upstreams) Reset()

func (*Upstreams) String 

func (x *Upstreams) String() string

func (*Upstreams) UnmarshalBinary 

func (msg *Upstreams) UnmarshalBinary(b []byte) error

UnmarshalBinary implements encoding.BinaryUnmarshaler

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.