v1alpha1

package
v0.0.0-...-d6e0dea Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KubeNamespaceTag = "k8s.dubbo.io/namespace"
	KubeServiceTag   = "k8s.dubbo.io/service-name"
	KubePortTag      = "k8s.dubbo.io/service-port"
)
View Source 
const (
	// Mandatory tag that has a reserved meaning in Dubbo.
	ServiceTag     = "dubbo.io/service"
	ServiceUnknown = "unknown"

	// Locality related tags
	ZoneTag = "dubbo.io/zone"

	MeshTag = "dubbo.io/mesh"

	// Optional tag that has a reserved meaning in Dubbo.
	// If absent, Dubbo will treat application's protocol as opaque TCP.
	ProtocolTag = "dubbo.io/protocol"
	// InstanceTag is set only for Dataplanes that implements headless services
	InstanceTag = "dubbo.io/instance"

	// External service tag
	ExternalServiceTag = "dubbo.io/external-service-name"

	// Listener tag is used to select Gateway listeners
	ListenerTag = "gateways.dubbo.io/listener-name"

	// Used for Service-less dataplanes
	TCPPortReserved = 49151 // IANA Reserved

	// DisplayName is a standard label that can be used to easier recognize policy name.
	// On Kubernetes, Dubbo resource name contains namespace. Display name is original name without namespace.
	// The name contains hash when the resource is synced from global to zone. In this case, display name is original name from originated CP.
	DisplayName = "dubbo.io/display-name"

	// ResourceOriginLabel is a standard label that has information about the origin of the resource.
	// It can be either "global" or "zone".
	ResourceOriginLabel = "dubbo.io/origin"
)
View Source 
const (
	LoggingTcpType  = "tcp"
	LoggingFileType = "file"

	TracingZipkinType  = "zipkin"
	TracingDatadogType = "datadog"

	MetricsPrometheusType = "prometheus"
)
View Source 
const (
	Application    = "dubbo.io/application"
	Service        = "dubbo.io/service"
	ID             = "dubbo.io/id"
	ServiceVersion = "dubbo.io/serviceVersion"
	ServiceGroup   = "dubbo.io/serviceGroup"
	Revision       = "dubbo.io/revision"
)

Application 流量管控相关的基础label

View Source 
const (
	AppTag = "app"
)
View Source 
const (
	ApplicationName = "applicationName"
)

extensions

View Source 
const MatchAllTag = "*"

Variables

View Source 
var (
	Dataplane_Networking_Inbound_State_name = map[int32]string{
		0: "Ready",
		1: "NotReady",
		2: "Ignored",
	}
	Dataplane_Networking_Inbound_State_value = map[string]int32{
		"Ready":    0,
		"NotReady": 1,
		"Ignored":  2,
	}
)

Enum value maps for Dataplane_Networking_Inbound_State.

View Source 
var (
	PrometheusTlsConfig_Mode_name = map[int32]string{
		0: "activeMTLSBackend",
		1: "providedTLS",
		2: "disabled",
	}
	PrometheusTlsConfig_Mode_value = map[string]int32{
		"activeMTLSBackend": 0,
		"providedTLS":       1,
		"disabled":          2,
	}
)

Enum value maps for PrometheusTlsConfig_Mode.

View Source 
var DDSSyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.DDSSyncService",
	HandlerType: (*DDSSyncServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GlobalToZoneSync",
			Handler:       _DDSSyncService_GlobalToZoneSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ZoneToGlobalSync",
			Handler:       _DDSSyncService_ZoneToGlobalSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/mesh/v1alpha1/dds.proto",
}

DDSSyncService_ServiceDesc is the grpc.ServiceDesc for DDSSyncService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_mesh_v1alpha1_affinity_route_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_condition_route_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_dataplane_insight_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_dataplane_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_dds_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_dynamic_config_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_envoy_admin_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_mapping_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_mds_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_mesh_insight_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_mesh_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_metadata_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_metrics_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_tag_route_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_zone_ingress_insight_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_zone_ingress_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_zoneegress_proto protoreflect.FileDescriptor
View Source 
var File_api_mesh_v1alpha1_zoneegressinsight_proto protoreflect.FileDescriptor
View Source 
var GlobalDDSService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.GlobalDDSService",
	HandlerType: (*GlobalDDSServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HealthCheck",
			Handler:    _GlobalDDSService_HealthCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/mesh/v1alpha1/dds.proto",
}

GlobalDDSService_ServiceDesc is the grpc.ServiceDesc for GlobalDDSService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var MDSSyncService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.MDSSyncService",
	HandlerType: (*MDSSyncServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MappingRegister",
			Handler:    _MDSSyncService_MappingRegister_Handler,
		},
		{
			MethodName: "MetadataRegister",
			Handler:    _MDSSyncService_MetadataRegister_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MetadataSync",
			Handler:       _MDSSyncService_MetadataSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "MappingSync",
			Handler:       _MDSSyncService_MappingSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/mesh/v1alpha1/mds.proto",
}

MDSSyncService_ServiceDesc is the grpc.ServiceDesc for MDSSyncService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func BuildServiceKey 

func BuildServiceKey(baseDto Base) string

func GetOverridePath 

func GetOverridePath(key string) string

func GetRoutePath 

func GetRoutePath(key string, routeType string) string

func LoadObject 

func LoadObject(content string, obj interface{}) error

func Merge 

func Merge[TagSet ~map[string]string](other ...TagSet) TagSet

func MergeAs 

func MergeAs[R ~map[string]string, T ~map[string]string](other ...T) R

MergeAs is just syntactic sugar which converts merged result to assumed type

func RegisterDDSSyncServiceServer 

func RegisterDDSSyncServiceServer(s grpc.ServiceRegistrar, srv DDSSyncServiceServer)

func RegisterGlobalDDSServiceServer 

func RegisterGlobalDDSServiceServer(s grpc.ServiceRegistrar, srv GlobalDDSServiceServer)

func RegisterMDSSyncServiceServer 

func RegisterMDSSyncServiceServer(s grpc.ServiceRegistrar, srv MDSSyncServiceServer)

Types

type AddressMatch 

type AddressMatch struct {
	Wildcard string `protobuf:"bytes,1,opt,name=wildcard,proto3" json:"wildcard,omitempty"`
	Cird     string `protobuf:"bytes,2,opt,name=cird,proto3" json:"cird,omitempty"`
	Exact    string `protobuf:"bytes,3,opt,name=exact,proto3" json:"exact,omitempty"`
	// contains filtered or unexported fields
}

func (*AddressMatch) Descriptor deprecated 

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

Deprecated: Use AddressMatch.ProtoReflect.Descriptor instead.

func (*AddressMatch) GetCird 

func (x *AddressMatch) GetCird() string

func (*AddressMatch) GetExact 

func (x *AddressMatch) GetExact() string

func (*AddressMatch) GetWildcard 

func (x *AddressMatch) GetWildcard() string

func (*AddressMatch) ProtoMessage 

func (*AddressMatch) ProtoMessage()

func (*AddressMatch) ProtoReflect 

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

func (*AddressMatch) Reset 

func (x *AddressMatch) Reset()

func (*AddressMatch) String 

func (x *AddressMatch) String() string

type AffinityAware 

type AffinityAware struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Ratio int32  `protobuf:"varint,2,opt,name=ratio,proto3" json:"ratio,omitempty"`
	// contains filtered or unexported fields
}

func (*AffinityAware) Descriptor deprecated 

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

Deprecated: Use AffinityAware.ProtoReflect.Descriptor instead.

func (*AffinityAware) GetKey 

func (x *AffinityAware) GetKey() string

func (*AffinityAware) GetRatio 

func (x *AffinityAware) GetRatio() int32

func (*AffinityAware) ProtoMessage 

func (*AffinityAware) ProtoMessage()

func (*AffinityAware) ProtoReflect 

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

func (*AffinityAware) Reset 

func (x *AffinityAware) Reset()

func (*AffinityAware) String 

func (x *AffinityAware) String() string

type AffinityRoute 

type AffinityRoute struct {
	ConfigVersion string         `protobuf:"bytes,1,opt,name=configVersion,proto3" json:"configVersion,omitempty"`
	Scope         string         `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"` // must be chosen from `service` and `application`
	Key           string         `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`     // specifies which service or application the rule body acts on
	Runtime       bool           `protobuf:"varint,4,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Enabled       bool           `protobuf:"varint,5,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Affinity      *AffinityAware `protobuf:"bytes,6,opt,name=affinity,proto3" json:"affinity,omitempty"`
	// contains filtered or unexported fields
}

func (*AffinityRoute) Descriptor deprecated 

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

Deprecated: Use AffinityRoute.ProtoReflect.Descriptor instead.

func (*AffinityRoute) GetAffinity 

func (x *AffinityRoute) GetAffinity() *AffinityAware

func (*AffinityRoute) GetConfigVersion 

func (x *AffinityRoute) GetConfigVersion() string

func (*AffinityRoute) GetEnabled 

func (x *AffinityRoute) GetEnabled() bool

func (*AffinityRoute) GetKey 

func (x *AffinityRoute) GetKey() string

func (*AffinityRoute) GetRuntime 

func (x *AffinityRoute) GetRuntime() bool

func (*AffinityRoute) GetScope 

func (x *AffinityRoute) GetScope() string

func (*AffinityRoute) ProtoMessage 

func (*AffinityRoute) ProtoMessage()

func (*AffinityRoute) ProtoReflect 

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

func (*AffinityRoute) Reset 

func (x *AffinityRoute) Reset()

func (*AffinityRoute) String 

func (x *AffinityRoute) String() string

type Base 

type Base struct {
	Application    string `json:"application" yaml:"application"`
	Service        string `json:"service" yaml:"service"`
	ID             string `json:"id" yaml:"id"`
	ServiceVersion string `json:"serviceVersion" yaml:"serviceVersion"`
	ServiceGroup   string `json:"serviceGroup" yaml:"serviceGroup"`
}

type CertificateAuthorityBackend 

type CertificateAuthorityBackend struct {

	// Name of the backend
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the backend. Has to be one of the loaded plugins (Dubbo ships with
	// builtin and provided)
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Dataplane certificate settings
	DpCert *CertificateAuthorityBackend_DpCert `protobuf:"bytes,3,opt,name=dpCert,proto3" json:"dpCert,omitempty"`
	// Configuration of the backend
	Conf *structpb.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

CertificateAuthorityBackend defines Certificate Authority backend

func (*CertificateAuthorityBackend) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend) GetConf 

func (x *CertificateAuthorityBackend) GetConf() *structpb.Struct

func (*CertificateAuthorityBackend) GetDpCert 

func (x *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert

func (*CertificateAuthorityBackend) GetName 

func (x *CertificateAuthorityBackend) GetName() string

func (*CertificateAuthorityBackend) GetType 

func (x *CertificateAuthorityBackend) GetType() string

func (*CertificateAuthorityBackend) ProtoMessage 

func (*CertificateAuthorityBackend) ProtoMessage()

func (*CertificateAuthorityBackend) ProtoReflect 

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

func (*CertificateAuthorityBackend) Reset 

func (x *CertificateAuthorityBackend) Reset()

func (*CertificateAuthorityBackend) String 

func (x *CertificateAuthorityBackend) String() string

type CertificateAuthorityBackend_DpCert 

type CertificateAuthorityBackend_DpCert struct {

	// Rotation settings
	Rotation *CertificateAuthorityBackend_DpCert_Rotation `protobuf:"bytes,1,opt,name=rotation,proto3" json:"rotation,omitempty"`
	// contains filtered or unexported fields
}

DpCert defines settings for certificates generated for Dataplanes

func (*CertificateAuthorityBackend_DpCert) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend_DpCert.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert) GetRotation 

func (x *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation

func (*CertificateAuthorityBackend_DpCert) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) ProtoReflect 

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

func (*CertificateAuthorityBackend_DpCert) Reset 

func (x *CertificateAuthorityBackend_DpCert) Reset()

func (*CertificateAuthorityBackend_DpCert) String 

func (x *CertificateAuthorityBackend_DpCert) String() string

type CertificateAuthorityBackend_DpCert_Rotation 

type CertificateAuthorityBackend_DpCert_Rotation struct {

	// Time after which generated certificate for Dataplane will expire
	Expiration string `protobuf:"bytes,1,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// contains filtered or unexported fields
}

Rotation defines rotation settings for Dataplane certificate

func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend_DpCert_Rotation.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration 

func (x *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect 

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

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset 

func (x *CertificateAuthorityBackend_DpCert_Rotation) Reset()

func (*CertificateAuthorityBackend_DpCert_Rotation) String 

func (x *CertificateAuthorityBackend_DpCert_Rotation) String() string

type ConditionMatch 

type ConditionMatch struct {
	Address         *AddressMatch    `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	ProviderAddress *AddressMatch    `protobuf:"bytes,5,opt,name=providerAddress,proto3" json:"providerAddress,omitempty"`
	Service         *ListStringMatch `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Application     *ListStringMatch `protobuf:"bytes,3,opt,name=application,proto3" json:"application,omitempty"`
	Param           []*ParamMatch    `protobuf:"bytes,4,rep,name=param,proto3" json:"param,omitempty"`
	// contains filtered or unexported fields
}

func (*ConditionMatch) Descriptor deprecated 

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

Deprecated: Use ConditionMatch.ProtoReflect.Descriptor instead.

func (*ConditionMatch) GetAddress 

func (x *ConditionMatch) GetAddress() *AddressMatch

func (*ConditionMatch) GetApplication 

func (x *ConditionMatch) GetApplication() *ListStringMatch

func (*ConditionMatch) GetParam 

func (x *ConditionMatch) GetParam() []*ParamMatch

func (*ConditionMatch) GetProviderAddress 

func (x *ConditionMatch) GetProviderAddress() *AddressMatch

func (*ConditionMatch) GetService 

func (x *ConditionMatch) GetService() *ListStringMatch

func (*ConditionMatch) ProtoMessage 

func (*ConditionMatch) ProtoMessage()

func (*ConditionMatch) ProtoReflect 

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

func (*ConditionMatch) Reset 

func (x *ConditionMatch) Reset()

func (*ConditionMatch) String 

func (x *ConditionMatch) String() string

type ConditionRoute 

type ConditionRoute struct {

	// Types that are assignable to Conditions:
	//
	//	*ConditionRoute_ConditionsV3
	//	*ConditionRoute_ConditionsV3X1
	Conditions isConditionRoute_Conditions `protobuf_oneof:"conditions"`
	// contains filtered or unexported fields
}

func ConditionRouteDecodeFromYAML 

func ConditionRouteDecodeFromYAML(content []byte) (*ConditionRoute, error)

func (*ConditionRoute) Descriptor deprecated 

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

Deprecated: Use ConditionRoute.ProtoReflect.Descriptor instead.

func (*ConditionRoute) GetConditions 

func (m *ConditionRoute) GetConditions() isConditionRoute_Conditions

func (*ConditionRoute) GetConditionsV3 

func (x *ConditionRoute) GetConditionsV3() *ConditionRouteV3

func (*ConditionRoute) GetConditionsV3X1 

func (x *ConditionRoute) GetConditionsV3X1() *ConditionRouteV3X1

func (*ConditionRoute) GetVersion 

func (x *ConditionRoute) GetVersion() string

func (*ConditionRoute) ProtoMessage 

func (*ConditionRoute) ProtoMessage()

func (*ConditionRoute) ProtoReflect 

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

func (*ConditionRoute) Reset 

func (x *ConditionRoute) Reset()

func (*ConditionRoute) String 

func (x *ConditionRoute) String() string

func (*ConditionRoute) ToConditionRouteV3 

func (x *ConditionRoute) ToConditionRouteV3() *ConditionRouteV3

func (*ConditionRoute) ToConditionRouteV3x1 

func (x *ConditionRoute) ToConditionRouteV3x1() *ConditionRouteV3X1

func (*ConditionRoute) ToYAML 

func (x *ConditionRoute) ToYAML() ([]byte, error)

type ConditionRouteV3 

type ConditionRouteV3 struct {
	ConfigVersion string   `protobuf:"bytes,1,opt,name=configVersion,proto3" json:"configVersion,omitempty"`
	Priority      int32    `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	Enabled       bool     `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Force         bool     `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	Runtime       bool     `protobuf:"varint,5,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Key           string   `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Scope         string   `protobuf:"bytes,7,opt,name=scope,proto3" json:"scope,omitempty"`
	Conditions    []string `protobuf:"bytes,8,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

func (*ConditionRouteV3) Descriptor deprecated 

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

Deprecated: Use ConditionRouteV3.ProtoReflect.Descriptor instead.

func (*ConditionRouteV3) GetConditions 

func (x *ConditionRouteV3) GetConditions() []string

func (*ConditionRouteV3) GetConfigVersion 

func (x *ConditionRouteV3) GetConfigVersion() string

func (*ConditionRouteV3) GetEnabled 

func (x *ConditionRouteV3) GetEnabled() bool

func (*ConditionRouteV3) GetForce 

func (x *ConditionRouteV3) GetForce() bool

func (*ConditionRouteV3) GetKey 

func (x *ConditionRouteV3) GetKey() string

func (*ConditionRouteV3) GetPriority 

func (x *ConditionRouteV3) GetPriority() int32

func (*ConditionRouteV3) GetRuntime 

func (x *ConditionRouteV3) GetRuntime() bool

func (*ConditionRouteV3) GetScope 

func (x *ConditionRouteV3) GetScope() string

func (*ConditionRouteV3) ProtoMessage 

func (*ConditionRouteV3) ProtoMessage()

func (*ConditionRouteV3) ProtoReflect 

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

func (*ConditionRouteV3) Reset 

func (x *ConditionRouteV3) Reset()

func (*ConditionRouteV3) String 

func (x *ConditionRouteV3) String() string

func (*ConditionRouteV3) ToConditionRoute 

func (x *ConditionRouteV3) ToConditionRoute() *ConditionRoute

type ConditionRouteV3X1 

type ConditionRouteV3X1 struct {
	ConfigVersion string           `protobuf:"bytes,1,opt,name=configVersion,proto3" json:"configVersion,omitempty"`
	Scope         string           `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"` // must be chosen from `service` and `application`
	Key           string           `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`     // specifies which service or application the rule body acts on
	Force         bool             `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	Runtime       bool             `protobuf:"varint,5,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Enabled       bool             `protobuf:"varint,6,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Conditions    []*ConditionRule `protobuf:"bytes,8,rep,name=conditions,proto3" json:"conditions,omitempty"`
	// contains filtered or unexported fields
}

func (*ConditionRouteV3X1) Descriptor deprecated 

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

Deprecated: Use ConditionRouteV3X1.ProtoReflect.Descriptor instead.

func (*ConditionRouteV3X1) GetConditions 

func (x *ConditionRouteV3X1) GetConditions() []*ConditionRule

func (*ConditionRouteV3X1) GetConfigVersion 

func (x *ConditionRouteV3X1) GetConfigVersion() string

func (*ConditionRouteV3X1) GetEnabled 

func (x *ConditionRouteV3X1) GetEnabled() bool

func (*ConditionRouteV3X1) GetForce 

func (x *ConditionRouteV3X1) GetForce() bool

func (*ConditionRouteV3X1) GetKey 

func (x *ConditionRouteV3X1) GetKey() string

func (*ConditionRouteV3X1) GetRuntime 

func (x *ConditionRouteV3X1) GetRuntime() bool

func (*ConditionRouteV3X1) GetScope 

func (x *ConditionRouteV3X1) GetScope() string

func (*ConditionRouteV3X1) ProtoMessage 

func (*ConditionRouteV3X1) ProtoMessage()

func (*ConditionRouteV3X1) ProtoReflect 

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

func (*ConditionRouteV3X1) RangeConditions 

func (x *ConditionRouteV3X1) RangeConditions(f func(r *ConditionRule) (isStop bool))

func (*ConditionRouteV3X1) RangeConditionsToRemove 

func (x *ConditionRouteV3X1) RangeConditionsToRemove(f func(r *ConditionRule) (isRemove bool))

func (*ConditionRouteV3X1) Reset 

func (x *ConditionRouteV3X1) Reset()

func (*ConditionRouteV3X1) String 

func (x *ConditionRouteV3X1) String() string

func (*ConditionRouteV3X1) ToConditionRoute 

func (x *ConditionRouteV3X1) ToConditionRoute() *ConditionRoute

type ConditionRoute_ConditionsV3 

type ConditionRoute_ConditionsV3 struct {
	ConditionsV3 *ConditionRouteV3 `protobuf:"bytes,1,opt,name=conditionsV3,proto3,oneof"`
}

type ConditionRoute_ConditionsV3X1 

type ConditionRoute_ConditionsV3X1 struct {
	ConditionsV3X1 *ConditionRouteV3X1 `protobuf:"bytes,2,opt,name=conditionsV3x1,proto3,oneof"`
}

type ConditionRule 

type ConditionRule struct {
	From *ConditionRuleFrom `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To   []*ConditionRuleTo `protobuf:"bytes,2,rep,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*ConditionRule) Descriptor deprecated 

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

Deprecated: Use ConditionRule.ProtoReflect.Descriptor instead.

func (*ConditionRule) GetFrom 

func (x *ConditionRule) GetFrom() *ConditionRuleFrom

func (*ConditionRule) GetTo 

func (x *ConditionRule) GetTo() []*ConditionRuleTo

func (*ConditionRule) IsMatchMethod 

func (x *ConditionRule) IsMatchMethod() (string, bool)

func (*ConditionRule) ProtoMessage 

func (*ConditionRule) ProtoMessage()

func (*ConditionRule) ProtoReflect 

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

func (*ConditionRule) Reset 

func (x *ConditionRule) Reset()

func (*ConditionRule) String 

func (x *ConditionRule) String() string

type ConditionRuleFrom 

type ConditionRuleFrom struct {
	Match string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// contains filtered or unexported fields
}

func (*ConditionRuleFrom) Descriptor deprecated 

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

Deprecated: Use ConditionRuleFrom.ProtoReflect.Descriptor instead.

func (*ConditionRuleFrom) GetMatch 

func (x *ConditionRuleFrom) GetMatch() string

func (*ConditionRuleFrom) ProtoMessage 

func (*ConditionRuleFrom) ProtoMessage()

func (*ConditionRuleFrom) ProtoReflect 

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

func (*ConditionRuleFrom) Reset 

func (x *ConditionRuleFrom) Reset()

func (*ConditionRuleFrom) String 

func (x *ConditionRuleFrom) String() string

type ConditionRuleTo 

type ConditionRuleTo struct {
	Match  string `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	Weight int32  `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"` // default value will be handled by application logic
	// contains filtered or unexported fields
}

func (*ConditionRuleTo) Descriptor deprecated 

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

Deprecated: Use ConditionRuleTo.ProtoReflect.Descriptor instead.

func (*ConditionRuleTo) GetMatch 

func (x *ConditionRuleTo) GetMatch() string

func (*ConditionRuleTo) GetWeight 

func (x *ConditionRuleTo) GetWeight() int32

func (*ConditionRuleTo) ProtoMessage 

func (*ConditionRuleTo) ProtoMessage()

func (*ConditionRuleTo) ProtoReflect 

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

func (*ConditionRuleTo) Reset 

func (x *ConditionRuleTo) Reset()

func (*ConditionRuleTo) String 

func (x *ConditionRuleTo) String() string

type DDSSyncServiceClient 

type DDSSyncServiceClient interface {
	// GlobalToZoneSync is logically a service exposed by global control-plane
	// that allows zone control plane to connect and synchronize resources from
	// the global control-plane to the zone control-plane. It uses delta xDS from
	// go-control-plane and responds only with the changes to the resources.
	GlobalToZoneSync(ctx context.Context, opts ...grpc.CallOption) (DDSSyncService_GlobalToZoneSyncClient, error)
	// ZoneToGlobalSync is logically a service exposed by global control-plane
	// that allows zone control plane to connect and synchronize resources to
	// the global control-plane. It uses delta xDS from go-control-plane and
	// responds only with the changes to the resources.
	ZoneToGlobalSync(ctx context.Context, opts ...grpc.CallOption) (DDSSyncService_ZoneToGlobalSyncClient, error)
}

DDSSyncServiceClient is the client API for DDSSyncService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDDSSyncServiceClient 

func NewDDSSyncServiceClient(cc grpc.ClientConnInterface) DDSSyncServiceClient

type DDSSyncServiceServer 

type DDSSyncServiceServer interface {
	// GlobalToZoneSync is logically a service exposed by global control-plane
	// that allows zone control plane to connect and synchronize resources from
	// the global control-plane to the zone control-plane. It uses delta xDS from
	// go-control-plane and responds only with the changes to the resources.
	GlobalToZoneSync(DDSSyncService_GlobalToZoneSyncServer) error
	// ZoneToGlobalSync is logically a service exposed by global control-plane
	// that allows zone control plane to connect and synchronize resources to
	// the global control-plane. It uses delta xDS from go-control-plane and
	// responds only with the changes to the resources.
	ZoneToGlobalSync(DDSSyncService_ZoneToGlobalSyncServer) error
	// contains filtered or unexported methods
}

DDSSyncServiceServer is the server API for DDSSyncService service. All implementations must embed UnimplementedDDSSyncServiceServer for forward compatibility

type DDSSyncService_GlobalToZoneSyncClient 

type DDSSyncService_GlobalToZoneSyncClient interface {
	Send(*v3.DeltaDiscoveryRequest) error
	Recv() (*v3.DeltaDiscoveryResponse, error)
	grpc.ClientStream
}

type DDSSyncService_GlobalToZoneSyncServer 

type DDSSyncService_GlobalToZoneSyncServer interface {
	Send(*v3.DeltaDiscoveryResponse) error
	Recv() (*v3.DeltaDiscoveryRequest, error)
	grpc.ServerStream
}

type DDSSyncService_ZoneToGlobalSyncClient 

type DDSSyncService_ZoneToGlobalSyncClient interface {
	Send(*v3.DeltaDiscoveryResponse) error
	Recv() (*v3.DeltaDiscoveryRequest, error)
	grpc.ClientStream
}

type DDSSyncService_ZoneToGlobalSyncServer 

type DDSSyncService_ZoneToGlobalSyncServer interface {
	Send(*v3.DeltaDiscoveryRequest) error
	Recv() (*v3.DeltaDiscoveryResponse, error)
	grpc.ServerStream
}

type Dataplane 

type Dataplane struct {

	// Networking describes inbound and outbound interfaces of the data plane
	// proxy.
	Networking *Dataplane_Networking `protobuf:"bytes,1,opt,name=networking,proto3" json:"networking,omitempty"`
	// Configuration for metrics that should be collected and exposed by the
	// data plane proxy.
	//
	// Settings defined here will override their respective defaults
	// defined at a Mesh level.
	Metrics *MetricsBackend `protobuf:"bytes,2,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// Probes describe a list of endpoints that will be exposed without mTLS.
	// This is useful to expose the health endpoints of the application so the
	// orchestration system (e.g. Kubernetes) can still health check the
	// application.
	Probes     *Dataplane_Probes `protobuf:"bytes,3,opt,name=probes,proto3" json:"probes,omitempty"`
	Extensions map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

Dataplane defines configuration of a side-car proxy.

func (*Dataplane) Descriptor deprecated 

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

Deprecated: Use Dataplane.ProtoReflect.Descriptor instead.

func (*Dataplane) GetExtensions 

func (x *Dataplane) GetExtensions() map[string]string

func (*Dataplane) GetIdentifyingService 

func (d *Dataplane) GetIdentifyingService() string

func (*Dataplane) GetMetrics 

func (x *Dataplane) GetMetrics() *MetricsBackend

func (*Dataplane) GetNetworking 

func (x *Dataplane) GetNetworking() *Dataplane_Networking

func (*Dataplane) GetProbes 

func (x *Dataplane) GetProbes() *Dataplane_Probes

func (*Dataplane) ProtoMessage 

func (*Dataplane) ProtoMessage()

func (*Dataplane) ProtoReflect 

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

func (*Dataplane) Reset 

func (x *Dataplane) Reset()

func (*Dataplane) SingleValueTagSets 

func (d *Dataplane) SingleValueTagSets() []SingleValueTagSet

func (*Dataplane) String 

func (x *Dataplane) String() string

func (*Dataplane) TagSet 

func (d *Dataplane) TagSet() MultiValueTagSet

type DataplaneInsight 

type DataplaneInsight struct {

	// List of ADS subscriptions created by a given Dataplane.
	Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Insights about mTLS for Dataplane.
	MTLS *DataplaneInsight_MTLS `protobuf:"bytes,2,opt,name=mTLS,proto3" json:"mTLS,omitempty"`
	// contains filtered or unexported fields
}

DataplaneInsight defines the observed state of a Dataplane.

func (*DataplaneInsight) AllSubscriptions 

func (x *DataplaneInsight) AllSubscriptions() []generic.Subscription

func (*DataplaneInsight) Descriptor deprecated 

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

Deprecated: Use DataplaneInsight.ProtoReflect.Descriptor instead.

func (*DataplaneInsight) GetLastSubscription 

func (x *DataplaneInsight) GetLastSubscription() generic.Subscription

func (*DataplaneInsight) GetMTLS 

func (x *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS

func (*DataplaneInsight) GetSubscription 

func (x *DataplaneInsight) GetSubscription(id string) generic.Subscription

func (*DataplaneInsight) GetSubscriptions 

func (x *DataplaneInsight) GetSubscriptions() []*DiscoverySubscription

func (*DataplaneInsight) IsOnline 

func (x *DataplaneInsight) IsOnline() bool

func (*DataplaneInsight) ProtoMessage 

func (*DataplaneInsight) ProtoMessage()

func (*DataplaneInsight) ProtoReflect 

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

func (*DataplaneInsight) Reset 

func (x *DataplaneInsight) Reset()

func (*DataplaneInsight) String 

func (x *DataplaneInsight) String() string

func (*DataplaneInsight) Sum 

func (x *DataplaneInsight) Sum(v func(*DiscoverySubscription) uint64) uint64

func (*DataplaneInsight) UpdateCert 

func (x *DataplaneInsight) UpdateCert(generation time.Time, expiration time.Time, issuedBackend string, supportedBackends []string) error

func (*DataplaneInsight) UpdateSubscription 

func (x *DataplaneInsight) UpdateSubscription(s generic.Subscription) error

type DataplaneInsight_MTLS 

type DataplaneInsight_MTLS struct {

	// Expiration time of the last certificate that was generated for a
	// Dataplane.
	CertificateExpirationTime *timestamppb.Timestamp `` /* 138-byte string literal not displayed */
	// Time on which the last certificate was generated.
	LastCertificateRegeneration *timestamppb.Timestamp `` /* 144-byte string literal not displayed */
	// Number of certificate regenerations for a Dataplane.
	CertificateRegenerations uint32 `` /* 134-byte string literal not displayed */
	// Backend that was used to generate current certificate
	IssuedBackend string `protobuf:"bytes,4,opt,name=issuedBackend,proto3" json:"issuedBackend,omitempty"`
	// Supported backends (CA).
	SupportedBackends []string `protobuf:"bytes,5,rep,name=supportedBackends,proto3" json:"supportedBackends,omitempty"`
	// contains filtered or unexported fields
}

MTLS defines insights for mTLS

func (*DataplaneInsight_MTLS) Descriptor deprecated 

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

Deprecated: Use DataplaneInsight_MTLS.ProtoReflect.Descriptor instead.

func (*DataplaneInsight_MTLS) GetCertificateExpirationTime 

func (x *DataplaneInsight_MTLS) GetCertificateExpirationTime() *timestamppb.Timestamp

func (*DataplaneInsight_MTLS) GetCertificateRegenerations 

func (x *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32

func (*DataplaneInsight_MTLS) GetIssuedBackend 

func (x *DataplaneInsight_MTLS) GetIssuedBackend() string

func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration 

func (x *DataplaneInsight_MTLS) GetLastCertificateRegeneration() *timestamppb.Timestamp

func (*DataplaneInsight_MTLS) GetSupportedBackends 

func (x *DataplaneInsight_MTLS) GetSupportedBackends() []string

func (*DataplaneInsight_MTLS) ProtoMessage 

func (*DataplaneInsight_MTLS) ProtoMessage()

func (*DataplaneInsight_MTLS) ProtoReflect 

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

func (*DataplaneInsight_MTLS) Reset 

func (x *DataplaneInsight_MTLS) Reset()

func (*DataplaneInsight_MTLS) String 

func (x *DataplaneInsight_MTLS) String() string

type Dataplane_Networking 

type Dataplane_Networking struct {

	// IP on which the data plane proxy is accessible to the control plane and
	// other data plane proxies in the same network. This can also be a
	// hostname, in which case the control plane will periodically resolve it.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// In some situations, a data plane proxy resides in a private network (e.g.
	// Docker) and is not reachable via `address` to other data plane proxies.
	// `advertisedAddress` is configured with a routable address for such data
	// plane proxy so that other proxies in the mesh can connect to it over
	// `advertisedAddress` and not via address.
	//
	// Envoy still binds to the `address`, not `advertisedAddress`.
	AdvertisedAddress string `protobuf:"bytes,7,opt,name=advertisedAddress,proto3" json:"advertisedAddress,omitempty"`
	// Inbound describes a list of inbound interfaces of the data plane proxy.
	//
	// Inbound describes a service implemented by the data plane proxy.
	// All incoming traffic to a data plane proxy is going through inbound
	// listeners. For every defined Inbound there is a corresponding Envoy
	// Listener.
	Inbound []*Dataplane_Networking_Inbound `protobuf:"bytes,1,rep,name=inbound,proto3" json:"inbound,omitempty"`
	// Outbound describes a list of services consumed by the data plane proxy.
	// For every defined Outbound, there is a corresponding Envoy Listener.
	Outbound []*Dataplane_Networking_Outbound `protobuf:"bytes,2,rep,name=outbound,proto3" json:"outbound,omitempty"`
	// Admin describes configuration related to Envoy Admin API.
	// Due to security, all the Envoy Admin endpoints are exposed only on
	// localhost. Additionally, Envoy will expose `/ready` endpoint on
	// `networking.address` for health checking systems to be able to check the
	// state of Envoy. The rest of the endpoints exposed on `networking.address`
	// are always protected by mTLS and only meant to be consumed internally by
	// the control plane.
	Admin *EnvoyAdmin `protobuf:"bytes,8,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

Networking describes inbound and outbound interfaces of a data plane proxy.

func (*Dataplane_Networking) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking) GetAddress 

func (x *Dataplane_Networking) GetAddress() string

func (*Dataplane_Networking) GetAdmin 

func (x *Dataplane_Networking) GetAdmin() *EnvoyAdmin

func (*Dataplane_Networking) GetAdvertisedAddress 

func (x *Dataplane_Networking) GetAdvertisedAddress() string

func (*Dataplane_Networking) GetHealthyInbounds 

func (n *Dataplane_Networking) GetHealthyInbounds() []*Dataplane_Networking_Inbound

func (*Dataplane_Networking) GetInbound 

func (x *Dataplane_Networking) GetInbound() []*Dataplane_Networking_Inbound

func (*Dataplane_Networking) GetInboundForPort 

func (n *Dataplane_Networking) GetInboundForPort(port uint32) *Dataplane_Networking_Inbound

func (*Dataplane_Networking) GetInboundInterface 

func (n *Dataplane_Networking) GetInboundInterface(service string) (*InboundInterface, error)

func (*Dataplane_Networking) GetInboundInterfaces 

func (n *Dataplane_Networking) GetInboundInterfaces() []InboundInterface

func (*Dataplane_Networking) GetOutbound 

func (x *Dataplane_Networking) GetOutbound() []*Dataplane_Networking_Outbound

func (*Dataplane_Networking) GetOutboundInterfaces 

func (n *Dataplane_Networking) GetOutboundInterfaces() []OutboundInterface

func (*Dataplane_Networking) ProtoMessage 

func (*Dataplane_Networking) ProtoMessage()

func (*Dataplane_Networking) ProtoReflect 

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

func (*Dataplane_Networking) Reset 

func (x *Dataplane_Networking) Reset()

func (*Dataplane_Networking) String 

func (x *Dataplane_Networking) String() string

func (*Dataplane_Networking) ToInboundInterface 

func (n *Dataplane_Networking) ToInboundInterface(inbound *Dataplane_Networking_Inbound) InboundInterface

func (*Dataplane_Networking) ToOutboundInterface 

func (n *Dataplane_Networking) ToOutboundInterface(outbound *Dataplane_Networking_Outbound) OutboundInterface

type Dataplane_Networking_Inbound 

type Dataplane_Networking_Inbound struct {

	// Port of the inbound interface that will forward requests to the
	// service.
	//
	// When transparent proxying is used, it is a port on which the service is
	// listening to. When transparent proxying is not used, Envoy will bind to
	// this port.
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// Port of the service that requests will be forwarded to.
	// Defaults to the same value as `port`.
	ServicePort uint32 `protobuf:"varint,4,opt,name=servicePort,proto3" json:"servicePort,omitempty"`
	// Address of the service that requests will be forwarded to.
	// Defaults to 'inbound.address', since Dubbo DP should be deployed next
	// to the service.
	ServiceAddress string `protobuf:"bytes,6,opt,name=serviceAddress,proto3" json:"serviceAddress,omitempty"`
	// Address on which inbound listener will be exposed.
	// Defaults to `networking.address`.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// Tags associated with an application this data plane proxy is deployed
	// next to, e.g. `dubbo.io/service=web`, `version=1.0`. You can then
	// reference these tags in policies like MeshTrafficPermission.
	// `dubbo.io/service` tag is mandatory.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Health describes the status of an inbound.
	// If 'health' is nil we consider data plane proxy as healthy.
	// Unhealthy data plane proxies are excluded from Endpoints Discovery
	// Service (EDS). On Kubernetes, it is filled automatically by the control
	// plane if Pod has readiness probe configured. On Universal, it can be
	// set by the external health checking system, but the most common way is
	// to use service probes.
	Health *Dataplane_Networking_Inbound_Health `protobuf:"bytes,7,opt,name=health,proto3" json:"health,omitempty"`
	// ServiceProbe defines parameters for probing the service next to
	// sidecar. When service probe is defined, Envoy will periodically health
	// check the application next to it and report the status to the control
	// plane. On Kubernetes, Dubbo deployments rely on Kubernetes probes so
	// this is not used.
	ServiceProbe *Dataplane_Networking_Inbound_ServiceProbe `protobuf:"bytes,8,opt,name=serviceProbe,proto3" json:"serviceProbe,omitempty"`
	// State describes the current state of the listener.
	State Dataplane_Networking_Inbound_State `protobuf:"varint,9,opt,name=state,proto3,enum=dubbo.mesh.v1alpha1.Dataplane_Networking_Inbound_State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

Inbound describes a service implemented by the data plane proxy. All incoming traffic to a data plane proxy are going through inbound listeners. For every defined Inbound there is a corresponding Envoy Listener.

func (*Dataplane_Networking_Inbound) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound) GetAddress 

func (x *Dataplane_Networking_Inbound) GetAddress() string

func (*Dataplane_Networking_Inbound) GetHealth 

func (x *Dataplane_Networking_Inbound) GetHealth() *Dataplane_Networking_Inbound_Health

func (*Dataplane_Networking_Inbound) GetPort 

func (x *Dataplane_Networking_Inbound) GetPort() uint32

func (*Dataplane_Networking_Inbound) GetProtocol 

func (d *Dataplane_Networking_Inbound) GetProtocol() string

GetProtocol returns a protocol supported by this inbound interface.

The purpose of this method is to encapsulate implementation detail that protocol is modeled as a tag rather than a separate field.

func (*Dataplane_Networking_Inbound) GetService 

func (d *Dataplane_Networking_Inbound) GetService() string

GetService returns a service represented by this inbound interface.

The purpose of this method is to encapsulate implementation detail that service is modeled as a tag rather than a separate field.

func (*Dataplane_Networking_Inbound) GetServiceAddress 

func (x *Dataplane_Networking_Inbound) GetServiceAddress() string

func (*Dataplane_Networking_Inbound) GetServicePort 

func (x *Dataplane_Networking_Inbound) GetServicePort() uint32

func (*Dataplane_Networking_Inbound) GetServiceProbe 

func (x *Dataplane_Networking_Inbound) GetServiceProbe() *Dataplane_Networking_Inbound_ServiceProbe

func (*Dataplane_Networking_Inbound) GetState 

func (x *Dataplane_Networking_Inbound) GetState() Dataplane_Networking_Inbound_State

func (*Dataplane_Networking_Inbound) GetTags 

func (x *Dataplane_Networking_Inbound) GetTags() map[string]string

func (*Dataplane_Networking_Inbound) ProtoMessage 

func (*Dataplane_Networking_Inbound) ProtoMessage()

func (*Dataplane_Networking_Inbound) ProtoReflect 

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

func (*Dataplane_Networking_Inbound) Reset 

func (x *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) String 

func (x *Dataplane_Networking_Inbound) String() string

type Dataplane_Networking_Inbound_Health 

type Dataplane_Networking_Inbound_Health struct {

	// Ready indicates if the data plane proxy is ready to serve the
	// traffic.
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

Health describes the status of an inbound

func (*Dataplane_Networking_Inbound_Health) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_Health.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_Health) GetReady 

func (x *Dataplane_Networking_Inbound_Health) GetReady() bool

func (*Dataplane_Networking_Inbound_Health) ProtoMessage 

func (*Dataplane_Networking_Inbound_Health) ProtoMessage()

func (*Dataplane_Networking_Inbound_Health) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_Health) Reset 

func (x *Dataplane_Networking_Inbound_Health) Reset()

func (*Dataplane_Networking_Inbound_Health) String 

func (x *Dataplane_Networking_Inbound_Health) String() string

type Dataplane_Networking_Inbound_ServiceProbe 

type Dataplane_Networking_Inbound_ServiceProbe struct {

	// Interval between consecutive health checks.
	Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// Maximum time to wait for a health check response.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of consecutive unhealthy checks before considering a host
	// unhealthy.
	UnhealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=unhealthy_threshold,json=unhealthyThreshold,proto3" json:"unhealthy_threshold,omitempty"`
	// Number of consecutive healthy checks before considering a host
	// healthy.
	HealthyThreshold *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=healthy_threshold,json=healthyThreshold,proto3" json:"healthy_threshold,omitempty"`
	// Tcp checker tries to establish tcp connection with destination
	Tcp *Dataplane_Networking_Inbound_ServiceProbe_Tcp `protobuf:"bytes,5,opt,name=tcp,proto3" json:"tcp,omitempty"`
	// contains filtered or unexported fields
}

ServiceProbe defines parameters for probing service's port

func (*Dataplane_Networking_Inbound_ServiceProbe) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe) GetHealthyThreshold 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetHealthyThreshold() *wrapperspb.UInt32Value

func (*Dataplane_Networking_Inbound_ServiceProbe) GetInterval 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTcp 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetTcp() *Dataplane_Networking_Inbound_ServiceProbe_Tcp

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTimeout 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetTimeout() *durationpb.Duration

func (*Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold() *wrapperspb.UInt32Value

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe) String() string

type Dataplane_Networking_Inbound_ServiceProbe_Tcp 

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

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe_Tcp.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) String() string

type Dataplane_Networking_Inbound_State 

type Dataplane_Networking_Inbound_State int32
const (
	// Inbound is ready to serve the traffic.
	Dataplane_Networking_Inbound_Ready Dataplane_Networking_Inbound_State = 0
	// Inbound is not ready to serve the traffic.
	Dataplane_Networking_Inbound_NotReady Dataplane_Networking_Inbound_State = 1
	// Inbound is not created. It cannot be targeted by policies.
	// However, a data plane proxy receives a certificate with identity of
	// this inbound.
	Dataplane_Networking_Inbound_Ignored Dataplane_Networking_Inbound_State = 2
)

func (Dataplane_Networking_Inbound_State) Descriptor 

func (Dataplane_Networking_Inbound_State) Descriptor() protoreflect.EnumDescriptor

func (Dataplane_Networking_Inbound_State) Enum 

func (x Dataplane_Networking_Inbound_State) Enum() *Dataplane_Networking_Inbound_State

func (Dataplane_Networking_Inbound_State) EnumDescriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_State.Descriptor instead.

func (Dataplane_Networking_Inbound_State) Number 

func (x Dataplane_Networking_Inbound_State) Number() protoreflect.EnumNumber

func (Dataplane_Networking_Inbound_State) String 

func (x Dataplane_Networking_Inbound_State) String() string

func (Dataplane_Networking_Inbound_State) Type 

func (Dataplane_Networking_Inbound_State) Type() protoreflect.EnumType

type Dataplane_Networking_Outbound 

type Dataplane_Networking_Outbound struct {

	// IP on which the consumed service will be available to this data plane
	// proxy. On Kubernetes, it's usually ClusterIP of a Service or PodIP of a
	// Headless Service. Defaults to 127.0.0.1
	Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// Port on which the consumed service will be available to this data plane
	// proxy. When transparent proxying is not used, Envoy will bind to this
	// port.
	Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// Tags of consumed data plane proxies.
	// `dubbo.io/service` tag is required.
	// These tags can then be referenced in `destinations` section of policies
	// like TrafficRoute or in `to` section in policies like MeshAccessLog. It
	// is recommended to only use `dubbo.io/service`. If you need to consume
	// specific data plane proxy of a service (for example: `version=v2`) the
	// better practice is to use TrafficRoute.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

Outbound describes a service consumed by the data plane proxy. For every defined Outbound there is a corresponding Envoy Listener.

func (*Dataplane_Networking_Outbound) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Outbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Outbound) GetAddress 

func (x *Dataplane_Networking_Outbound) GetAddress() string

func (*Dataplane_Networking_Outbound) GetPort 

func (x *Dataplane_Networking_Outbound) GetPort() uint32

func (*Dataplane_Networking_Outbound) GetService 

func (d *Dataplane_Networking_Outbound) GetService() string

GetService returns a service name represented by this outbound interface.

The purpose of this method is to encapsulate implementation detail that service is modeled as a tag rather than a separate field.

func (*Dataplane_Networking_Outbound) GetTags 

func (x *Dataplane_Networking_Outbound) GetTags() map[string]string

func (*Dataplane_Networking_Outbound) ProtoMessage 

func (*Dataplane_Networking_Outbound) ProtoMessage()

func (*Dataplane_Networking_Outbound) ProtoReflect 

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

func (*Dataplane_Networking_Outbound) Reset 

func (x *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) String 

func (x *Dataplane_Networking_Outbound) String() string

type Dataplane_Probes 

type Dataplane_Probes struct {

	// Port on which the probe endpoints will be exposed. This cannot overlap
	// with any other ports.
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// List of endpoints to expose without mTLS.
	Endpoints []*Dataplane_Probes_Endpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataplane_Probes) Descriptor deprecated 

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

Deprecated: Use Dataplane_Probes.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes) GetEndpoints 

func (x *Dataplane_Probes) GetEndpoints() []*Dataplane_Probes_Endpoint

func (*Dataplane_Probes) GetPort 

func (x *Dataplane_Probes) GetPort() uint32

func (*Dataplane_Probes) ProtoMessage 

func (*Dataplane_Probes) ProtoMessage()

func (*Dataplane_Probes) ProtoReflect 

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

func (*Dataplane_Probes) Reset 

func (x *Dataplane_Probes) Reset()

func (*Dataplane_Probes) String 

func (x *Dataplane_Probes) String() string

type Dataplane_Probes_Endpoint 

type Dataplane_Probes_Endpoint struct {

	// Inbound port is a port of the application from which we expose the
	// endpoint.
	InboundPort uint32 `protobuf:"varint,1,opt,name=inbound_port,json=inboundPort,proto3" json:"inbound_port,omitempty"`
	// Inbound path is a path of the application from which we expose the
	// endpoint. It is recommended to be as specific as possible.
	InboundPath string `protobuf:"bytes,2,opt,name=inbound_path,json=inboundPath,proto3" json:"inbound_path,omitempty"`
	// Path is a path on which we expose inbound path on the probes port.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*Dataplane_Probes_Endpoint) Descriptor deprecated 

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

Deprecated: Use Dataplane_Probes_Endpoint.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes_Endpoint) GetInboundPath 

func (x *Dataplane_Probes_Endpoint) GetInboundPath() string

func (*Dataplane_Probes_Endpoint) GetInboundPort 

func (x *Dataplane_Probes_Endpoint) GetInboundPort() uint32

func (*Dataplane_Probes_Endpoint) GetPath 

func (x *Dataplane_Probes_Endpoint) GetPath() string

func (*Dataplane_Probes_Endpoint) ProtoMessage 

func (*Dataplane_Probes_Endpoint) ProtoMessage()

func (*Dataplane_Probes_Endpoint) ProtoReflect 

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

func (*Dataplane_Probes_Endpoint) Reset 

func (x *Dataplane_Probes_Endpoint) Reset()

func (*Dataplane_Probes_Endpoint) String 

func (x *Dataplane_Probes_Endpoint) String() string

type DiscoveryServiceStats 

type DiscoveryServiceStats struct {

	// Number of xDS responses sent to the Dataplane.
	ResponsesSent uint64 `protobuf:"varint,1,opt,name=responses_sent,json=responsesSent,proto3" json:"responses_sent,omitempty"`
	// Number of xDS responses ACKed by the Dataplane.
	ResponsesAcknowledged uint64 `protobuf:"varint,2,opt,name=responses_acknowledged,json=responsesAcknowledged,proto3" json:"responses_acknowledged,omitempty"`
	// Number of xDS responses NACKed by the Dataplane.
	ResponsesRejected uint64 `protobuf:"varint,3,opt,name=responses_rejected,json=responsesRejected,proto3" json:"responses_rejected,omitempty"`
	// contains filtered or unexported fields
}

DiscoveryServiceStats defines all stats over a single xDS service.

func (*DiscoveryServiceStats) Descriptor deprecated 

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

Deprecated: Use DiscoveryServiceStats.ProtoReflect.Descriptor instead.

func (*DiscoveryServiceStats) GetResponsesAcknowledged 

func (x *DiscoveryServiceStats) GetResponsesAcknowledged() uint64

func (*DiscoveryServiceStats) GetResponsesRejected 

func (x *DiscoveryServiceStats) GetResponsesRejected() uint64

func (*DiscoveryServiceStats) GetResponsesSent 

func (x *DiscoveryServiceStats) GetResponsesSent() uint64

func (*DiscoveryServiceStats) ProtoMessage 

func (*DiscoveryServiceStats) ProtoMessage()

func (*DiscoveryServiceStats) ProtoReflect 

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

func (*DiscoveryServiceStats) Reset 

func (x *DiscoveryServiceStats) Reset()

func (*DiscoveryServiceStats) String 

func (x *DiscoveryServiceStats) String() string

type DiscoverySubscription 

type DiscoverySubscription struct {

	// Unique id per ADS subscription.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Control Plane instance that handled given subscription.
	ControlPlaneInstanceId string `` /* 131-byte string literal not displayed */
	// Time when a given Dataplane connected to the Control Plane.
	ConnectTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"`
	// Time when a given Dataplane disconnected from the Control Plane.
	DisconnectTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=disconnect_time,json=disconnectTime,proto3" json:"disconnect_time,omitempty"`
	// Status of the ADS subscription.
	Status *DiscoverySubscriptionStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// Version of Envoy and Dubbo dataplane
	Version *Version `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
	// Generation is an integer number which is periodically increased by the
	// status sink
	Generation uint32 `protobuf:"varint,7,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

DiscoverySubscription describes a single ADS subscription created by a Dataplane to the Control Plane. Ideally, there should be only one such subscription per Dataplane lifecycle. Presence of multiple subscriptions might indicate one of the following events: - transient loss of network connection between Dataplane and Control Plane - Dataplane restart (i.e. hot restart or crash) - Control Plane restart (i.e. rolling update or crash) - etc

func (*DiscoverySubscription) Descriptor deprecated 

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

Deprecated: Use DiscoverySubscription.ProtoReflect.Descriptor instead.

func (*DiscoverySubscription) GetConnectTime 

func (x *DiscoverySubscription) GetConnectTime() *timestamppb.Timestamp

func (*DiscoverySubscription) GetControlPlaneInstanceId 

func (x *DiscoverySubscription) GetControlPlaneInstanceId() string

func (*DiscoverySubscription) GetDisconnectTime 

func (x *DiscoverySubscription) GetDisconnectTime() *timestamppb.Timestamp

func (*DiscoverySubscription) GetGeneration 

func (x *DiscoverySubscription) GetGeneration() uint32

func (*DiscoverySubscription) GetId 

func (x *DiscoverySubscription) GetId() string

func (*DiscoverySubscription) GetStatus 

func (x *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscription) GetVersion 

func (x *DiscoverySubscription) GetVersion() *Version

func (*DiscoverySubscription) IsOnline 

func (x *DiscoverySubscription) IsOnline() bool

func (*DiscoverySubscription) ProtoMessage 

func (*DiscoverySubscription) ProtoMessage()

func (*DiscoverySubscription) ProtoReflect 

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

func (*DiscoverySubscription) Reset 

func (x *DiscoverySubscription) Reset()

func (*DiscoverySubscription) SetDisconnectTime 

func (x *DiscoverySubscription) SetDisconnectTime(t time.Time)

func (*DiscoverySubscription) String 

func (x *DiscoverySubscription) String() string

type DiscoverySubscriptionStatus 

type DiscoverySubscriptionStatus struct {

	// Time when status of a given ADS subscription was most recently updated.
	LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"`
	// Total defines an aggregate over individual xDS stats.
	Total *DiscoveryServiceStats `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"`
	// CDS defines all CDS stats.
	Cds *DiscoveryServiceStats `protobuf:"bytes,3,opt,name=cds,proto3" json:"cds,omitempty"`
	// EDS defines all EDS stats.
	Eds *DiscoveryServiceStats `protobuf:"bytes,4,opt,name=eds,proto3" json:"eds,omitempty"`
	// LDS defines all LDS stats.
	Lds *DiscoveryServiceStats `protobuf:"bytes,5,opt,name=lds,proto3" json:"lds,omitempty"`
	// RDS defines all RDS stats.
	Rds *DiscoveryServiceStats `protobuf:"bytes,6,opt,name=rds,proto3" json:"rds,omitempty"`
	// contains filtered or unexported fields
}

DiscoverySubscriptionStatus defines status of an ADS subscription.

func NewSubscriptionStatus 

func NewSubscriptionStatus(now time.Time) *DiscoverySubscriptionStatus

func (*DiscoverySubscriptionStatus) Descriptor deprecated 

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

Deprecated: Use DiscoverySubscriptionStatus.ProtoReflect.Descriptor instead.

func (*DiscoverySubscriptionStatus) GetCds 

func (x *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetEds 

func (x *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetLastUpdateTime 

func (x *DiscoverySubscriptionStatus) GetLastUpdateTime() *timestamppb.Timestamp

func (*DiscoverySubscriptionStatus) GetLds 

func (x *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetRds 

func (x *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetTotal 

func (x *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) ProtoMessage 

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) ProtoReflect 

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

func (*DiscoverySubscriptionStatus) Reset 

func (x *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf 

func (s *DiscoverySubscriptionStatus) StatsOf(typeUrl string) *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) String 

func (x *DiscoverySubscriptionStatus) String() string

type DubboDpVersion 

type DubboDpVersion struct {

	// Version number of Dubbo Dataplane
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Git tag of Dubbo Dataplane version
	GitTag string `protobuf:"bytes,2,opt,name=gitTag,proto3" json:"gitTag,omitempty"`
	// Git commit of Dubbo Dataplane version
	GitCommit string `protobuf:"bytes,3,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"`
	// Build date of Dubbo Dataplane version
	BuildDate string `protobuf:"bytes,4,opt,name=buildDate,proto3" json:"buildDate,omitempty"`
	// True iff Dubbo DP version is compatible with Dubbo CP version
	DubboCpCompatible bool `protobuf:"varint,5,opt,name=DubboCpCompatible,proto3" json:"DubboCpCompatible,omitempty"`
	// contains filtered or unexported fields
}

func (*DubboDpVersion) Descriptor deprecated 

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

Deprecated: Use DubboDpVersion.ProtoReflect.Descriptor instead.

func (*DubboDpVersion) GetBuildDate 

func (x *DubboDpVersion) GetBuildDate() string

func (*DubboDpVersion) GetDubboCpCompatible 

func (x *DubboDpVersion) GetDubboCpCompatible() bool

func (*DubboDpVersion) GetGitCommit 

func (x *DubboDpVersion) GetGitCommit() string

func (*DubboDpVersion) GetGitTag 

func (x *DubboDpVersion) GetGitTag() string

func (*DubboDpVersion) GetVersion 

func (x *DubboDpVersion) GetVersion() string

func (*DubboDpVersion) ProtoMessage 

func (*DubboDpVersion) ProtoMessage()

func (*DubboDpVersion) ProtoReflect 

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

func (*DubboDpVersion) Reset 

func (x *DubboDpVersion) Reset()

func (*DubboDpVersion) String 

func (x *DubboDpVersion) String() string

type DubboResource 

type DubboResource struct {
	Meta *DubboResource_Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Spec *anypb.Any          `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*DubboResource) Descriptor deprecated 

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

Deprecated: Use DubboResource.ProtoReflect.Descriptor instead.

func (*DubboResource) GetMeta 

func (x *DubboResource) GetMeta() *DubboResource_Meta

func (*DubboResource) GetSpec 

func (x *DubboResource) GetSpec() *anypb.Any

func (*DubboResource) ProtoMessage 

func (*DubboResource) ProtoMessage()

func (*DubboResource) ProtoReflect 

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

func (*DubboResource) Reset 

func (x *DubboResource) Reset()

func (*DubboResource) String 

func (x *DubboResource) String() string

type DubboResource_Meta 

type DubboResource_Meta struct {
	Name    string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mesh    string            `protobuf:"bytes,2,opt,name=mesh,proto3" json:"mesh,omitempty"`
	Version string            `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Labels  map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DubboResource_Meta) Descriptor deprecated 

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

Deprecated: Use DubboResource_Meta.ProtoReflect.Descriptor instead.

func (*DubboResource_Meta) GetLabels 

func (x *DubboResource_Meta) GetLabels() map[string]string

func (*DubboResource_Meta) GetMesh 

func (x *DubboResource_Meta) GetMesh() string

func (*DubboResource_Meta) GetName 

func (x *DubboResource_Meta) GetName() string

func (*DubboResource_Meta) GetVersion 

func (x *DubboResource_Meta) GetVersion() string

func (*DubboResource_Meta) ProtoMessage 

func (*DubboResource_Meta) ProtoMessage()

func (*DubboResource_Meta) ProtoReflect 

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

func (*DubboResource_Meta) Reset 

func (x *DubboResource_Meta) Reset()

func (*DubboResource_Meta) String 

func (x *DubboResource_Meta) String() string

type DynamicConfig 

type DynamicConfig struct {
	Key           string            `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Scope         string            `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	ConfigVersion string            `protobuf:"bytes,3,opt,name=configVersion,proto3" json:"configVersion,omitempty"`
	Enabled       bool              `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Configs       []*OverrideConfig `protobuf:"bytes,5,rep,name=configs,proto3" json:"configs,omitempty"`
	// contains filtered or unexported fields
}

func (*DynamicConfig) Descriptor deprecated 

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

Deprecated: Use DynamicConfig.ProtoReflect.Descriptor instead.

func (*DynamicConfig) GetConfigVersion 

func (x *DynamicConfig) GetConfigVersion() string

func (*DynamicConfig) GetConfigs 

func (x *DynamicConfig) GetConfigs() []*OverrideConfig

func (*DynamicConfig) GetEnabled 

func (x *DynamicConfig) GetEnabled() bool

func (*DynamicConfig) GetKey 

func (x *DynamicConfig) GetKey() string

func (*DynamicConfig) GetScope 

func (x *DynamicConfig) GetScope() string

func (*DynamicConfig) ListGenConfigs 

func (d *DynamicConfig) ListGenConfigs() []*OverrideConfig

func (*DynamicConfig) ListUnGenConfigs 

func (d *DynamicConfig) ListUnGenConfigs() []*OverrideConfig

func (*DynamicConfig) ProtoMessage 

func (*DynamicConfig) ProtoMessage()

func (*DynamicConfig) ProtoReflect 

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

func (*DynamicConfig) RangeConfig 

func (d *DynamicConfig) RangeConfig(f func(conf *OverrideConfig) (isStop bool))

func (*DynamicConfig) RangeConfigsToRemove 

func (d *DynamicConfig) RangeConfigsToRemove(matchFunc func(conf *OverrideConfig) (IsRemove bool))

func (*DynamicConfig) Reset 

func (x *DynamicConfig) Reset()

func (*DynamicConfig) String 

func (x *DynamicConfig) String() string

type EnvoyAdmin 

type EnvoyAdmin struct {

	// Port on which Envoy Admin API server will be listening
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyAdmin) Descriptor deprecated 

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

Deprecated: Use EnvoyAdmin.ProtoReflect.Descriptor instead.

func (*EnvoyAdmin) GetPort 

func (x *EnvoyAdmin) GetPort() uint32

func (*EnvoyAdmin) ProtoMessage 

func (*EnvoyAdmin) ProtoMessage()

func (*EnvoyAdmin) ProtoReflect 

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

func (*EnvoyAdmin) Reset 

func (x *EnvoyAdmin) Reset()

func (*EnvoyAdmin) String 

func (x *EnvoyAdmin) String() string

type EnvoyVersion 

type EnvoyVersion struct {

	// Version number of Envoy
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Full build tag of Envoy version
	Build string `protobuf:"bytes,2,opt,name=build,proto3" json:"build,omitempty"`
	// True iff Envoy version is compatible with Dubbo DP version
	DubboDpCompatible bool `protobuf:"varint,3,opt,name=DubboDpCompatible,proto3" json:"DubboDpCompatible,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvoyVersion) Descriptor deprecated 

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

Deprecated: Use EnvoyVersion.ProtoReflect.Descriptor instead.

func (*EnvoyVersion) GetBuild 

func (x *EnvoyVersion) GetBuild() string

func (*EnvoyVersion) GetDubboDpCompatible 

func (x *EnvoyVersion) GetDubboDpCompatible() bool

func (*EnvoyVersion) GetVersion 

func (x *EnvoyVersion) GetVersion() string

func (*EnvoyVersion) ProtoMessage 

func (*EnvoyVersion) ProtoMessage()

func (*EnvoyVersion) ProtoReflect 

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

func (*EnvoyVersion) Reset 

func (x *EnvoyVersion) Reset()

func (*EnvoyVersion) String 

func (x *EnvoyVersion) String() string

type FileLoggingBackendConfig 

type FileLoggingBackendConfig struct {

	// Path to a file that logs will be written to
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

FileLoggingBackendConfig defines configuration for file based access logs

func (*FileLoggingBackendConfig) Descriptor deprecated 

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

Deprecated: Use FileLoggingBackendConfig.ProtoReflect.Descriptor instead.

func (*FileLoggingBackendConfig) GetPath 

func (x *FileLoggingBackendConfig) GetPath() string

func (*FileLoggingBackendConfig) ProtoMessage 

func (*FileLoggingBackendConfig) ProtoMessage()

func (*FileLoggingBackendConfig) ProtoReflect 

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

func (*FileLoggingBackendConfig) Reset 

func (x *FileLoggingBackendConfig) Reset()

func (*FileLoggingBackendConfig) String 

func (x *FileLoggingBackendConfig) String() string

type GlobalDDSServiceClient 

type GlobalDDSServiceClient interface {
	// HealthCheck allows us to implement a health check that works across
	// proxies, unlike HTTP/2 PING frames.
	HealthCheck(ctx context.Context, in *ZoneHealthCheckRequest, opts ...grpc.CallOption) (*ZoneHealthCheckResponse, error)
}

GlobalDDSServiceClient is the client API for GlobalDDSService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGlobalDDSServiceClient 

func NewGlobalDDSServiceClient(cc grpc.ClientConnInterface) GlobalDDSServiceClient

type GlobalDDSServiceServer 

type GlobalDDSServiceServer interface {
	// HealthCheck allows us to implement a health check that works across
	// proxies, unlike HTTP/2 PING frames.
	HealthCheck(context.Context, *ZoneHealthCheckRequest) (*ZoneHealthCheckResponse, error)
	// contains filtered or unexported methods
}

GlobalDDSServiceServer is the server API for GlobalDDSService service. All implementations must embed UnimplementedGlobalDDSServiceServer for forward compatibility

type InboundInterface 

type InboundInterface struct {
	DataplaneAdvertisedIP string
	DataplaneIP           string
	DataplanePort         uint32
	WorkloadIP            string
	WorkloadPort          uint32
}

func (*InboundInterface) IsServiceLess 

func (i *InboundInterface) IsServiceLess() bool

func (InboundInterface) MarshalText 

func (i InboundInterface) MarshalText() ([]byte, error)

func (InboundInterface) String 

func (i InboundInterface) String() string

type ListStringMatch 

type ListStringMatch struct {
	Oneof []*StringMatch `protobuf:"bytes,1,rep,name=oneof,proto3" json:"oneof,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStringMatch) Descriptor deprecated 

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

Deprecated: Use ListStringMatch.ProtoReflect.Descriptor instead.

func (*ListStringMatch) GetOneof 

func (x *ListStringMatch) GetOneof() []*StringMatch

func (*ListStringMatch) ProtoMessage 

func (*ListStringMatch) ProtoMessage()

func (*ListStringMatch) ProtoReflect 

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

func (*ListStringMatch) Reset 

func (x *ListStringMatch) Reset()

func (*ListStringMatch) String 

func (x *ListStringMatch) String() string

type Logging 

type Logging struct {

	// Name of the default backend
	DefaultBackend string `protobuf:"bytes,1,opt,name=defaultBackend,proto3" json:"defaultBackend,omitempty"`
	// List of available logging backends
	Backends []*LoggingBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

func (*Logging) Descriptor deprecated 

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

Deprecated: Use Logging.ProtoReflect.Descriptor instead.

func (*Logging) GetBackends 

func (x *Logging) GetBackends() []*LoggingBackend

func (*Logging) GetDefaultBackend 

func (x *Logging) GetDefaultBackend() string

func (*Logging) ProtoMessage 

func (*Logging) ProtoMessage()

func (*Logging) ProtoReflect 

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

func (*Logging) Reset 

func (x *Logging) Reset()

func (*Logging) String 

func (x *Logging) String() string

type LoggingBackend 

type LoggingBackend struct {

	// Name of the backend, can be then used in Mesh.logging.defaultBackend or in
	// TrafficLogging
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Format of access logs. Placehodlers available on
	// https://www.envoyproxy.io/docs/envoy/latest/configuration/observability/access_log
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// Type of the backend (Dubbo ships with 'tcp' and 'file')
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// Configuration of the backend
	Conf *structpb.Struct `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

LoggingBackend defines logging backend available to mesh. Backends can be used in TrafficLog rules.

func (*LoggingBackend) Descriptor deprecated 

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

Deprecated: Use LoggingBackend.ProtoReflect.Descriptor instead.

func (*LoggingBackend) GetConf 

func (x *LoggingBackend) GetConf() *structpb.Struct

func (*LoggingBackend) GetFormat 

func (x *LoggingBackend) GetFormat() string

func (*LoggingBackend) GetName 

func (x *LoggingBackend) GetName() string

func (*LoggingBackend) GetType 

func (x *LoggingBackend) GetType() string

func (*LoggingBackend) ProtoMessage 

func (*LoggingBackend) ProtoMessage()

func (*LoggingBackend) ProtoReflect 

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

func (*LoggingBackend) Reset 

func (x *LoggingBackend) Reset()

func (*LoggingBackend) String 

func (x *LoggingBackend) String() string

type MDSSyncServiceClient 

type MDSSyncServiceClient interface {
	// MappingRegister from dp to cp, data plane register snp information to
	// control plane.
	MappingRegister(ctx context.Context, in *MappingRegisterRequest, opts ...grpc.CallOption) (*MappingRegisterResponse, error)
	MetadataRegister(ctx context.Context, in *MetaDataRegisterRequest, opts ...grpc.CallOption) (*MetaDataRegisterResponse, error)
	MetadataSync(ctx context.Context, opts ...grpc.CallOption) (MDSSyncService_MetadataSyncClient, error)
	// MappingSync from cp to dp, control plane sync snp information to data
	// plane. Only in Kubernetes environment without zk/nacos, this rpc works. In
	// other case (exists zk/nacos), data plane search in zk/nacos.
	//
	// data plane and control plane keep a streaming link:
	// when Mapping Resource updated, control plane sync Mapping Resource to
	// data plane.
	MappingSync(ctx context.Context, opts ...grpc.CallOption) (MDSSyncService_MappingSyncClient, error)
}

MDSSyncServiceClient is the client API for MDSSyncService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMDSSyncServiceClient 

func NewMDSSyncServiceClient(cc grpc.ClientConnInterface) MDSSyncServiceClient

type MDSSyncServiceServer 

type MDSSyncServiceServer interface {
	// MappingRegister from dp to cp, data plane register snp information to
	// control plane.
	MappingRegister(context.Context, *MappingRegisterRequest) (*MappingRegisterResponse, error)
	MetadataRegister(context.Context, *MetaDataRegisterRequest) (*MetaDataRegisterResponse, error)
	MetadataSync(MDSSyncService_MetadataSyncServer) error
	// MappingSync from cp to dp, control plane sync snp information to data
	// plane. Only in Kubernetes environment without zk/nacos, this rpc works. In
	// other case (exists zk/nacos), data plane search in zk/nacos.
	//
	// data plane and control plane keep a streaming link:
	// when Mapping Resource updated, control plane sync Mapping Resource to
	// data plane.
	MappingSync(MDSSyncService_MappingSyncServer) error
	// contains filtered or unexported methods
}

MDSSyncServiceServer is the server API for MDSSyncService service. All implementations must embed UnimplementedMDSSyncServiceServer for forward compatibility

type MDSSyncService_MappingSyncClient 

type MDSSyncService_MappingSyncClient interface {
	Send(*MappingSyncRequest) error
	Recv() (*MappingSyncResponse, error)
	grpc.ClientStream
}

type MDSSyncService_MappingSyncServer 

type MDSSyncService_MappingSyncServer interface {
	Send(*MappingSyncResponse) error
	Recv() (*MappingSyncRequest, error)
	grpc.ServerStream
}

type MDSSyncService_MetadataSyncClient 

type MDSSyncService_MetadataSyncClient interface {
	Send(*MetadataSyncRequest) error
	Recv() (*MetadataSyncResponse, error)
	grpc.ClientStream
}

type MDSSyncService_MetadataSyncServer 

type MDSSyncService_MetadataSyncServer interface {
	Send(*MetadataSyncResponse) error
	Recv() (*MetadataSyncRequest, error)
	grpc.ServerStream
}

type Mapping 

type Mapping struct {
	Zone             string   `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	InterfaceName    string   `protobuf:"bytes,2,opt,name=interfaceName,proto3" json:"interfaceName,omitempty"`
	ApplicationNames []string `protobuf:"bytes,3,rep,name=applicationNames,proto3" json:"applicationNames,omitempty"`
	// contains filtered or unexported fields
}

func (*Mapping) Descriptor deprecated 

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

Deprecated: Use Mapping.ProtoReflect.Descriptor instead.

func (*Mapping) GetApplicationNames 

func (x *Mapping) GetApplicationNames() []string

func (*Mapping) GetInterfaceName 

func (x *Mapping) GetInterfaceName() string

func (*Mapping) GetZone 

func (x *Mapping) GetZone() string

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) ProtoReflect 

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

func (*Mapping) Reset 

func (x *Mapping) Reset()

func (*Mapping) String 

func (x *Mapping) String() string

type MappingRegisterRequest 

type MappingRegisterRequest struct {
	Namespace       string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ApplicationName string   `protobuf:"bytes,2,opt,name=applicationName,proto3" json:"applicationName,omitempty"`
	InterfaceNames  []string `protobuf:"bytes,3,rep,name=interfaceNames,proto3" json:"interfaceNames,omitempty"`
	PodName         string   `protobuf:"bytes,4,opt,name=podName,proto3" json:"podName,omitempty"`
	// contains filtered or unexported fields
}

func (*MappingRegisterRequest) Descriptor deprecated 

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

Deprecated: Use MappingRegisterRequest.ProtoReflect.Descriptor instead.

func (*MappingRegisterRequest) GetApplicationName 

func (x *MappingRegisterRequest) GetApplicationName() string

func (*MappingRegisterRequest) GetInterfaceNames 

func (x *MappingRegisterRequest) GetInterfaceNames() []string

func (*MappingRegisterRequest) GetNamespace 

func (x *MappingRegisterRequest) GetNamespace() string

func (*MappingRegisterRequest) GetPodName 

func (x *MappingRegisterRequest) GetPodName() string

func (*MappingRegisterRequest) ProtoMessage 

func (*MappingRegisterRequest) ProtoMessage()

func (*MappingRegisterRequest) ProtoReflect 

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

func (*MappingRegisterRequest) Reset 

func (x *MappingRegisterRequest) Reset()

func (*MappingRegisterRequest) String 

func (x *MappingRegisterRequest) String() string

type MappingRegisterResponse 

type MappingRegisterResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*MappingRegisterResponse) Descriptor deprecated 

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

Deprecated: Use MappingRegisterResponse.ProtoReflect.Descriptor instead.

func (*MappingRegisterResponse) GetMessage 

func (x *MappingRegisterResponse) GetMessage() string

func (*MappingRegisterResponse) GetSuccess 

func (x *MappingRegisterResponse) GetSuccess() bool

func (*MappingRegisterResponse) ProtoMessage 

func (*MappingRegisterResponse) ProtoMessage()

func (*MappingRegisterResponse) ProtoReflect 

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

func (*MappingRegisterResponse) Reset 

func (x *MappingRegisterResponse) Reset()

func (*MappingRegisterResponse) String 

func (x *MappingRegisterResponse) String() string

type MappingSyncRequest 

type MappingSyncRequest struct {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Nonce         string `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	InterfaceName string `protobuf:"bytes,3,opt,name=interfaceName,proto3" json:"interfaceName,omitempty"`
	// contains filtered or unexported fields
}

func (*MappingSyncRequest) Descriptor deprecated 

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

Deprecated: Use MappingSyncRequest.ProtoReflect.Descriptor instead.

func (*MappingSyncRequest) GetInterfaceName 

func (x *MappingSyncRequest) GetInterfaceName() string

func (*MappingSyncRequest) GetNamespace 

func (x *MappingSyncRequest) GetNamespace() string

func (*MappingSyncRequest) GetNonce 

func (x *MappingSyncRequest) GetNonce() string

func (*MappingSyncRequest) ProtoMessage 

func (*MappingSyncRequest) ProtoMessage()

func (*MappingSyncRequest) ProtoReflect 

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

func (*MappingSyncRequest) Reset 

func (x *MappingSyncRequest) Reset()

func (*MappingSyncRequest) String 

func (x *MappingSyncRequest) String() string

type MappingSyncResponse 

type MappingSyncResponse struct {
	Nonce    string     `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Revision int64      `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	Mappings []*Mapping `protobuf:"bytes,3,rep,name=mappings,proto3" json:"mappings,omitempty"`
	// contains filtered or unexported fields
}

func (*MappingSyncResponse) Descriptor deprecated 

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

Deprecated: Use MappingSyncResponse.ProtoReflect.Descriptor instead.

func (*MappingSyncResponse) GetMappings 

func (x *MappingSyncResponse) GetMappings() []*Mapping

func (*MappingSyncResponse) GetNonce 

func (x *MappingSyncResponse) GetNonce() string

func (*MappingSyncResponse) GetRevision 

func (x *MappingSyncResponse) GetRevision() int64

func (*MappingSyncResponse) ProtoMessage 

func (*MappingSyncResponse) ProtoMessage()

func (*MappingSyncResponse) ProtoReflect 

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

func (*MappingSyncResponse) Reset 

func (x *MappingSyncResponse) Reset()

func (*MappingSyncResponse) String 

func (x *MappingSyncResponse) String() string

type Mesh 

type Mesh struct {

	// mTLS settings.
	// +optional
	Mtls *Mesh_Mtls `protobuf:"bytes,1,opt,name=mtls,proto3" json:"mtls,omitempty"`
	// Tracing settings.
	// +optional
	Tracing *Tracing `protobuf:"bytes,2,opt,name=tracing,proto3" json:"tracing,omitempty"`
	// Logging settings.
	// +optional
	Logging *Logging `protobuf:"bytes,3,opt,name=logging,proto3" json:"logging,omitempty"`
	// Networking settings of the mesh
	Networking *Networking `protobuf:"bytes,5,opt,name=networking,proto3" json:"networking,omitempty"`
	// Routing settings of the mesh
	Routing *Routing `protobuf:"bytes,6,opt,name=routing,proto3" json:"routing,omitempty"`
	// contains filtered or unexported fields
}

Mesh defines configuration of a single mesh.

func (*Mesh) Descriptor deprecated 

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

Deprecated: Use Mesh.ProtoReflect.Descriptor instead.

func (*Mesh) GetLogging 

func (x *Mesh) GetLogging() *Logging

func (*Mesh) GetMtls 

func (x *Mesh) GetMtls() *Mesh_Mtls

func (*Mesh) GetNetworking 

func (x *Mesh) GetNetworking() *Networking

func (*Mesh) GetRouting 

func (x *Mesh) GetRouting() *Routing

func (*Mesh) GetTracing 

func (x *Mesh) GetTracing() *Tracing

func (*Mesh) ProtoMessage 

func (*Mesh) ProtoMessage()

func (*Mesh) ProtoReflect 

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

func (*Mesh) Reset 

func (x *Mesh) Reset()

func (*Mesh) String 

func (x *Mesh) String() string

type MeshInsight 

type MeshInsight struct {
	Dataplanes *MeshInsight_DataplaneStat         `protobuf:"bytes,2,opt,name=dataplanes,proto3" json:"dataplanes,omitempty"`
	Policies   map[string]*MeshInsight_PolicyStat `` /* 157-byte string literal not displayed */
	DpVersions *MeshInsight_DpVersions            `protobuf:"bytes,4,opt,name=dpVersions,proto3" json:"dpVersions,omitempty"`
	// mTLS statistics
	MTLS             *MeshInsight_MTLS             `protobuf:"bytes,5,opt,name=mTLS,proto3" json:"mTLS,omitempty"`
	Services         *MeshInsight_ServiceStat      `protobuf:"bytes,6,opt,name=services,proto3" json:"services,omitempty"`
	DataplanesByType *MeshInsight_DataplanesByType `protobuf:"bytes,7,opt,name=dataplanesByType,proto3" json:"dataplanesByType,omitempty"`
	// contains filtered or unexported fields
}

MeshInsight defines the observed state of a Mesh.

func (*MeshInsight) Descriptor deprecated 

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

Deprecated: Use MeshInsight.ProtoReflect.Descriptor instead.

func (*MeshInsight) GetDataplanes 

func (x *MeshInsight) GetDataplanes() *MeshInsight_DataplaneStat

func (*MeshInsight) GetDataplanesByType 

func (x *MeshInsight) GetDataplanesByType() *MeshInsight_DataplanesByType

func (*MeshInsight) GetDpVersions 

func (x *MeshInsight) GetDpVersions() *MeshInsight_DpVersions

func (*MeshInsight) GetMTLS 

func (x *MeshInsight) GetMTLS() *MeshInsight_MTLS

func (*MeshInsight) GetPolicies 

func (x *MeshInsight) GetPolicies() map[string]*MeshInsight_PolicyStat

func (*MeshInsight) GetServices 

func (x *MeshInsight) GetServices() *MeshInsight_ServiceStat

func (*MeshInsight) ProtoMessage 

func (*MeshInsight) ProtoMessage()

func (*MeshInsight) ProtoReflect 

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

func (*MeshInsight) Reset 

func (x *MeshInsight) Reset()

func (*MeshInsight) String 

func (x *MeshInsight) String() string

type MeshInsight_DataplaneStat 

type MeshInsight_DataplaneStat struct {
	Total             uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Online            uint32 `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"`
	Offline           uint32 `protobuf:"varint,3,opt,name=offline,proto3" json:"offline,omitempty"`
	PartiallyDegraded uint32 `protobuf:"varint,4,opt,name=partially_degraded,json=partiallyDegraded,proto3" json:"partially_degraded,omitempty"`
	// contains filtered or unexported fields
}

DataplaneStat defines statistic specifically for Dataplane

func (*MeshInsight_DataplaneStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DataplaneStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplaneStat) GetOffline 

func (x *MeshInsight_DataplaneStat) GetOffline() uint32

func (*MeshInsight_DataplaneStat) GetOnline 

func (x *MeshInsight_DataplaneStat) GetOnline() uint32

func (*MeshInsight_DataplaneStat) GetPartiallyDegraded 

func (x *MeshInsight_DataplaneStat) GetPartiallyDegraded() uint32

func (*MeshInsight_DataplaneStat) GetTotal 

func (x *MeshInsight_DataplaneStat) GetTotal() uint32

func (*MeshInsight_DataplaneStat) ProtoMessage 

func (*MeshInsight_DataplaneStat) ProtoMessage()

func (*MeshInsight_DataplaneStat) ProtoReflect 

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

func (*MeshInsight_DataplaneStat) Reset 

func (x *MeshInsight_DataplaneStat) Reset()

func (*MeshInsight_DataplaneStat) String 

func (x *MeshInsight_DataplaneStat) String() string

type MeshInsight_DataplanesByType 

type MeshInsight_DataplanesByType struct {
	Standard *MeshInsight_DataplaneStat `protobuf:"bytes,1,opt,name=standard,proto3" json:"standard,omitempty"`
	// contains filtered or unexported fields
}

DataplanesByType defines statistics splitted by dataplane types

func (*MeshInsight_DataplanesByType) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DataplanesByType.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplanesByType) GetStandard 

func (x *MeshInsight_DataplanesByType) GetStandard() *MeshInsight_DataplaneStat

func (*MeshInsight_DataplanesByType) ProtoMessage 

func (*MeshInsight_DataplanesByType) ProtoMessage()

func (*MeshInsight_DataplanesByType) ProtoReflect 

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

func (*MeshInsight_DataplanesByType) Reset 

func (x *MeshInsight_DataplanesByType) Reset()

func (*MeshInsight_DataplanesByType) String 

func (x *MeshInsight_DataplanesByType) String() string

type MeshInsight_DpVersions 

type MeshInsight_DpVersions struct {

	// Dataplane stats grouped by DubboDP version
	DubboDp map[string]*MeshInsight_DataplaneStat `` /* 155-byte string literal not displayed */
	// Dataplane stats grouped by Envoy version
	Envoy map[string]*MeshInsight_DataplaneStat `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

DpVersions defines statistics grouped by dataplane versions

func (*MeshInsight_DpVersions) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DpVersions.ProtoReflect.Descriptor instead.

func (*MeshInsight_DpVersions) GetDubboDp 

func (x *MeshInsight_DpVersions) GetDubboDp() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_DpVersions) GetEnvoy 

func (x *MeshInsight_DpVersions) GetEnvoy() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_DpVersions) ProtoMessage 

func (*MeshInsight_DpVersions) ProtoMessage()

func (*MeshInsight_DpVersions) ProtoReflect 

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

func (*MeshInsight_DpVersions) Reset 

func (x *MeshInsight_DpVersions) Reset()

func (*MeshInsight_DpVersions) String 

func (x *MeshInsight_DpVersions) String() string

type MeshInsight_MTLS 

type MeshInsight_MTLS struct {

	// Dataplanes grouped by issued backends.
	IssuedBackends map[string]*MeshInsight_DataplaneStat `` /* 169-byte string literal not displayed */
	// Dataplanes grouped by supported backends.
	SupportedBackends map[string]*MeshInsight_DataplaneStat `` /* 175-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MeshInsight_MTLS) Descriptor deprecated 

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

Deprecated: Use MeshInsight_MTLS.ProtoReflect.Descriptor instead.

func (*MeshInsight_MTLS) GetIssuedBackends 

func (x *MeshInsight_MTLS) GetIssuedBackends() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_MTLS) GetSupportedBackends 

func (x *MeshInsight_MTLS) GetSupportedBackends() map[string]*MeshInsight_DataplaneStat

func (*MeshInsight_MTLS) ProtoMessage 

func (*MeshInsight_MTLS) ProtoMessage()

func (*MeshInsight_MTLS) ProtoReflect 

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

func (*MeshInsight_MTLS) Reset 

func (x *MeshInsight_MTLS) Reset()

func (*MeshInsight_MTLS) String 

func (x *MeshInsight_MTLS) String() string

type MeshInsight_PolicyStat 

type MeshInsight_PolicyStat struct {
	Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

PolicyStat defines statistic for all policies in general

func (*MeshInsight_PolicyStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_PolicyStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_PolicyStat) GetTotal 

func (x *MeshInsight_PolicyStat) GetTotal() uint32

func (*MeshInsight_PolicyStat) ProtoMessage 

func (*MeshInsight_PolicyStat) ProtoMessage()

func (*MeshInsight_PolicyStat) ProtoReflect 

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

func (*MeshInsight_PolicyStat) Reset 

func (x *MeshInsight_PolicyStat) Reset()

func (*MeshInsight_PolicyStat) String 

func (x *MeshInsight_PolicyStat) String() string

type MeshInsight_ServiceStat 

type MeshInsight_ServiceStat struct {
	Total    uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Internal uint32 `protobuf:"varint,2,opt,name=internal,proto3" json:"internal,omitempty"`
	External uint32 `protobuf:"varint,3,opt,name=external,proto3" json:"external,omitempty"`
	// contains filtered or unexported fields
}

ServiceStat defines statistics of mesh services

func (*MeshInsight_ServiceStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_ServiceStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_ServiceStat) GetExternal 

func (x *MeshInsight_ServiceStat) GetExternal() uint32

func (*MeshInsight_ServiceStat) GetInternal 

func (x *MeshInsight_ServiceStat) GetInternal() uint32

func (*MeshInsight_ServiceStat) GetTotal 

func (x *MeshInsight_ServiceStat) GetTotal() uint32

func (*MeshInsight_ServiceStat) ProtoMessage 

func (*MeshInsight_ServiceStat) ProtoMessage()

func (*MeshInsight_ServiceStat) ProtoReflect 

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

func (*MeshInsight_ServiceStat) Reset 

func (x *MeshInsight_ServiceStat) Reset()

func (*MeshInsight_ServiceStat) String 

func (x *MeshInsight_ServiceStat) String() string

type Mesh_Mtls 

type Mesh_Mtls struct {

	// Name of the enabled backend
	EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"`
	// List of available Certificate Authority backends
	Backends []*CertificateAuthorityBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

mTLS settings of a Mesh.

func (*Mesh_Mtls) Descriptor deprecated 

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

Deprecated: Use Mesh_Mtls.ProtoReflect.Descriptor instead.

func (*Mesh_Mtls) GetBackends 

func (x *Mesh_Mtls) GetBackends() []*CertificateAuthorityBackend

func (*Mesh_Mtls) GetEnabledBackend 

func (x *Mesh_Mtls) GetEnabledBackend() string

func (*Mesh_Mtls) ProtoMessage 

func (*Mesh_Mtls) ProtoMessage()

func (*Mesh_Mtls) ProtoReflect 

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

func (*Mesh_Mtls) Reset 

func (x *Mesh_Mtls) Reset()

func (*Mesh_Mtls) String 

func (x *Mesh_Mtls) String() string

type MetaData 

type MetaData struct {
	Zone     string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	App      string `protobuf:"bytes,2,opt,name=app,proto3" json:"app,omitempty"`
	Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// key format is '{group}/{interface name}:{version}:{protocol}'
	Services map[string]*ServiceInfo `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*MetaData) Descriptor deprecated 

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

Deprecated: Use MetaData.ProtoReflect.Descriptor instead.

func (*MetaData) GetApp 

func (x *MetaData) GetApp() string

func (*MetaData) GetRevision 

func (x *MetaData) GetRevision() string

func (*MetaData) GetServices 

func (x *MetaData) GetServices() map[string]*ServiceInfo

func (*MetaData) GetZone 

func (x *MetaData) GetZone() string

func (*MetaData) ProtoMessage 

func (*MetaData) ProtoMessage()

func (*MetaData) ProtoReflect 

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

func (*MetaData) Reset 

func (x *MetaData) Reset()

func (*MetaData) String 

func (x *MetaData) String() string

type MetaDataRegisterRequest 

type MetaDataRegisterRequest struct {
	Namespace string    `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName   string    `protobuf:"bytes,2,opt,name=podName,proto3" json:"podName,omitempty"`   // dubbo的应用实例名, 由sdk通过环境变量获取
	Metadata  *MetaData `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` // 上报的元数据
	// contains filtered or unexported fields
}

func (*MetaDataRegisterRequest) Descriptor deprecated 

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

Deprecated: Use MetaDataRegisterRequest.ProtoReflect.Descriptor instead.

func (*MetaDataRegisterRequest) GetMetadata 

func (x *MetaDataRegisterRequest) GetMetadata() *MetaData

func (*MetaDataRegisterRequest) GetNamespace 

func (x *MetaDataRegisterRequest) GetNamespace() string

func (*MetaDataRegisterRequest) GetPodName 

func (x *MetaDataRegisterRequest) GetPodName() string

func (*MetaDataRegisterRequest) ProtoMessage 

func (*MetaDataRegisterRequest) ProtoMessage()

func (*MetaDataRegisterRequest) ProtoReflect 

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

func (*MetaDataRegisterRequest) Reset 

func (x *MetaDataRegisterRequest) Reset()

func (*MetaDataRegisterRequest) String 

func (x *MetaDataRegisterRequest) String() string

type MetaDataRegisterResponse 

type MetaDataRegisterResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaDataRegisterResponse) Descriptor deprecated 

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

Deprecated: Use MetaDataRegisterResponse.ProtoReflect.Descriptor instead.

func (*MetaDataRegisterResponse) GetMessage 

func (x *MetaDataRegisterResponse) GetMessage() string

func (*MetaDataRegisterResponse) GetSuccess 

func (x *MetaDataRegisterResponse) GetSuccess() bool

func (*MetaDataRegisterResponse) ProtoMessage 

func (*MetaDataRegisterResponse) ProtoMessage()

func (*MetaDataRegisterResponse) ProtoReflect 

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

func (*MetaDataRegisterResponse) Reset 

func (x *MetaDataRegisterResponse) Reset()

func (*MetaDataRegisterResponse) String 

func (x *MetaDataRegisterResponse) String() string

type MetadataSyncRequest 

type MetadataSyncRequest struct {
	Namespace       string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Nonce           string `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	ApplicationName string `protobuf:"bytes,3,opt,name=applicationName,proto3" json:"applicationName,omitempty"`
	Revision        string `protobuf:"bytes,4,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

可以根据应用名和版本号进行获取

func (*MetadataSyncRequest) Descriptor deprecated 

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

Deprecated: Use MetadataSyncRequest.ProtoReflect.Descriptor instead.

func (*MetadataSyncRequest) GetApplicationName 

func (x *MetadataSyncRequest) GetApplicationName() string

func (*MetadataSyncRequest) GetNamespace 

func (x *MetadataSyncRequest) GetNamespace() string

func (*MetadataSyncRequest) GetNonce 

func (x *MetadataSyncRequest) GetNonce() string

func (*MetadataSyncRequest) GetRevision 

func (x *MetadataSyncRequest) GetRevision() string

func (*MetadataSyncRequest) ProtoMessage 

func (*MetadataSyncRequest) ProtoMessage()

func (*MetadataSyncRequest) ProtoReflect 

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

func (*MetadataSyncRequest) Reset 

func (x *MetadataSyncRequest) Reset()

func (*MetadataSyncRequest) String 

func (x *MetadataSyncRequest) String() string

type MetadataSyncResponse 

type MetadataSyncResponse struct {
	Nonce     string      `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Revision  int64       `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"`
	MetaDatum []*MetaData `protobuf:"bytes,3,rep,name=metaDatum,proto3" json:"metaDatum,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataSyncResponse) Descriptor deprecated 

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

Deprecated: Use MetadataSyncResponse.ProtoReflect.Descriptor instead.

func (*MetadataSyncResponse) GetMetaDatum 

func (x *MetadataSyncResponse) GetMetaDatum() []*MetaData

func (*MetadataSyncResponse) GetNonce 

func (x *MetadataSyncResponse) GetNonce() string

func (*MetadataSyncResponse) GetRevision 

func (x *MetadataSyncResponse) GetRevision() int64

func (*MetadataSyncResponse) ProtoMessage 

func (*MetadataSyncResponse) ProtoMessage()

func (*MetadataSyncResponse) ProtoReflect 

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

func (*MetadataSyncResponse) Reset 

func (x *MetadataSyncResponse) Reset()

func (*MetadataSyncResponse) String 

func (x *MetadataSyncResponse) String() string

type Metrics 

type Metrics struct {

	// Name of the enabled backend
	EnabledBackend string `protobuf:"bytes,1,opt,name=enabledBackend,proto3" json:"enabledBackend,omitempty"`
	// List of available Metrics backends
	Backends []*MetricsBackend `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"`
	// contains filtered or unexported fields
}

Metrics defines configuration for metrics that should be collected and exposed by dataplanes.

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetBackends 

func (x *Metrics) GetBackends() []*MetricsBackend

func (*Metrics) GetEnabledBackend 

func (x *Metrics) GetEnabledBackend() string

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type MetricsBackend 

type MetricsBackend struct {

	// Name of the backend, can be then used in Mesh.metrics.enabledBackend
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the backend (Dubbo ships with 'prometheus')
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Configuration of the backend
	Conf *structpb.Struct `protobuf:"bytes,3,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

MetricsBackend defines metric backends

func (*MetricsBackend) Descriptor deprecated 

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

Deprecated: Use MetricsBackend.ProtoReflect.Descriptor instead.

func (*MetricsBackend) GetConf 

func (x *MetricsBackend) GetConf() *structpb.Struct

func (*MetricsBackend) GetName 

func (x *MetricsBackend) GetName() string

func (*MetricsBackend) GetType 

func (x *MetricsBackend) GetType() string

func (*MetricsBackend) ProtoMessage 

func (*MetricsBackend) ProtoMessage()

func (*MetricsBackend) ProtoReflect 

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

func (*MetricsBackend) Reset 

func (x *MetricsBackend) Reset()

func (*MetricsBackend) String 

func (x *MetricsBackend) String() string

type MultiValueTagSet 

type MultiValueTagSet map[string]map[string]bool

Set of tags that allows multiple values per key.

func MultiValueTagSetFrom 

func MultiValueTagSetFrom(data map[string][]string) MultiValueTagSet

func (MultiValueTagSet) Keys 

func (t MultiValueTagSet) Keys() []string

func (MultiValueTagSet) String 

func (t MultiValueTagSet) String() string

func (MultiValueTagSet) UniqueValues 

func (t MultiValueTagSet) UniqueValues(key string) []string

func (MultiValueTagSet) Values 

func (t MultiValueTagSet) Values(key string) []string

type Networking 

type Networking struct {

	// Outbound settings
	Outbound *Networking_Outbound `protobuf:"bytes,1,opt,name=outbound,proto3" json:"outbound,omitempty"`
	// contains filtered or unexported fields
}

Networking defines the networking configuration of the mesh

func (*Networking) Descriptor deprecated 

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

Deprecated: Use Networking.ProtoReflect.Descriptor instead.

func (*Networking) GetOutbound 

func (x *Networking) GetOutbound() *Networking_Outbound

func (*Networking) ProtoMessage 

func (*Networking) ProtoMessage()

func (*Networking) ProtoReflect 

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

func (*Networking) Reset 

func (x *Networking) Reset()

func (*Networking) String 

func (x *Networking) String() string

type Networking_Outbound 

type Networking_Outbound struct {

	// Control the passthrough cluster
	Passthrough *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=passthrough,proto3" json:"passthrough,omitempty"`
	// contains filtered or unexported fields
}

Outbound describes the common mesh outbound settings

func (*Networking_Outbound) Descriptor deprecated 

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

Deprecated: Use Networking_Outbound.ProtoReflect.Descriptor instead.

func (*Networking_Outbound) GetPassthrough 

func (x *Networking_Outbound) GetPassthrough() *wrapperspb.BoolValue

func (*Networking_Outbound) ProtoMessage 

func (*Networking_Outbound) ProtoMessage()

func (*Networking_Outbound) ProtoReflect 

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

func (*Networking_Outbound) Reset 

func (x *Networking_Outbound) Reset()

func (*Networking_Outbound) String 

func (x *Networking_Outbound) String() string

type OutboundInterface 

type OutboundInterface struct {
	DataplaneIP   string
	DataplanePort uint32
}

func (OutboundInterface) MarshalText 

func (i OutboundInterface) MarshalText() ([]byte, error)

func (OutboundInterface) String 

func (i OutboundInterface) String() string

type OverrideConfig 

type OverrideConfig struct {
	Side              string            `protobuf:"bytes,1,opt,name=side,proto3" json:"side,omitempty"`
	Addresses         []string          `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	ProviderAddresses []string          `protobuf:"bytes,3,rep,name=providerAddresses,proto3" json:"providerAddresses,omitempty"`
	Parameters        map[string]string `` /* 161-byte string literal not displayed */
	Applications      []string          `protobuf:"bytes,5,rep,name=applications,proto3" json:"applications,omitempty"`
	Services          []string          `protobuf:"bytes,6,rep,name=services,proto3" json:"services,omitempty"`
	Type              string            `protobuf:"bytes,7,opt,name=type,proto3" json:"type,omitempty"`
	Enabled           bool              `protobuf:"varint,8,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Match             *ConditionMatch   `protobuf:"bytes,9,opt,name=match,proto3" json:"match,omitempty"`
	// to mark which config generate by control plane
	XGenerateByCp bool `protobuf:"varint,10,opt,name=__generate_by_cp,json=GenerateByCp,proto3" json:"__generate_by_cp,omitempty"`
	// contains filtered or unexported fields
}

func (*OverrideConfig) Descriptor deprecated 

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

Deprecated: Use OverrideConfig.ProtoReflect.Descriptor instead.

func (*OverrideConfig) GetAddresses 

func (x *OverrideConfig) GetAddresses() []string

func (*OverrideConfig) GetApplications 

func (x *OverrideConfig) GetApplications() []string

func (*OverrideConfig) GetEnabled 

func (x *OverrideConfig) GetEnabled() bool

func (*OverrideConfig) GetMatch 

func (x *OverrideConfig) GetMatch() *ConditionMatch

func (*OverrideConfig) GetParameters 

func (x *OverrideConfig) GetParameters() map[string]string

func (*OverrideConfig) GetProviderAddresses 

func (x *OverrideConfig) GetProviderAddresses() []string

func (*OverrideConfig) GetServices 

func (x *OverrideConfig) GetServices() []string

func (*OverrideConfig) GetSide 

func (x *OverrideConfig) GetSide() string

func (*OverrideConfig) GetType 

func (x *OverrideConfig) GetType() string

func (*OverrideConfig) GetXGenerateByCp 

func (x *OverrideConfig) GetXGenerateByCp() bool

func (*OverrideConfig) ProtoMessage 

func (*OverrideConfig) ProtoMessage()

func (*OverrideConfig) ProtoReflect 

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

func (*OverrideConfig) Reset 

func (x *OverrideConfig) Reset()

func (*OverrideConfig) String 

func (x *OverrideConfig) String() string

type ParamMatch 

type ParamMatch struct {
	Key   string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *StringMatch `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ParamMatch) Descriptor deprecated 

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

Deprecated: Use ParamMatch.ProtoReflect.Descriptor instead.

func (*ParamMatch) GetKey