v1alpha1

package
v0.0.0-...-02ae7d7 Latest Latest
Warning

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

Go to latest
Published: Dec 16, 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 (*CertificateAuthorityBackend) GetDpCert

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 (*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 (*CertificateAuthorityBackend_DpCert) ProtoMessage

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) ProtoReflect

func (*CertificateAuthorityBackend_DpCert) Reset

func (*CertificateAuthorityBackend_DpCert) 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

Deprecated: Use CertificateAuthorityBackend_DpCert_Rotation.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset

func (*CertificateAuthorityBackend_DpCert_Rotation) 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.

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 (*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 (*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 (*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 (*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 (*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 (*Dataplane_Networking_Inbound) GetState

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 (*Dataplane_Networking_Inbound) Reset

func (x *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) 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 (*Dataplane_Networking_Inbound_Health) ProtoMessage

func (*Dataplane_Networking_Inbound_Health) ProtoMessage()

func (*Dataplane_Networking_Inbound_Health) ProtoReflect

func (*Dataplane_Networking_Inbound_Health) Reset

func (*Dataplane_Networking_Inbound_Health) 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 (*Dataplane_Networking_Inbound_ServiceProbe) GetInterval

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTcp

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTimeout

func (*Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect

func (*Dataplane_Networking_Inbound_ServiceProbe) Reset

func (*Dataplane_Networking_Inbound_ServiceProbe) 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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe_Tcp.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) 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) Enum

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 (Dataplane_Networking_Inbound_State) String

func (Dataplane_Networking_Inbound_State) Type

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 (*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 (*Dataplane_Networking_Outbound) Reset

func (x *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) 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 (*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 (*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 (*DiscoverySubscriptionStatus) GetEds

func (*DiscoverySubscriptionStatus) GetLastUpdateTime

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

func (*DiscoverySubscriptionStatus) GetLds

func (*DiscoverySubscriptionStatus) GetRds

func (*DiscoverySubscriptionStatus) GetTotal

func (*DiscoverySubscriptionStatus) ProtoMessage

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) ProtoReflect

func (*DiscoverySubscriptionStatus) Reset

func (x *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf

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.

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.

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 (*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 (*MeshInsight_DataplanesByType) ProtoMessage

func (*MeshInsight_DataplanesByType) ProtoMessage()

func (*MeshInsight_DataplanesByType) ProtoReflect

func (*MeshInsight_DataplanesByType) Reset

func (x *MeshInsight_DataplanesByType) Reset()

func (*MeshInsight_DataplanesByType) 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 (*MeshInsight_DpVersions) GetEnvoy

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

func (x *ParamMatch) GetKey() string

func (*ParamMatch) GetValue

func (x *ParamMatch) GetValue() *StringMatch

func (*ParamMatch) ProtoMessage

func (*ParamMatch) ProtoMessage()

func (*ParamMatch) ProtoReflect

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

func (*ParamMatch) Reset

func (x *ParamMatch) Reset()

func (*ParamMatch) String

func (x *ParamMatch) String() string

type PrometheusAggregateMetricsConfig

type PrometheusAggregateMetricsConfig struct {

	// Name which identify given configuration.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Port on which a service expose HTTP endpoint with Prometheus metrics.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Path on which a service expose HTTP endpoint with Prometheus metrics.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// If false then the application won't be scrapped. If nil, then it is treated
	// as true and dubbo-dp scrapes metrics from the service.
	Enabled *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Address on which a service expose HTTP endpoint with Prometheus metrics.
	Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

PrometheusAggregateMetricsConfig defines endpoints that should be scrapped by dubbo-dp for prometheus metrics. Any configuration change require sidecar restart.

func (*PrometheusAggregateMetricsConfig) Descriptor deprecated

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

Deprecated: Use PrometheusAggregateMetricsConfig.ProtoReflect.Descriptor instead.

func (*PrometheusAggregateMetricsConfig) GetAddress

func (x *PrometheusAggregateMetricsConfig) GetAddress() string

func (*PrometheusAggregateMetricsConfig) GetEnabled

func (*PrometheusAggregateMetricsConfig) GetName

func (*PrometheusAggregateMetricsConfig) GetPath

func (*PrometheusAggregateMetricsConfig) GetPort

func (*PrometheusAggregateMetricsConfig) ProtoMessage

func (*PrometheusAggregateMetricsConfig) ProtoMessage()

func (*PrometheusAggregateMetricsConfig) ProtoReflect

func (*PrometheusAggregateMetricsConfig) Reset

func (*PrometheusAggregateMetricsConfig) String

type PrometheusEnvoyConfig

type PrometheusEnvoyConfig struct {

	// FilterRegex value that is going to be passed to Envoy for filtering
	// Envoy metrics.
	FilterRegex string `protobuf:"bytes,1,opt,name=filterRegex,proto3" json:"filterRegex,omitempty"`
	// If true then return metrics that Envoy has updated (counters incremented
	// at least once, gauges changed at least once, and histograms added to at
	// least once). If nil, then it is treated as false.
	UsedOnly *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=usedOnly,proto3" json:"usedOnly,omitempty"`
	// contains filtered or unexported fields
}

PrometheusEnvoyConfig defines filters that should be passed to Envoy for filtering.

func (*PrometheusEnvoyConfig) Descriptor deprecated

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

Deprecated: Use PrometheusEnvoyConfig.ProtoReflect.Descriptor instead.

func (*PrometheusEnvoyConfig) GetFilterRegex

func (x *PrometheusEnvoyConfig) GetFilterRegex() string

func (*PrometheusEnvoyConfig) GetUsedOnly

func (x *PrometheusEnvoyConfig) GetUsedOnly() *wrapperspb.BoolValue

func (*PrometheusEnvoyConfig) ProtoMessage

func (*PrometheusEnvoyConfig) ProtoMessage()

func (*PrometheusEnvoyConfig) ProtoReflect

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

func (*PrometheusEnvoyConfig) Reset

func (x *PrometheusEnvoyConfig) Reset()

func (*PrometheusEnvoyConfig) String

func (x *PrometheusEnvoyConfig) String() string

type PrometheusMetricsBackendConfig

type PrometheusMetricsBackendConfig struct {

	// Port on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Port uint32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Path on which a dataplane should expose HTTP endpoint with Prometheus
	// metrics.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// Tags associated with an application this dataplane is deployed next to,
	// e.g. service=web, version=1.0.
	// `service` tag is mandatory.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// If true then endpoints for scraping metrics won't require mTLS even if mTLS
	// is enabled in Mesh. If nil, then it is treated as false.
	SkipMTLS *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=skipMTLS,proto3" json:"skipMTLS,omitempty"`
	// Map with the configuration of applications which metrics are going to be
	// scrapped by dubbo-dp.
	Aggregate []*PrometheusAggregateMetricsConfig `protobuf:"bytes,5,rep,name=aggregate,proto3" json:"aggregate,omitempty"`
	// Configuration of Envoy's metrics.
	Envoy *PrometheusEnvoyConfig `protobuf:"bytes,6,opt,name=envoy,proto3" json:"envoy,omitempty"`
	// Configuration of TLS for prometheus listener.
	Tls *PrometheusTlsConfig `protobuf:"bytes,7,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

PrometheusMetricsBackendConfig defines configuration of Prometheus backend

func (*PrometheusMetricsBackendConfig) Descriptor deprecated

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

Deprecated: Use PrometheusMetricsBackendConfig.ProtoReflect.Descriptor instead.

func (*PrometheusMetricsBackendConfig) GetAggregate

func (*PrometheusMetricsBackendConfig) GetEnvoy

func (*PrometheusMetricsBackendConfig) GetPath

func (*PrometheusMetricsBackendConfig) GetPort

func (*PrometheusMetricsBackendConfig) GetSkipMTLS

func (*PrometheusMetricsBackendConfig) GetTags

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

func (*PrometheusMetricsBackendConfig) GetTls

func (*PrometheusMetricsBackendConfig) ProtoMessage

func (*PrometheusMetricsBackendConfig) ProtoMessage()

func (*PrometheusMetricsBackendConfig) ProtoReflect

func (*PrometheusMetricsBackendConfig) Reset

func (x *PrometheusMetricsBackendConfig) Reset()

func (*PrometheusMetricsBackendConfig) String

type PrometheusTlsConfig

type PrometheusTlsConfig struct {

	// mode defines how configured is the TLS for Prometheus.
	// Supported values, delegated, disabled, activeMTLSBackend. Default to
	// `activeMTLSBackend`.
	Mode PrometheusTlsConfig_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=dubbo.mesh.v1alpha1.PrometheusTlsConfig_Mode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

PrometheusEnvoyConfig defines Tls configuration for Prometheus listener.

func (*PrometheusTlsConfig) Descriptor deprecated

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

Deprecated: Use PrometheusTlsConfig.ProtoReflect.Descriptor instead.

func (*PrometheusTlsConfig) GetMode

func (*PrometheusTlsConfig) ProtoMessage

func (*PrometheusTlsConfig) ProtoMessage()

func (*PrometheusTlsConfig) ProtoReflect

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

func (*PrometheusTlsConfig) Reset

func (x *PrometheusTlsConfig) Reset()

func (*PrometheusTlsConfig) String

func (x *PrometheusTlsConfig) String() string

type PrometheusTlsConfig_Mode

type PrometheusTlsConfig_Mode int32
const (
	// control-plane delivers certificates to the prometheus listener.
	// This should be used when prometheus is running inside the Mesh.
	PrometheusTlsConfig_activeMTLSBackend PrometheusTlsConfig_Mode = 0
	// In this way user is resposible for providing certificates to dataplanes.
	// Path for the certificte and the key needs to be provided to the dataplane
	// by environments variables:
	// * DUBBO_DATAPLANE_RUNTIME_METRICS_CERT_PATH
	// * DUBBO_DATAPLANE_RUNTIME_METRICS_KEY_PATH
	PrometheusTlsConfig_providedTLS PrometheusTlsConfig_Mode = 1
	// allows disabling TLS for the prometheus listener.
	PrometheusTlsConfig_disabled PrometheusTlsConfig_Mode = 2
)

func (PrometheusTlsConfig_Mode) Descriptor

func (PrometheusTlsConfig_Mode) Enum

func (PrometheusTlsConfig_Mode) EnumDescriptor deprecated

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

Deprecated: Use PrometheusTlsConfig_Mode.Descriptor instead.

func (PrometheusTlsConfig_Mode) Number

func (PrometheusTlsConfig_Mode) String

func (x PrometheusTlsConfig_Mode) String() string

func (PrometheusTlsConfig_Mode) Type

type ProxyType

type ProxyType string
const (
	DataplaneProxyType ProxyType = "dataplane"
	IngressProxyType   ProxyType = "ingress"
	EgressProxyType    ProxyType = "egress"
)

func (ProxyType) IsValid

func (t ProxyType) IsValid() error

type ResourceOrigin

type ResourceOrigin string
const (
	GlobalResourceOrigin ResourceOrigin = "global"
	ZoneResourceOrigin   ResourceOrigin = "zone"
)

func (ResourceOrigin) IsValid

func (o ResourceOrigin) IsValid() error

type Routing

type Routing struct {

	// Enable the Locality Aware Load Balancing
	LocalityAwareLoadBalancing bool `protobuf:"varint,1,opt,name=localityAwareLoadBalancing,proto3" json:"localityAwareLoadBalancing,omitempty"`
	// Enable routing traffic to services in other zone or external services
	// through ZoneEgress. Default: false
	ZoneEgress bool `protobuf:"varint,2,opt,name=zoneEgress,proto3" json:"zoneEgress,omitempty"`
	// contains filtered or unexported fields
}

Routing defines configuration for the routing in the mesh

func (*Routing) Descriptor deprecated

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

Deprecated: Use Routing.ProtoReflect.Descriptor instead.

func (*Routing) GetLocalityAwareLoadBalancing

func (x *Routing) GetLocalityAwareLoadBalancing() bool

func (*Routing) GetZoneEgress

func (x *Routing) GetZoneEgress() bool

func (*Routing) ProtoMessage

func (*Routing) ProtoMessage()

func (*Routing) ProtoReflect

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

func (*Routing) Reset

func (x *Routing) Reset()

func (*Routing) String

func (x *Routing) String() string

type ServiceInfo

type ServiceInfo struct {
	Name     string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Group    string            `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	Version  string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Protocol string            `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Port     int64             `protobuf:"varint,5,opt,name=port,proto3" json:"port,omitempty"`
	Path     string            `protobuf:"bytes,6,opt,name=path,proto3" json:"path,omitempty"`
	Params   map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ServiceInfo) Descriptor deprecated

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

Deprecated: Use ServiceInfo.ProtoReflect.Descriptor instead.

func (*ServiceInfo) GetGroup

func (x *ServiceInfo) GetGroup() string

func (*ServiceInfo) GetName

func (x *ServiceInfo) GetName() string

func (*ServiceInfo) GetParams

func (x *ServiceInfo) GetParams() map[string]string

func (*ServiceInfo) GetPath

func (x *ServiceInfo) GetPath() string

func (*ServiceInfo) GetPort

func (x *ServiceInfo) GetPort() int64

func (*ServiceInfo) GetProtocol

func (x *ServiceInfo) GetProtocol() string

func (*ServiceInfo) GetVersion

func (x *ServiceInfo) GetVersion() string

func (*ServiceInfo) ProtoMessage

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) ProtoReflect

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

func (*ServiceInfo) Reset

func (x *ServiceInfo) Reset()

func (*ServiceInfo) String

func (x *ServiceInfo) String() string

type SingleValueTagSet

type SingleValueTagSet map[string]string

Set of tags that only allows a single value per key.

func (SingleValueTagSet) Exclude

func (SingleValueTagSet) Keys

func (t SingleValueTagSet) Keys() []string

func (SingleValueTagSet) String

func (t SingleValueTagSet) String() string

type StringMatch

type StringMatch struct {
	Exact    string `protobuf:"bytes,1,opt,name=exact,proto3" json:"exact,omitempty"`
	Prefix   string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Regex    string `protobuf:"bytes,3,opt,name=regex,proto3" json:"regex,omitempty"`
	Noempty  string `protobuf:"bytes,4,opt,name=noempty,proto3" json:"noempty,omitempty"`
	Empty    string `protobuf:"bytes,5,opt,name=empty,proto3" json:"empty,omitempty"`
	Wildcard string `protobuf:"bytes,6,opt,name=wildcard,proto3" json:"wildcard,omitempty"`
	// contains filtered or unexported fields
}

func (*StringMatch) Descriptor deprecated

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

Deprecated: Use StringMatch.ProtoReflect.Descriptor instead.

func (*StringMatch) GetEmpty

func (x *StringMatch) GetEmpty() string

func (*StringMatch) GetExact

func (x *StringMatch) GetExact() string

func (*StringMatch) GetNoempty

func (x *StringMatch) GetNoempty() string

func (*StringMatch) GetPrefix

func (x *StringMatch) GetPrefix() string

func (*StringMatch) GetRegex

func (x *StringMatch) GetRegex() string

func (*StringMatch) GetWildcard

func (x *StringMatch) GetWildcard() string

func (*StringMatch) ProtoMessage

func (*StringMatch) ProtoMessage()

func (*StringMatch) ProtoReflect

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

func (*StringMatch) Reset

func (x *StringMatch) Reset()

func (*StringMatch) String

func (x *StringMatch) String() string

type Tag

type Tag struct {
	Name      string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addresses []string      `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Match     []*ParamMatch `protobuf:"bytes,3,rep,name=match,proto3" json:"match,omitempty"`
	// to mark which config generate by control plane
	XGenerateByCp bool `protobuf:"varint,8,opt,name=__generate_by_cp,json=GenerateByCp,proto3" json:"__generate_by_cp,omitempty"`
	// contains filtered or unexported fields
}

func (*Tag) Descriptor deprecated

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetAddresses

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

func (*Tag) GetMatch

func (x *Tag) GetMatch() []*ParamMatch

func (*Tag) GetName

func (x *Tag) GetName() string

func (*Tag) GetXGenerateByCp

func (x *Tag) GetXGenerateByCp() bool

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect

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

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

type TagRoute

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

func (*TagRoute) Descriptor deprecated

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

Deprecated: Use TagRoute.ProtoReflect.Descriptor instead.

func (*TagRoute) GetConfigVersion

func (x *TagRoute) GetConfigVersion() string

func (*TagRoute) GetEnabled

func (x *TagRoute) GetEnabled() bool

func (*TagRoute) GetForce

func (x *TagRoute) GetForce() bool

func (*TagRoute) GetKey

func (x *TagRoute) GetKey() string

func (*TagRoute) GetPriority

func (x *TagRoute) GetPriority() int32

func (*TagRoute) GetRuntime

func (x *TagRoute) GetRuntime() bool

func (*TagRoute) GetTags

func (x *TagRoute) GetTags() []*Tag

func (*TagRoute) ListGenConfigs

func (x *TagRoute) ListGenConfigs() []*Tag

func (*TagRoute) ListUnGenConfigs

func (x *TagRoute) ListUnGenConfigs() []*Tag

func (*TagRoute) ProtoMessage

func (*TagRoute) ProtoMessage()

func (*TagRoute) ProtoReflect

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

func (*TagRoute) RangeTags

func (x *TagRoute) RangeTags(f func(*Tag) (isStop bool))

func (*TagRoute) RangeTagsToRemove

func (x *TagRoute) RangeTagsToRemove(f func(*Tag) (IsRemove bool))

func (*TagRoute) Reset

func (x *TagRoute) Reset()

func (*TagRoute) String

func (x *TagRoute) String() string

type TagSelector

type TagSelector map[string]string

func MatchAnyService

func MatchAnyService() TagSelector

func MatchService

func MatchService(service string) TagSelector

func MatchTags

func MatchTags(tags map[string]string) TagSelector

func (TagSelector) Equal

func (s TagSelector) Equal(other TagSelector) bool

func (TagSelector) Matches

func (s TagSelector) Matches(tags map[string]string) bool

func (TagSelector) MatchesFuzzy

func (s TagSelector) MatchesFuzzy(tags map[string]string) bool

func (TagSelector) Rank

func (s TagSelector) Rank() TagSelectorRank

type TagSelectorRank

type TagSelectorRank struct {
	// Number of tags that match by the exact value.
	ExactMatches int
	// Number of tags that match by a wildcard ('*').
	WildcardMatches int
}

TagSelectorRank helps to decide which of 2 selectors is more specific.

func (TagSelectorRank) CombinedWith

func (r TagSelectorRank) CombinedWith(other TagSelectorRank) TagSelectorRank

func (TagSelectorRank) CompareTo

func (r TagSelectorRank) CompareTo(other TagSelectorRank) int

type TcpLoggingBackendConfig

type TcpLoggingBackendConfig struct {

	// Address to TCP service that will receive logs
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

TcpLoggingBackendConfig defines configuration for TCP based access logs

func (*TcpLoggingBackendConfig) Descriptor deprecated

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

Deprecated: Use TcpLoggingBackendConfig.ProtoReflect.Descriptor instead.

func (*TcpLoggingBackendConfig) GetAddress

func (x *TcpLoggingBackendConfig) GetAddress() string

func (*TcpLoggingBackendConfig) ProtoMessage

func (*TcpLoggingBackendConfig) ProtoMessage()

func (*TcpLoggingBackendConfig) ProtoReflect

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

func (*TcpLoggingBackendConfig) Reset

func (x *TcpLoggingBackendConfig) Reset()

func (*TcpLoggingBackendConfig) String

func (x *TcpLoggingBackendConfig) String() string

type Tracing

type Tracing struct {

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

Tracing defines tracing configuration of the mesh.

func (*Tracing) Descriptor deprecated

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

Deprecated: Use Tracing.ProtoReflect.Descriptor instead.

func (*Tracing) GetBackends

func (x *Tracing) GetBackends() []*TracingBackend

func (*Tracing) GetDefaultBackend

func (x *Tracing) GetDefaultBackend() string

func (*Tracing) ProtoMessage

func (*Tracing) ProtoMessage()

func (*Tracing) ProtoReflect

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

func (*Tracing) Reset

func (x *Tracing) Reset()

func (*Tracing) String

func (x *Tracing) String() string

type TracingBackend

type TracingBackend struct {

	// Name of the backend, can be then used in Mesh.tracing.defaultBackend or in
	// TrafficTrace
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Percentage of traces that will be sent to the backend (range 0.0 - 100.0).
	// Empty value defaults to 100.0%
	Sampling *wrapperspb.DoubleValue `protobuf:"bytes,2,opt,name=sampling,proto3" json:"sampling,omitempty"`
	// Type of the backend (Dubbo ships with 'zipkin')
	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
}

TracingBackend defines tracing backend available to mesh. Backends can be used in TrafficTrace rules.

func (*TracingBackend) Descriptor deprecated

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

Deprecated: Use TracingBackend.ProtoReflect.Descriptor instead.

func (*TracingBackend) GetConf

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

func (*TracingBackend) GetName

func (x *TracingBackend) GetName() string

func (*TracingBackend) GetSampling

func (x *TracingBackend) GetSampling() *wrapperspb.DoubleValue

func (*TracingBackend) GetType

func (x *TracingBackend) GetType() string

func (*TracingBackend) ProtoMessage

func (*TracingBackend) ProtoMessage()

func (*TracingBackend) ProtoReflect

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

func (*TracingBackend) Reset

func (x *TracingBackend) Reset()

func (*TracingBackend) String

func (x *TracingBackend) String() string

type UnimplementedDDSSyncServiceServer

type UnimplementedDDSSyncServiceServer struct {
}

UnimplementedDDSSyncServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDDSSyncServiceServer) GlobalToZoneSync

func (UnimplementedDDSSyncServiceServer) ZoneToGlobalSync

type UnimplementedGlobalDDSServiceServer

type UnimplementedGlobalDDSServiceServer struct {
}

UnimplementedGlobalDDSServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGlobalDDSServiceServer) HealthCheck

type UnimplementedMDSSyncServiceServer

type UnimplementedMDSSyncServiceServer struct {
}

UnimplementedMDSSyncServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMDSSyncServiceServer) MappingRegister

func (UnimplementedMDSSyncServiceServer) MappingSync

func (UnimplementedMDSSyncServiceServer) MetadataRegister

func (UnimplementedMDSSyncServiceServer) MetadataSync

type UnsafeDDSSyncServiceServer

type UnsafeDDSSyncServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDDSSyncServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DDSSyncServiceServer will result in compilation errors.

type UnsafeGlobalDDSServiceServer

type UnsafeGlobalDDSServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeGlobalDDSServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GlobalDDSServiceServer will result in compilation errors.

type UnsafeMDSSyncServiceServer

type UnsafeMDSSyncServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeMDSSyncServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MDSSyncServiceServer will result in compilation errors.

type Version

type Version struct {

	// Version of Dubbo Dataplane
	DubboDp *DubboDpVersion `protobuf:"bytes,1,opt,name=DubboDp,proto3" json:"DubboDp,omitempty"`
	// Version of Envoy
	Envoy *EnvoyVersion `protobuf:"bytes,2,opt,name=envoy,proto3" json:"envoy,omitempty"`
	// Versions of other dependencies, i.e. CoreDNS
	Dependencies map[string]string `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

Version defines version of Dubbo

func NewVersion

func NewVersion() *Version

func (*Version) Descriptor deprecated

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetDependencies

func (x *Version) GetDependencies() map[string]string

func (*Version) GetDubboDp

func (x *Version) GetDubboDp() *DubboDpVersion

func (*Version) GetEnvoy

func (x *Version) GetEnvoy() *EnvoyVersion

func (*Version) ProtoMessage

func (*Version) ProtoMessage()

func (*Version) ProtoReflect

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

func (*Version) Reset

func (x *Version) Reset()

func (*Version) String

func (x *Version) String() string

type ZipkinTracingBackendConfig

type ZipkinTracingBackendConfig struct {

	// Address of Zipkin collector.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Generate 128bit traces. Default: false
	TraceId128Bit bool `protobuf:"varint,2,opt,name=traceId128bit,proto3" json:"traceId128bit,omitempty"`
	// Version of the API. values: httpJson, httpJsonV1, httpProto. Default:
	// httpJson see
	// https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/trace/v3/trace.proto#envoy-v3-api-enum-config-trace-v3-zipkinconfig-collectorendpointversion
	ApiVersion string `protobuf:"bytes,3,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// Determines whether client and server spans will share the same span
	// context. Default: true.
	// https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/trace/v3/zipkin.proto#config-trace-v3-zipkinconfig
	SharedSpanContext *wrapperspb.BoolValue `protobuf:"bytes,4,opt,name=sharedSpanContext,proto3" json:"sharedSpanContext,omitempty"`
	// contains filtered or unexported fields
}

func (*ZipkinTracingBackendConfig) Descriptor deprecated

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

Deprecated: Use ZipkinTracingBackendConfig.ProtoReflect.Descriptor instead.

func (*ZipkinTracingBackendConfig) GetApiVersion

func (x *ZipkinTracingBackendConfig) GetApiVersion() string

func (*ZipkinTracingBackendConfig) GetSharedSpanContext

func (x *ZipkinTracingBackendConfig) GetSharedSpanContext() *wrapperspb.BoolValue

func (*ZipkinTracingBackendConfig) GetTraceId128Bit

func (x *ZipkinTracingBackendConfig) GetTraceId128Bit() bool

func (*ZipkinTracingBackendConfig) GetUrl

func (x *ZipkinTracingBackendConfig) GetUrl() string

func (*ZipkinTracingBackendConfig) ProtoMessage

func (*ZipkinTracingBackendConfig) ProtoMessage()

func (*ZipkinTracingBackendConfig) ProtoReflect

func (*ZipkinTracingBackendConfig) Reset

func (x *ZipkinTracingBackendConfig) Reset()

func (*ZipkinTracingBackendConfig) String

func (x *ZipkinTracingBackendConfig) String() string

type ZoneEgress

type ZoneEgress struct {

	// Zone field contains Zone name where egress is serving, field will be
	// automatically set by Global Dubbo CP
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// Networking defines the address and port of the Egress to listen on.
	Networking *ZoneEgress_Networking `protobuf:"bytes,2,opt,name=networking,proto3" json:"networking,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneEgress) Descriptor deprecated

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

Deprecated: Use ZoneEgress.ProtoReflect.Descriptor instead.

func (*ZoneEgress) GetNetworking

func (x *ZoneEgress) GetNetworking() *ZoneEgress_Networking

func (*ZoneEgress) GetZone

func (x *ZoneEgress) GetZone() string

func (*ZoneEgress) ProtoMessage

func (*ZoneEgress) ProtoMessage()

func (*ZoneEgress) ProtoReflect

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

func (*ZoneEgress) Reset

func (x *ZoneEgress) Reset()

func (*ZoneEgress) String

func (x *ZoneEgress) String() string

type ZoneEgressInsight

type ZoneEgressInsight struct {

	// List of ADS subscriptions created by a given Zone Dubbo CP.
	Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ZoneEgressInsight defines the observed state of a Zone Egress.

func (*ZoneEgressInsight) Descriptor deprecated

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

Deprecated: Use ZoneEgressInsight.ProtoReflect.Descriptor instead.

func (*ZoneEgressInsight) GetSubscriptions

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

func (*ZoneEgressInsight) ProtoMessage

func (*ZoneEgressInsight) ProtoMessage()

func (*ZoneEgressInsight) ProtoReflect

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

func (*ZoneEgressInsight) Reset

func (x *ZoneEgressInsight) Reset()

func (*ZoneEgressInsight) String

func (x *ZoneEgressInsight) String() string

type ZoneEgress_Networking

type ZoneEgress_Networking struct {

	// Address on which inbound listener will be exposed
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Port of the inbound interface that will forward requests to the service.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Admin contains configuration related to Envoy Admin API
	Admin *EnvoyAdmin `protobuf:"bytes,3,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneEgress_Networking) Descriptor deprecated

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

Deprecated: Use ZoneEgress_Networking.ProtoReflect.Descriptor instead.

func (*ZoneEgress_Networking) GetAddress

func (x *ZoneEgress_Networking) GetAddress() string

func (*ZoneEgress_Networking) GetAdmin

func (x *ZoneEgress_Networking) GetAdmin() *EnvoyAdmin

func (*ZoneEgress_Networking) GetPort

func (x *ZoneEgress_Networking) GetPort() uint32

func (*ZoneEgress_Networking) ProtoMessage

func (*ZoneEgress_Networking) ProtoMessage()

func (*ZoneEgress_Networking) ProtoReflect

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

func (*ZoneEgress_Networking) Reset

func (x *ZoneEgress_Networking) Reset()

func (*ZoneEgress_Networking) String

func (x *ZoneEgress_Networking) String() string

type ZoneHealthCheckRequest

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

func (*ZoneHealthCheckRequest) Descriptor deprecated

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

Deprecated: Use ZoneHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*ZoneHealthCheckRequest) ProtoMessage

func (*ZoneHealthCheckRequest) ProtoMessage()

func (*ZoneHealthCheckRequest) ProtoReflect

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

func (*ZoneHealthCheckRequest) Reset

func (x *ZoneHealthCheckRequest) Reset()

func (*ZoneHealthCheckRequest) String

func (x *ZoneHealthCheckRequest) String() string

type ZoneHealthCheckResponse

type ZoneHealthCheckResponse struct {

	// The the interval that the global control plane
	// expects between health check pings
	Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneHealthCheckResponse) Descriptor deprecated

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

Deprecated: Use ZoneHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*ZoneHealthCheckResponse) GetInterval

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

func (*ZoneHealthCheckResponse) ProtoMessage

func (*ZoneHealthCheckResponse) ProtoMessage()

func (*ZoneHealthCheckResponse) ProtoReflect

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

func (*ZoneHealthCheckResponse) Reset

func (x *ZoneHealthCheckResponse) Reset()

func (*ZoneHealthCheckResponse) String

func (x *ZoneHealthCheckResponse) String() string

type ZoneIngress

type ZoneIngress struct {
	Zone              string                          `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	Networking        *ZoneIngress_Networking         `protobuf:"bytes,2,opt,name=networking,proto3" json:"networking,omitempty"`
	AvailableServices []*ZoneIngress_AvailableService `protobuf:"bytes,3,rep,name=availableServices,proto3" json:"availableServices,omitempty"`
	// contains filtered or unexported fields
}

ZoneIngress allows us to configure dataplane in the Ingress mode. In this mode, dataplane has only inbound interfaces. Every inbound interface matches with services that reside in that cluster.

func (*ZoneIngress) Descriptor deprecated

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

Deprecated: Use ZoneIngress.ProtoReflect.Descriptor instead.

func (*ZoneIngress) GetAvailableServices

func (x *ZoneIngress) GetAvailableServices() []*ZoneIngress_AvailableService

func (*ZoneIngress) GetNetworking

func (x *ZoneIngress) GetNetworking() *ZoneIngress_Networking

func (*ZoneIngress) GetZone

func (x *ZoneIngress) GetZone() string

func (*ZoneIngress) ProtoMessage

func (*ZoneIngress) ProtoMessage()

func (*ZoneIngress) ProtoReflect

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

func (*ZoneIngress) Reset

func (x *ZoneIngress) Reset()

func (*ZoneIngress) String

func (x *ZoneIngress) String() string

type ZoneIngressInsight

type ZoneIngressInsight struct {

	// List of ADS subscriptions created by a given Zone Dubbo CP.
	Subscriptions []*DiscoverySubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// contains filtered or unexported fields
}

ZoneIngressInsight defines the observed state of a Zone Ingress.

func (*ZoneIngressInsight) AllSubscriptions

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

func (*ZoneIngressInsight) Descriptor deprecated

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

Deprecated: Use ZoneIngressInsight.ProtoReflect.Descriptor instead.

func (*ZoneIngressInsight) GetLastSubscription

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

func (*ZoneIngressInsight) GetSubscription

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

func (*ZoneIngressInsight) GetSubscriptions

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

func (*ZoneIngressInsight) IsOnline

func (x *ZoneIngressInsight) IsOnline() bool

func (*ZoneIngressInsight) ProtoMessage

func (*ZoneIngressInsight) ProtoMessage()

func (*ZoneIngressInsight) ProtoReflect

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

func (*ZoneIngressInsight) Reset

func (x *ZoneIngressInsight) Reset()

func (*ZoneIngressInsight) String

func (x *ZoneIngressInsight) String() string

func (*ZoneIngressInsight) Sum

func (*ZoneIngressInsight) UpdateSubscription

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

type ZoneIngress_AvailableService

type ZoneIngress_AvailableService struct {
	Tags      map[string]string `` /* 149-byte string literal not displayed */
	Instances uint32            `protobuf:"varint,2,opt,name=instances,proto3" json:"instances,omitempty"`
	Mesh      string            `protobuf:"bytes,3,opt,name=mesh,proto3" json:"mesh,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneIngress_AvailableService) Descriptor deprecated

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

Deprecated: Use ZoneIngress_AvailableService.ProtoReflect.Descriptor instead.

func (*ZoneIngress_AvailableService) GetInstances

func (x *ZoneIngress_AvailableService) GetInstances() uint32

func (*ZoneIngress_AvailableService) GetMesh

func (x *ZoneIngress_AvailableService) GetMesh() string

func (*ZoneIngress_AvailableService) GetTags

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

func (*ZoneIngress_AvailableService) ProtoMessage

func (*ZoneIngress_AvailableService) ProtoMessage()

func (*ZoneIngress_AvailableService) ProtoReflect

func (*ZoneIngress_AvailableService) Reset

func (x *ZoneIngress_AvailableService) Reset()

func (*ZoneIngress_AvailableService) String

type ZoneIngress_Networking

type ZoneIngress_Networking struct {
	Address           string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	AdvertisedAddress string `protobuf:"bytes,2,opt,name=advertisedAddress,proto3" json:"advertisedAddress,omitempty"`
	Port              uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	AdvertisedPort    uint32 `protobuf:"varint,4,opt,name=advertisedPort,proto3" json:"advertisedPort,omitempty"`
	// Admin contains configuration related to Envoy Admin API
	Admin *EnvoyAdmin `protobuf:"bytes,5,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneIngress_Networking) Descriptor deprecated

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

Deprecated: Use ZoneIngress_Networking.ProtoReflect.Descriptor instead.

func (*ZoneIngress_Networking) GetAddress

func (x *ZoneIngress_Networking) GetAddress() string

func (*ZoneIngress_Networking) GetAdmin

func (x *ZoneIngress_Networking) GetAdmin() *EnvoyAdmin

func (*ZoneIngress_Networking) GetAdvertisedAddress

func (x *ZoneIngress_Networking) GetAdvertisedAddress() string

func (*ZoneIngress_Networking) GetAdvertisedPort

func (x *ZoneIngress_Networking) GetAdvertisedPort() uint32

func (*ZoneIngress_Networking) GetPort

func (x *ZoneIngress_Networking) GetPort() uint32

func (*ZoneIngress_Networking) ProtoMessage

func (*ZoneIngress_Networking) ProtoMessage()

func (*ZoneIngress_Networking) ProtoReflect

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

func (*ZoneIngress_Networking) Reset

func (x *ZoneIngress_Networking) Reset()

func (*ZoneIngress_Networking) String

func (x *ZoneIngress_Networking) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL