v1alpha1

package
v0.0.0-...-ad79e7e Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2024 License: Apache-2.0 Imports: 28 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 (
	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 DubboDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.DubboDiscoveryService",
	HandlerType: (*DubboDiscoveryServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamDubboResources",
			Handler:       _DubboDiscoveryService_StreamDubboResources_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/mesh/v1alpha1/dds.proto",
}

DubboDiscoveryService_ServiceDesc is the grpc.ServiceDesc for DubboDiscoveryService 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_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_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 MetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.MetadataService",
	HandlerType: (*MetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MetadataRegister",
			Handler:    _MetadataService_MetadataRegister_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MetadataSync",
			Handler:       _MetadataService_MetadataSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/mesh/v1alpha1/metadata.proto",
}

MetadataService_ServiceDesc is the grpc.ServiceDesc for MetadataService 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 ServiceNameMappingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.mesh.v1alpha1.ServiceNameMappingService",
	HandlerType: (*ServiceNameMappingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MappingRegister",
			Handler:    _ServiceNameMappingService_MappingRegister_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MappingSync",
			Handler:       _ServiceNameMappingService_MappingSync_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/mesh/v1alpha1/mapping.proto",
}

ServiceNameMappingService_ServiceDesc is the grpc.ServiceDesc for ServiceNameMappingService 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 RegisterDubboDiscoveryServiceServer 

func RegisterDubboDiscoveryServiceServer(s grpc.ServiceRegistrar, srv DubboDiscoveryServiceServer)

func RegisterGlobalDDSServiceServer 

func RegisterGlobalDDSServiceServer(s grpc.ServiceRegistrar, srv GlobalDDSServiceServer)

func RegisterMetadataServiceServer 

func RegisterMetadataServiceServer(s grpc.ServiceRegistrar, srv MetadataServiceServer)

func RegisterServiceNameMappingServiceServer 

func RegisterServiceNameMappingServiceServer(s grpc.ServiceRegistrar, srv ServiceNameMappingServiceServer)

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 Base 

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

type CertificateAuthorityBackend 

type CertificateAuthorityBackend struct {

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

CertificateAuthorityBackend defines Certificate Authority backend

func (*CertificateAuthorityBackend) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend) GetConf 

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

func (*CertificateAuthorityBackend) GetDpCert 

func (x *CertificateAuthorityBackend) GetDpCert() *CertificateAuthorityBackend_DpCert

func (*CertificateAuthorityBackend) GetName 

func (x *CertificateAuthorityBackend) GetName() string

func (*CertificateAuthorityBackend) GetType 

func (x *CertificateAuthorityBackend) GetType() string

func (*CertificateAuthorityBackend) ProtoMessage 

func (*CertificateAuthorityBackend) ProtoMessage()

func (*CertificateAuthorityBackend) ProtoReflect 

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

func (*CertificateAuthorityBackend) Reset 

func (x *CertificateAuthorityBackend) Reset()

func (*CertificateAuthorityBackend) String 

func (x *CertificateAuthorityBackend) String() string

type CertificateAuthorityBackend_DpCert 

type CertificateAuthorityBackend_DpCert struct {

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

DpCert defines settings for certificates generated for Dataplanes

func (*CertificateAuthorityBackend_DpCert) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend_DpCert.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert) GetRotation 

func (x *CertificateAuthorityBackend_DpCert) GetRotation() *CertificateAuthorityBackend_DpCert_Rotation

func (*CertificateAuthorityBackend_DpCert) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert) ProtoReflect 

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

func (*CertificateAuthorityBackend_DpCert) Reset 

func (x *CertificateAuthorityBackend_DpCert) Reset()

func (*CertificateAuthorityBackend_DpCert) String 

func (x *CertificateAuthorityBackend_DpCert) String() string

type CertificateAuthorityBackend_DpCert_Rotation 

type CertificateAuthorityBackend_DpCert_Rotation struct {

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

Rotation defines rotation settings for Dataplane certificate

func (*CertificateAuthorityBackend_DpCert_Rotation) Descriptor deprecated 

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

Deprecated: Use CertificateAuthorityBackend_DpCert_Rotation.ProtoReflect.Descriptor instead.

func (*CertificateAuthorityBackend_DpCert_Rotation) GetExpiration 

func (x *CertificateAuthorityBackend_DpCert_Rotation) GetExpiration() string

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage 

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoMessage()

func (*CertificateAuthorityBackend_DpCert_Rotation) ProtoReflect 

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

func (*CertificateAuthorityBackend_DpCert_Rotation) Reset 

func (x *CertificateAuthorityBackend_DpCert_Rotation) Reset()

func (*CertificateAuthorityBackend_DpCert_Rotation) String 

func (x *CertificateAuthorityBackend_DpCert_Rotation) String() string

type ConditionMatch 

type ConditionMatch struct {
	Address     *AddressMatch    `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	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) 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 {
	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 (*ConditionRoute) Descriptor deprecated 

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

Deprecated: Use ConditionRoute.ProtoReflect.Descriptor instead.

func (*ConditionRoute) GetConditions 

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

func (*ConditionRoute) GetConfigVersion 

func (x *ConditionRoute) GetConfigVersion() string

func (*ConditionRoute) GetEnabled 

func (x *ConditionRoute) GetEnabled() bool

func (*ConditionRoute) GetForce 

func (x *ConditionRoute) GetForce() bool

func (*ConditionRoute) GetKey 

func (x *ConditionRoute) GetKey() string

func (*ConditionRoute) GetPriority 

func (x *ConditionRoute) GetPriority() int32

func (*ConditionRoute) GetRuntime 

func (x *ConditionRoute) GetRuntime() bool

func (*ConditionRoute) GetScope 

func (x *ConditionRoute) GetScope() 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

type DDSSyncServiceClient 

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

DDSSyncServiceClient is the client API for DDSSyncService service.

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

func NewDDSSyncServiceClient 

func NewDDSSyncServiceClient(cc grpc.ClientConnInterface) DDSSyncServiceClient

type DDSSyncServiceServer 

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

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

type DDSSyncService_GlobalToZoneSyncClient 

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

type DDSSyncService_GlobalToZoneSyncServer 

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

type DDSSyncService_ZoneToGlobalSyncClient 

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

type DDSSyncService_ZoneToGlobalSyncServer 

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

type Dataplane 

type Dataplane struct {

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

Dataplane defines configuration of a side-car proxy.

func (*Dataplane) Descriptor deprecated 

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

Deprecated: Use Dataplane.ProtoReflect.Descriptor instead.

func (*Dataplane) GetExtensions 

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

func (*Dataplane) GetIdentifyingService 

func (d *Dataplane) GetIdentifyingService() string

func (*Dataplane) GetMetrics 

func (x *Dataplane) GetMetrics() *MetricsBackend

func (*Dataplane) GetNetworking 

func (x *Dataplane) GetNetworking() *Dataplane_Networking

func (*Dataplane) GetProbes 

func (x *Dataplane) GetProbes() *Dataplane_Probes

func (*Dataplane) ProtoMessage 

func (*Dataplane) ProtoMessage()

func (*Dataplane) ProtoReflect 

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

func (*Dataplane) Reset 

func (x *Dataplane) Reset()

func (*Dataplane) SingleValueTagSets 

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

func (*Dataplane) String 

func (x *Dataplane) String() string

func (*Dataplane) TagSet 

func (d *Dataplane) TagSet() MultiValueTagSet

type DataplaneInsight 

type DataplaneInsight struct {

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

DataplaneInsight defines the observed state of a Dataplane.

func (*DataplaneInsight) AllSubscriptions 

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

func (*DataplaneInsight) Descriptor deprecated 

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

Deprecated: Use DataplaneInsight.ProtoReflect.Descriptor instead.

func (*DataplaneInsight) GetLastSubscription 

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

func (*DataplaneInsight) GetMTLS 

func (x *DataplaneInsight) GetMTLS() *DataplaneInsight_MTLS

func (*DataplaneInsight) GetSubscription 

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

func (*DataplaneInsight) GetSubscriptions 

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

func (*DataplaneInsight) IsOnline 

func (x *DataplaneInsight) IsOnline() bool

func (*DataplaneInsight) ProtoMessage 

func (*DataplaneInsight) ProtoMessage()

func (*DataplaneInsight) ProtoReflect 

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

func (*DataplaneInsight) Reset 

func (x *DataplaneInsight) Reset()

func (*DataplaneInsight) String 

func (x *DataplaneInsight) String() string

func (*DataplaneInsight) Sum 

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

func (*DataplaneInsight) UpdateCert 

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

func (*DataplaneInsight) UpdateSubscription 

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

type DataplaneInsight_MTLS 

type DataplaneInsight_MTLS struct {

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

MTLS defines insights for mTLS

func (*DataplaneInsight_MTLS) Descriptor deprecated 

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

Deprecated: Use DataplaneInsight_MTLS.ProtoReflect.Descriptor instead.

func (*DataplaneInsight_MTLS) GetCertificateExpirationTime 

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

func (*DataplaneInsight_MTLS) GetCertificateRegenerations 

func (x *DataplaneInsight_MTLS) GetCertificateRegenerations() uint32

func (*DataplaneInsight_MTLS) GetIssuedBackend 

func (x *DataplaneInsight_MTLS) GetIssuedBackend() string

func (*DataplaneInsight_MTLS) GetLastCertificateRegeneration 

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

func (*DataplaneInsight_MTLS) GetSupportedBackends 

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

func (*DataplaneInsight_MTLS) ProtoMessage 

func (*DataplaneInsight_MTLS) ProtoMessage()

func (*DataplaneInsight_MTLS) ProtoReflect 

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

func (*DataplaneInsight_MTLS) Reset 

func (x *DataplaneInsight_MTLS) Reset()

func (*DataplaneInsight_MTLS) String 

func (x *DataplaneInsight_MTLS) String() string

type Dataplane_Networking 

type Dataplane_Networking struct {

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

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

func (*Dataplane_Networking) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking) GetAddress 

func (x *Dataplane_Networking) GetAddress() string

func (*Dataplane_Networking) GetAdmin 

func (x *Dataplane_Networking) GetAdmin() *EnvoyAdmin

func (*Dataplane_Networking) GetAdvertisedAddress 

func (x *Dataplane_Networking) GetAdvertisedAddress() string

func (*Dataplane_Networking) GetHealthyInbounds 

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

func (*Dataplane_Networking) GetInbound 

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

func (*Dataplane_Networking) GetInboundForPort 

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

func (*Dataplane_Networking) GetInboundInterface 

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

func (*Dataplane_Networking) GetInboundInterfaces 

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

func (*Dataplane_Networking) GetOutbound 

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

func (*Dataplane_Networking) GetOutboundInterfaces 

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

func (*Dataplane_Networking) ProtoMessage 

func (*Dataplane_Networking) ProtoMessage()

func (*Dataplane_Networking) ProtoReflect 

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

func (*Dataplane_Networking) Reset 

func (x *Dataplane_Networking) Reset()

func (*Dataplane_Networking) String 

func (x *Dataplane_Networking) String() string

func (*Dataplane_Networking) ToInboundInterface 

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

func (*Dataplane_Networking) ToOutboundInterface 

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

type Dataplane_Networking_Inbound 

type Dataplane_Networking_Inbound struct {

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

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

func (*Dataplane_Networking_Inbound) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound) GetAddress 

func (x *Dataplane_Networking_Inbound) GetAddress() string

func (*Dataplane_Networking_Inbound) GetHealth 

func (x *Dataplane_Networking_Inbound) GetHealth() *Dataplane_Networking_Inbound_Health

func (*Dataplane_Networking_Inbound) GetPort 

func (x *Dataplane_Networking_Inbound) GetPort() uint32

func (*Dataplane_Networking_Inbound) GetProtocol 

func (d *Dataplane_Networking_Inbound) GetProtocol() string

GetProtocol returns a protocol supported by this inbound interface.

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

func (*Dataplane_Networking_Inbound) GetService 

func (d *Dataplane_Networking_Inbound) GetService() string

GetService returns a service represented by this inbound interface.

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

func (*Dataplane_Networking_Inbound) GetServiceAddress 

func (x *Dataplane_Networking_Inbound) GetServiceAddress() string

func (*Dataplane_Networking_Inbound) GetServicePort 

func (x *Dataplane_Networking_Inbound) GetServicePort() uint32

func (*Dataplane_Networking_Inbound) GetServiceProbe 

func (x *Dataplane_Networking_Inbound) GetServiceProbe() *Dataplane_Networking_Inbound_ServiceProbe

func (*Dataplane_Networking_Inbound) GetState 

func (x *Dataplane_Networking_Inbound) GetState() Dataplane_Networking_Inbound_State

func (*Dataplane_Networking_Inbound) GetTags 

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

func (*Dataplane_Networking_Inbound) ProtoMessage 

func (*Dataplane_Networking_Inbound) ProtoMessage()

func (*Dataplane_Networking_Inbound) ProtoReflect 

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

func (*Dataplane_Networking_Inbound) Reset 

func (x *Dataplane_Networking_Inbound) Reset()

func (*Dataplane_Networking_Inbound) String 

func (x *Dataplane_Networking_Inbound) String() string

type Dataplane_Networking_Inbound_Health 

type Dataplane_Networking_Inbound_Health struct {

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

Health describes the status of an inbound

func (*Dataplane_Networking_Inbound_Health) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_Health.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_Health) GetReady 

func (x *Dataplane_Networking_Inbound_Health) GetReady() bool

func (*Dataplane_Networking_Inbound_Health) ProtoMessage 

func (*Dataplane_Networking_Inbound_Health) ProtoMessage()

func (*Dataplane_Networking_Inbound_Health) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_Health) Reset 

func (x *Dataplane_Networking_Inbound_Health) Reset()

func (*Dataplane_Networking_Inbound_Health) String 

func (x *Dataplane_Networking_Inbound_Health) String() string

type Dataplane_Networking_Inbound_ServiceProbe 

type Dataplane_Networking_Inbound_ServiceProbe struct {

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

ServiceProbe defines parameters for probing service's port

func (*Dataplane_Networking_Inbound_ServiceProbe) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe) GetHealthyThreshold 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) GetInterval 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTcp 

func (x *Dataplane_Networking_Inbound_ServiceProbe) GetTcp() *Dataplane_Networking_Inbound_ServiceProbe_Tcp

func (*Dataplane_Networking_Inbound_ServiceProbe) GetTimeout 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) GetUnhealthyThreshold 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_ServiceProbe) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe) String() string

type Dataplane_Networking_Inbound_ServiceProbe_Tcp 

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

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_ServiceProbe_Tcp.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage 

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoMessage()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) ProtoReflect 

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

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) Reset()

func (*Dataplane_Networking_Inbound_ServiceProbe_Tcp) String 

func (x *Dataplane_Networking_Inbound_ServiceProbe_Tcp) String() string

type Dataplane_Networking_Inbound_State 

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

func (Dataplane_Networking_Inbound_State) Descriptor 

func (Dataplane_Networking_Inbound_State) Descriptor() protoreflect.EnumDescriptor

func (Dataplane_Networking_Inbound_State) Enum 

func (x Dataplane_Networking_Inbound_State) Enum() *Dataplane_Networking_Inbound_State

func (Dataplane_Networking_Inbound_State) EnumDescriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Inbound_State.Descriptor instead.

func (Dataplane_Networking_Inbound_State) Number 

func (x Dataplane_Networking_Inbound_State) Number() protoreflect.EnumNumber

func (Dataplane_Networking_Inbound_State) String 

func (x Dataplane_Networking_Inbound_State) String() string

func (Dataplane_Networking_Inbound_State) Type 

func (Dataplane_Networking_Inbound_State) Type() protoreflect.EnumType

type Dataplane_Networking_Outbound 

type Dataplane_Networking_Outbound struct {

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

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

func (*Dataplane_Networking_Outbound) Descriptor deprecated 

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

Deprecated: Use Dataplane_Networking_Outbound.ProtoReflect.Descriptor instead.

func (*Dataplane_Networking_Outbound) GetAddress 

func (x *Dataplane_Networking_Outbound) GetAddress() string

func (*Dataplane_Networking_Outbound) GetPort 

func (x *Dataplane_Networking_Outbound) GetPort() uint32

func (*Dataplane_Networking_Outbound) GetService 

func (d *Dataplane_Networking_Outbound) GetService() string

GetService returns a service name represented by this outbound interface.

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

func (*Dataplane_Networking_Outbound) GetTags 

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

func (*Dataplane_Networking_Outbound) ProtoMessage 

func (*Dataplane_Networking_Outbound) ProtoMessage()

func (*Dataplane_Networking_Outbound) ProtoReflect 

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

func (*Dataplane_Networking_Outbound) Reset 

func (x *Dataplane_Networking_Outbound) Reset()

func (*Dataplane_Networking_Outbound) String 

func (x *Dataplane_Networking_Outbound) String() string

type Dataplane_Probes 

type Dataplane_Probes struct {

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

func (*Dataplane_Probes) Descriptor deprecated 

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

Deprecated: Use Dataplane_Probes.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes) GetEndpoints 

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

func (*Dataplane_Probes) GetPort 

func (x *Dataplane_Probes) GetPort() uint32

func (*Dataplane_Probes) ProtoMessage 

func (*Dataplane_Probes) ProtoMessage()

func (*Dataplane_Probes) ProtoReflect 

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

func (*Dataplane_Probes) Reset 

func (x *Dataplane_Probes) Reset()

func (*Dataplane_Probes) String 

func (x *Dataplane_Probes) String() string

type Dataplane_Probes_Endpoint 

type Dataplane_Probes_Endpoint struct {

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

func (*Dataplane_Probes_Endpoint) Descriptor deprecated 

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

Deprecated: Use Dataplane_Probes_Endpoint.ProtoReflect.Descriptor instead.

func (*Dataplane_Probes_Endpoint) GetInboundPath 

func (x *Dataplane_Probes_Endpoint) GetInboundPath() string

func (*Dataplane_Probes_Endpoint) GetInboundPort 

func (x *Dataplane_Probes_Endpoint) GetInboundPort() uint32

func (*Dataplane_Probes_Endpoint) GetPath 

func (x *Dataplane_Probes_Endpoint) GetPath() string

func (*Dataplane_Probes_Endpoint) ProtoMessage 

func (*Dataplane_Probes_Endpoint) ProtoMessage()

func (*Dataplane_Probes_Endpoint) ProtoReflect 

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

func (*Dataplane_Probes_Endpoint) Reset 

func (x *Dataplane_Probes_Endpoint) Reset()

func (*Dataplane_Probes_Endpoint) String 

func (x *Dataplane_Probes_Endpoint) String() string

type DiscoveryServiceStats 

type DiscoveryServiceStats struct {

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

DiscoveryServiceStats defines all stats over a single xDS service.

func (*DiscoveryServiceStats) Descriptor deprecated 

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

Deprecated: Use DiscoveryServiceStats.ProtoReflect.Descriptor instead.

func (*DiscoveryServiceStats) GetResponsesAcknowledged 

func (x *DiscoveryServiceStats) GetResponsesAcknowledged() uint64

func (*DiscoveryServiceStats) GetResponsesRejected 

func (x *DiscoveryServiceStats) GetResponsesRejected() uint64

func (*DiscoveryServiceStats) GetResponsesSent 

func (x *DiscoveryServiceStats) GetResponsesSent() uint64

func (*DiscoveryServiceStats) ProtoMessage 

func (*DiscoveryServiceStats) ProtoMessage()

func (*DiscoveryServiceStats) ProtoReflect 

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

func (*DiscoveryServiceStats) Reset 

func (x *DiscoveryServiceStats) Reset()

func (*DiscoveryServiceStats) String 

func (x *DiscoveryServiceStats) String() string

type DiscoverySubscription 

type DiscoverySubscription struct {

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

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

func (*DiscoverySubscription) Descriptor deprecated 

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

Deprecated: Use DiscoverySubscription.ProtoReflect.Descriptor instead.

func (*DiscoverySubscription) GetConnectTime 

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

func (*DiscoverySubscription) GetControlPlaneInstanceId 

func (x *DiscoverySubscription) GetControlPlaneInstanceId() string

func (*DiscoverySubscription) GetDisconnectTime 

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

func (*DiscoverySubscription) GetGeneration 

func (x *DiscoverySubscription) GetGeneration() uint32

func (*DiscoverySubscription) GetId 

func (x *DiscoverySubscription) GetId() string

func (*DiscoverySubscription) GetStatus 

func (x *DiscoverySubscription) GetStatus() *DiscoverySubscriptionStatus

func (*DiscoverySubscription) GetVersion 

func (x *DiscoverySubscription) GetVersion() *Version

func (*DiscoverySubscription) IsOnline 

func (x *DiscoverySubscription) IsOnline() bool

func (*DiscoverySubscription) ProtoMessage 

func (*DiscoverySubscription) ProtoMessage()

func (*DiscoverySubscription) ProtoReflect 

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

func (*DiscoverySubscription) Reset 

func (x *DiscoverySubscription) Reset()

func (*DiscoverySubscription) SetDisconnectTime 

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

func (*DiscoverySubscription) String 

func (x *DiscoverySubscription) String() string

type DiscoverySubscriptionStatus 

type DiscoverySubscriptionStatus struct {

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

DiscoverySubscriptionStatus defines status of an ADS subscription.

func NewSubscriptionStatus 

func NewSubscriptionStatus(now time.Time) *DiscoverySubscriptionStatus

func (*DiscoverySubscriptionStatus) Descriptor deprecated 

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

Deprecated: Use DiscoverySubscriptionStatus.ProtoReflect.Descriptor instead.

func (*DiscoverySubscriptionStatus) GetCds 

func (x *DiscoverySubscriptionStatus) GetCds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetEds 

func (x *DiscoverySubscriptionStatus) GetEds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetLastUpdateTime 

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

func (*DiscoverySubscriptionStatus) GetLds 

func (x *DiscoverySubscriptionStatus) GetLds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetRds 

func (x *DiscoverySubscriptionStatus) GetRds() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) GetTotal 

func (x *DiscoverySubscriptionStatus) GetTotal() *DiscoveryServiceStats

func (*DiscoverySubscriptionStatus) ProtoMessage 

func (*DiscoverySubscriptionStatus) ProtoMessage()

func (*DiscoverySubscriptionStatus) ProtoReflect 

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

func (*DiscoverySubscriptionStatus) Reset 

func (x *DiscoverySubscriptionStatus) Reset()

func (*DiscoverySubscriptionStatus) StatsOf 

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

func (*DiscoverySubscriptionStatus) String 

func (x *DiscoverySubscriptionStatus) String() string

type DubboDiscoveryServiceClient 

type DubboDiscoveryServiceClient interface {
	StreamDubboResources(ctx context.Context, opts ...grpc.CallOption) (DubboDiscoveryService_StreamDubboResourcesClient, error)
}

DubboDiscoveryServiceClient is the client API for DubboDiscoveryService service.

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

func NewDubboDiscoveryServiceClient 

func NewDubboDiscoveryServiceClient(cc grpc.ClientConnInterface) DubboDiscoveryServiceClient

type DubboDiscoveryServiceServer 

type DubboDiscoveryServiceServer interface {
	StreamDubboResources(DubboDiscoveryService_StreamDubboResourcesServer) error
	// contains filtered or unexported methods
}

DubboDiscoveryServiceServer is the server API for DubboDiscoveryService service. All implementations must embed UnimplementedDubboDiscoveryServiceServer for forward compatibility

type DubboDiscoveryService_StreamDubboResourcesClient 

type DubboDiscoveryService_StreamDubboResourcesClient interface {
	Send(*v3.DiscoveryRequest) error
	Recv() (*v3.DiscoveryResponse, error)
	grpc.ClientStream
}

type DubboDiscoveryService_StreamDubboResourcesServer 

type DubboDiscoveryService_StreamDubboResourcesServer interface {
	Send(*v3.DiscoveryResponse) error
	Recv() (*v3.DiscoveryRequest, error)
	grpc.ServerStream
}

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) ProtoMessage 

func (*DynamicConfig) ProtoMessage()

func (*DynamicConfig) ProtoReflect 

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

func (*DynamicConfig) Reset 

func (x *DynamicConfig) Reset()

func (*DynamicConfig) String 

func (x *DynamicConfig) String() string

type EnvoyAdmin 

type EnvoyAdmin struct {

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

func (*EnvoyAdmin) Descriptor deprecated 

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

Deprecated: Use EnvoyAdmin.ProtoReflect.Descriptor instead.

func (*EnvoyAdmin) GetPort 

func (x *EnvoyAdmin) GetPort() uint32

func (*EnvoyAdmin) ProtoMessage 

func (*EnvoyAdmin) ProtoMessage()

func (*EnvoyAdmin) ProtoReflect 

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

func (*EnvoyAdmin) Reset 

func (x *EnvoyAdmin) Reset()

func (*EnvoyAdmin) String 

func (x *EnvoyAdmin) String() string

type EnvoyVersion 

type EnvoyVersion struct {

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

func (*EnvoyVersion) Descriptor deprecated 

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

Deprecated: Use EnvoyVersion.ProtoReflect.Descriptor instead.

func (*EnvoyVersion) GetBuild 

func (x *EnvoyVersion) GetBuild() string

func (*EnvoyVersion) GetDubboDpCompatible 

func (x *EnvoyVersion) GetDubboDpCompatible() bool

func (*EnvoyVersion) GetVersion 

func (x *EnvoyVersion) GetVersion() string

func (*EnvoyVersion) ProtoMessage 

func (*EnvoyVersion) ProtoMessage()

func (*EnvoyVersion) ProtoReflect 

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

func (*EnvoyVersion) Reset 

func (x *EnvoyVersion) Reset()

func (*EnvoyVersion) String 

func (x *EnvoyVersion) String() string

type FileLoggingBackendConfig 

type FileLoggingBackendConfig struct {

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

FileLoggingBackendConfig defines configuration for file based access logs

func (*FileLoggingBackendConfig) Descriptor deprecated 

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

Deprecated: Use FileLoggingBackendConfig.ProtoReflect.Descriptor instead.

func (*FileLoggingBackendConfig) GetPath 

func (x *FileLoggingBackendConfig) GetPath() string

func (*FileLoggingBackendConfig) ProtoMessage 

func (*FileLoggingBackendConfig) ProtoMessage()

func (*FileLoggingBackendConfig) ProtoReflect 

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

func (*FileLoggingBackendConfig) Reset 

func (x *FileLoggingBackendConfig) Reset()

func (*FileLoggingBackendConfig) String 

func (x *FileLoggingBackendConfig) String() string

type GlobalDDSServiceClient 

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

GlobalDDSServiceClient is the client API for GlobalDDSService service.

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

func NewGlobalDDSServiceClient 

func NewGlobalDDSServiceClient(cc grpc.ClientConnInterface) GlobalDDSServiceClient

type GlobalDDSServiceServer 

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

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

type InboundInterface 

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

func (*InboundInterface) IsServiceLess 

func (i *InboundInterface) IsServiceLess() bool

func (InboundInterface) MarshalText 

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

func (InboundInterface) String 

func (i InboundInterface) String() string

type ListStringMatch 

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

func (*ListStringMatch) Descriptor deprecated 

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

Deprecated: Use ListStringMatch.ProtoReflect.Descriptor instead.

func (*ListStringMatch) GetOneof 

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

func (*ListStringMatch) ProtoMessage 

func (*ListStringMatch) ProtoMessage()

func (*ListStringMatch) ProtoReflect 

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

func (*ListStringMatch) Reset 

func (x *ListStringMatch) Reset()

func (*ListStringMatch) String 

func (x *ListStringMatch) String() string

type Logging 

type Logging struct {

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

func (*Logging) Descriptor deprecated 

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

Deprecated: Use Logging.ProtoReflect.Descriptor instead.

func (*Logging) GetBackends 

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

func (*Logging) GetDefaultBackend 

func (x *Logging) GetDefaultBackend() string

func (*Logging) ProtoMessage 

func (*Logging) ProtoMessage()

func (*Logging) ProtoReflect 

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

func (*Logging) Reset 

func (x *Logging) Reset()

func (*Logging) String 

func (x *Logging) String() string

type LoggingBackend 

type LoggingBackend struct {

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

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

func (*LoggingBackend) Descriptor deprecated 

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

Deprecated: Use LoggingBackend.ProtoReflect.Descriptor instead.

func (*LoggingBackend) GetConf 

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

func (*LoggingBackend) GetFormat 

func (x *LoggingBackend) GetFormat() string

func (*LoggingBackend) GetName 

func (x *LoggingBackend) GetName() string

func (*LoggingBackend) GetType 

func (x *LoggingBackend) GetType() string

func (*LoggingBackend) ProtoMessage 

func (*LoggingBackend) ProtoMessage()

func (*LoggingBackend) ProtoReflect 

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

func (*LoggingBackend) Reset 

func (x *LoggingBackend) Reset()

func (*LoggingBackend) String 

func (x *LoggingBackend) String() string

type Mapping 

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

func (*Mapping) Descriptor deprecated 

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

Deprecated: Use Mapping.ProtoReflect.Descriptor instead.

func (*Mapping) GetApplicationNames 

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

func (*Mapping) GetInterfaceName 

func (x *Mapping) GetInterfaceName() string

func (*Mapping) GetZone 

func (x *Mapping) GetZone() string

func (*Mapping) ProtoMessage 

func (*Mapping) ProtoMessage()

func (*Mapping) ProtoReflect 

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

func (*Mapping) Reset 

func (x *Mapping) Reset()

func (*Mapping) String 

func (x *Mapping) String() string

type MappingRegisterRequest 

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

func (*MappingRegisterRequest) Descriptor deprecated 

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

Deprecated: Use MappingRegisterRequest.ProtoReflect.Descriptor instead.

func (*MappingRegisterRequest) GetApplicationName 

func (x *MappingRegisterRequest) GetApplicationName() string

func (*MappingRegisterRequest) GetInterfaceNames 

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

func (*MappingRegisterRequest) GetNamespace 

func (x *MappingRegisterRequest) GetNamespace() string

func (*MappingRegisterRequest) GetPodName 

func (x *MappingRegisterRequest) GetPodName() string

func (*MappingRegisterRequest) ProtoMessage 

func (*MappingRegisterRequest) ProtoMessage()

func (*MappingRegisterRequest) ProtoReflect 

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

func (*MappingRegisterRequest) Reset 

func (x *MappingRegisterRequest) Reset()

func (*MappingRegisterRequest) String 

func (x *MappingRegisterRequest) String() string

type MappingRegisterResponse 

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

func (*MappingRegisterResponse) Descriptor deprecated 

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

Deprecated: Use MappingRegisterResponse.ProtoReflect.Descriptor instead.

func (*MappingRegisterResponse) GetMessage 

func (x *MappingRegisterResponse) GetMessage() string

func (*MappingRegisterResponse) GetSuccess 

func (x *MappingRegisterResponse) GetSuccess() bool

func (*MappingRegisterResponse) ProtoMessage 

func (*MappingRegisterResponse) ProtoMessage()

func (*MappingRegisterResponse) ProtoReflect 

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

func (*MappingRegisterResponse) Reset 

func (x *MappingRegisterResponse) Reset()

func (*MappingRegisterResponse) String 

func (x *MappingRegisterResponse) String() string

type MappingSyncRequest 

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

func (*MappingSyncRequest) Descriptor deprecated 

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

Deprecated: Use MappingSyncRequest.ProtoReflect.Descriptor instead.

func (*MappingSyncRequest) GetInterfaceName 

func (x *MappingSyncRequest) GetInterfaceName() string

func (*MappingSyncRequest) GetNamespace 

func (x *MappingSyncRequest) GetNamespace() string

func (*MappingSyncRequest) GetNonce 

func (x *MappingSyncRequest) GetNonce() string

func (*MappingSyncRequest) ProtoMessage 

func (*MappingSyncRequest) ProtoMessage()

func (*MappingSyncRequest) ProtoReflect 

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

func (*MappingSyncRequest) Reset 

func (x *MappingSyncRequest) Reset()

func (*MappingSyncRequest) String 

func (x *MappingSyncRequest) String() string

type MappingSyncResponse 

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

func (*MappingSyncResponse) Descriptor deprecated 

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

Deprecated: Use MappingSyncResponse.ProtoReflect.Descriptor instead.

func (*MappingSyncResponse) GetMappings 

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

func (*MappingSyncResponse) GetNonce 

func (x *MappingSyncResponse) GetNonce() string

func (*MappingSyncResponse) GetRevision 

func (x *MappingSyncResponse) GetRevision() int64

func (*MappingSyncResponse) ProtoMessage 

func (*MappingSyncResponse) ProtoMessage()

func (*MappingSyncResponse) ProtoReflect 

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

func (*MappingSyncResponse) Reset 

func (x *MappingSyncResponse) Reset()

func (*MappingSyncResponse) String 

func (x *MappingSyncResponse) String() string

type Mesh 

type Mesh struct {

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

Mesh defines configuration of a single mesh.

func (*Mesh) Descriptor deprecated 

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

Deprecated: Use Mesh.ProtoReflect.Descriptor instead.

func (*Mesh) GetLogging 

func (x *Mesh) GetLogging() *Logging

func (*Mesh) GetMtls 

func (x *Mesh) GetMtls() *Mesh_Mtls

func (*Mesh) GetNetworking 

func (x *Mesh) GetNetworking() *Networking

func (*Mesh) GetRouting 

func (x *Mesh) GetRouting() *Routing

func (*Mesh) GetTracing 

func (x *Mesh) GetTracing() *Tracing

func (*Mesh) ProtoMessage 

func (*Mesh) ProtoMessage()

func (*Mesh) ProtoReflect 

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

func (*Mesh) Reset 

func (x *Mesh) Reset()

func (*Mesh) String 

func (x *Mesh) String() string

type MeshInsight 

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

MeshInsight defines the observed state of a Mesh.

func (*MeshInsight) Descriptor deprecated 

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

Deprecated: Use MeshInsight.ProtoReflect.Descriptor instead.

func (*MeshInsight) GetDataplanes 

func (x *MeshInsight) GetDataplanes() *MeshInsight_DataplaneStat

func (*MeshInsight) GetDataplanesByType 

func (x *MeshInsight) GetDataplanesByType() *MeshInsight_DataplanesByType

func (*MeshInsight) GetDpVersions 

func (x *MeshInsight) GetDpVersions() *MeshInsight_DpVersions

func (*MeshInsight) GetMTLS 

func (x *MeshInsight) GetMTLS() *MeshInsight_MTLS

func (*MeshInsight) GetPolicies 

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

func (*MeshInsight) GetServices 

func (x *MeshInsight) GetServices() *MeshInsight_ServiceStat

func (*MeshInsight) ProtoMessage 

func (*MeshInsight) ProtoMessage()

func (*MeshInsight) ProtoReflect 

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

func (*MeshInsight) Reset 

func (x *MeshInsight) Reset()

func (*MeshInsight) String 

func (x *MeshInsight) String() string

type MeshInsight_DataplaneStat 

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

DataplaneStat defines statistic specifically for Dataplane

func (*MeshInsight_DataplaneStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DataplaneStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplaneStat) GetOffline 

func (x *MeshInsight_DataplaneStat) GetOffline() uint32

func (*MeshInsight_DataplaneStat) GetOnline 

func (x *MeshInsight_DataplaneStat) GetOnline() uint32

func (*MeshInsight_DataplaneStat) GetPartiallyDegraded 

func (x *MeshInsight_DataplaneStat) GetPartiallyDegraded() uint32

func (*MeshInsight_DataplaneStat) GetTotal 

func (x *MeshInsight_DataplaneStat) GetTotal() uint32

func (*MeshInsight_DataplaneStat) ProtoMessage 

func (*MeshInsight_DataplaneStat) ProtoMessage()

func (*MeshInsight_DataplaneStat) ProtoReflect 

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

func (*MeshInsight_DataplaneStat) Reset 

func (x *MeshInsight_DataplaneStat) Reset()

func (*MeshInsight_DataplaneStat) String 

func (x *MeshInsight_DataplaneStat) String() string

type MeshInsight_DataplanesByType 

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

DataplanesByType defines statistics splitted by dataplane types

func (*MeshInsight_DataplanesByType) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DataplanesByType.ProtoReflect.Descriptor instead.

func (*MeshInsight_DataplanesByType) GetStandard 

func (x *MeshInsight_DataplanesByType) GetStandard() *MeshInsight_DataplaneStat

func (*MeshInsight_DataplanesByType) ProtoMessage 

func (*MeshInsight_DataplanesByType) ProtoMessage()

func (*MeshInsight_DataplanesByType) ProtoReflect 

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

func (*MeshInsight_DataplanesByType) Reset 

func (x *MeshInsight_DataplanesByType) Reset()

func (*MeshInsight_DataplanesByType) String 

func (x *MeshInsight_DataplanesByType) String() string

type MeshInsight_DpVersions 

type MeshInsight_DpVersions struct {

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

DpVersions defines statistics grouped by dataplane versions

func (*MeshInsight_DpVersions) Descriptor deprecated 

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

Deprecated: Use MeshInsight_DpVersions.ProtoReflect.Descriptor instead.

func (*MeshInsight_DpVersions) GetDubboDp 

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

func (*MeshInsight_DpVersions) GetEnvoy 

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

func (*MeshInsight_DpVersions) ProtoMessage 

func (*MeshInsight_DpVersions) ProtoMessage()

func (*MeshInsight_DpVersions) ProtoReflect 

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

func (*MeshInsight_DpVersions) Reset 

func (x *MeshInsight_DpVersions) Reset()

func (*MeshInsight_DpVersions) String 

func (x *MeshInsight_DpVersions) String() string

type MeshInsight_MTLS 

type MeshInsight_MTLS struct {

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

func (*MeshInsight_MTLS) Descriptor deprecated 

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

Deprecated: Use MeshInsight_MTLS.ProtoReflect.Descriptor instead.

func (*MeshInsight_MTLS) GetIssuedBackends 

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

func (*MeshInsight_MTLS) GetSupportedBackends 

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

func (*MeshInsight_MTLS) ProtoMessage 

func (*MeshInsight_MTLS) ProtoMessage()

func (*MeshInsight_MTLS) ProtoReflect 

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

func (*MeshInsight_MTLS) Reset 

func (x *MeshInsight_MTLS) Reset()

func (*MeshInsight_MTLS) String 

func (x *MeshInsight_MTLS) String() string

type MeshInsight_PolicyStat 

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

PolicyStat defines statistic for all policies in general

func (*MeshInsight_PolicyStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_PolicyStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_PolicyStat) GetTotal 

func (x *MeshInsight_PolicyStat) GetTotal() uint32

func (*MeshInsight_PolicyStat) ProtoMessage 

func (*MeshInsight_PolicyStat) ProtoMessage()

func (*MeshInsight_PolicyStat) ProtoReflect 

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

func (*MeshInsight_PolicyStat) Reset 

func (x *MeshInsight_PolicyStat) Reset()

func (*MeshInsight_PolicyStat) String 

func (x *MeshInsight_PolicyStat) String() string

type MeshInsight_ServiceStat 

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

ServiceStat defines statistics of mesh services

func (*MeshInsight_ServiceStat) Descriptor deprecated 

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

Deprecated: Use MeshInsight_ServiceStat.ProtoReflect.Descriptor instead.

func (*MeshInsight_ServiceStat) GetExternal 

func (x *MeshInsight_ServiceStat) GetExternal() uint32

func (*MeshInsight_ServiceStat) GetInternal 

func (x *MeshInsight_ServiceStat) GetInternal() uint32

func (*MeshInsight_ServiceStat) GetTotal 

func (x *MeshInsight_ServiceStat) GetTotal() uint32

func (*MeshInsight_ServiceStat) ProtoMessage 

func (*MeshInsight_ServiceStat) ProtoMessage()

func (*MeshInsight_ServiceStat) ProtoReflect 

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

func (*MeshInsight_ServiceStat) Reset 

func (x *MeshInsight_ServiceStat) Reset()

func (*MeshInsight_ServiceStat) String 

func (x *MeshInsight_ServiceStat) String() string

type Mesh_Mtls 

type Mesh_Mtls struct {

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

mTLS settings of a Mesh.

func (*Mesh_Mtls) Descriptor deprecated 

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

Deprecated: Use Mesh_Mtls.ProtoReflect.Descriptor instead.

func (*Mesh_Mtls) GetBackends 

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

func (*Mesh_Mtls) GetEnabledBackend 

func (x *Mesh_Mtls) GetEnabledBackend() string

func (*Mesh_Mtls) ProtoMessage 

func (*Mesh_Mtls) ProtoMessage()

func (*Mesh_Mtls) ProtoReflect 

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

func (*Mesh_Mtls) Reset 

func (x *Mesh_Mtls) Reset()

func (*Mesh_Mtls) String 

func (x *Mesh_Mtls) String() string

type MetaData 

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

func (*MetaData) Descriptor deprecated 

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

Deprecated: Use MetaData.ProtoReflect.Descriptor instead.

func (*MetaData) GetApp 

func (x *MetaData) GetApp() string

func (*MetaData) GetRevision 

func (x *MetaData) GetRevision() string

func (*MetaData) GetServices 

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

func (*MetaData) GetZone 

func (x *MetaData) GetZone() string

func (*MetaData) ProtoMessage 

func (*MetaData) ProtoMessage()

func (*MetaData) ProtoReflect 

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

func (*MetaData) Reset 

func (x *MetaData) Reset()

func (*MetaData) String 

func (x *MetaData) String() string

type MetaDataRegisterRequest 

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

func (*MetaDataRegisterRequest) Descriptor deprecated 

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

Deprecated: Use MetaDataRegisterRequest.ProtoReflect.Descriptor instead.

func (*MetaDataRegisterRequest) GetMetadata 

func (x *MetaDataRegisterRequest) GetMetadata() *MetaData

func (*MetaDataRegisterRequest) GetNamespace 

func (x *MetaDataRegisterRequest) GetNamespace() string

func (*MetaDataRegisterRequest) GetPodName 

func (x *MetaDataRegisterRequest) GetPodName() string

func (*MetaDataRegisterRequest) ProtoMessage 

func (*MetaDataRegisterRequest) ProtoMessage()

func (*MetaDataRegisterRequest) ProtoReflect 

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

func (*MetaDataRegisterRequest) Reset 

func (x *MetaDataRegisterRequest) Reset()

func (*MetaDataRegisterRequest) String 

func (x *MetaDataRegisterRequest) String() string

type MetaDataRegisterResponse 

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

func (*MetaDataRegisterResponse) Descriptor deprecated 

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

Deprecated: Use MetaDataRegisterResponse.ProtoReflect.Descriptor instead.

func (*MetaDataRegisterResponse) GetMessage 

func (x *MetaDataRegisterResponse) GetMessage() string

func (*MetaDataRegisterResponse) GetSuccess 

func (x *MetaDataRegisterResponse) GetSuccess() bool

func (*MetaDataRegisterResponse) ProtoMessage 

func (*MetaDataRegisterResponse) ProtoMessage()

func (*MetaDataRegisterResponse) ProtoReflect 

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

func (*MetaDataRegisterResponse) Reset 

func (x *MetaDataRegisterResponse) Reset()

func (*MetaDataRegisterResponse) String 

func (x *MetaDataRegisterResponse) String() string

type MetadataServiceClient 

type MetadataServiceClient interface {
	MetadataRegister(ctx context.Context, in *MetaDataRegisterRequest, opts ...grpc.CallOption) (*MetaDataRegisterResponse, error)
	MetadataSync(ctx context.Context, opts ...grpc.CallOption) (MetadataService_MetadataSyncClient, error)
}

MetadataServiceClient is the client API for MetadataService service.

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

func NewMetadataServiceClient 

func NewMetadataServiceClient(cc grpc.ClientConnInterface) MetadataServiceClient

type MetadataServiceServer 

type MetadataServiceServer interface {
	MetadataRegister(context.Context, *MetaDataRegisterRequest) (*MetaDataRegisterResponse, error)
	MetadataSync(MetadataService_MetadataSyncServer) error
	// contains filtered or unexported methods
}

MetadataServiceServer is the server API for MetadataService service. All implementations must embed UnimplementedMetadataServiceServer for forward compatibility

type MetadataService_MetadataSyncClient 

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

type MetadataService_MetadataSyncServer 

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

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"`
	// 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) 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 (x *PrometheusAggregateMetricsConfig) GetEnabled() *wrapperspb.BoolValue

func (*PrometheusAggregateMetricsConfig) GetName 

func (x *PrometheusAggregateMetricsConfig) GetName() string

func (*PrometheusAggregateMetricsConfig) GetPath 

func (x *PrometheusAggregateMetricsConfig) GetPath() string

func (*PrometheusAggregateMetricsConfig) GetPort 

func (x *PrometheusAggregateMetricsConfig) GetPort() uint32

func (*PrometheusAggregateMetricsConfig) ProtoMessage 

func (*PrometheusAggregateMetricsConfig) ProtoMessage()

func (*PrometheusAggregateMetricsConfig) ProtoReflect 

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

func (*PrometheusAggregateMetricsConfig) Reset 

func (x *PrometheusAggregateMetricsConfig) Reset()

func (*PrometheusAggregateMetricsConfig) String 

func (x *PrometheusAggregateMetricsConfig) String() 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 (x *PrometheusMetricsBackendConfig) GetAggregate() []*PrometheusAggregateMetricsConfig

func (*PrometheusMetricsBackendConfig) GetEnvoy 

func (x *PrometheusMetricsBackendConfig) GetEnvoy() *PrometheusEnvoyConfig

func (*PrometheusMetricsBackendConfig) GetPath 

func (x *PrometheusMetricsBackendConfig) GetPath() string

func (*PrometheusMetricsBackendConfig) GetPort 

func (x *PrometheusMetricsBackendConfig) GetPort() uint32

func (*PrometheusMetricsBackendConfig) GetSkipMTLS 

func (x *PrometheusMetricsBackendConfig) GetSkipMTLS() *wrapperspb.BoolValue

func (*PrometheusMetricsBackendConfig) GetTags 

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

func (*PrometheusMetricsBackendConfig) GetTls 

func (x *PrometheusMetricsBackendConfig) GetTls() *PrometheusTlsConfig

func (*PrometheusMetricsBackendConfig) ProtoMessage 

func (*PrometheusMetricsBackendConfig) ProtoMessage()

func (*PrometheusMetricsBackendConfig) ProtoReflect 

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

func (*PrometheusMetricsBackendConfig) Reset 

func (x *PrometheusMetricsBackendConfig) Reset()

func (*PrometheusMetricsBackendConfig) String 

func (x *PrometheusMetricsBackendConfig) String() 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 (x *PrometheusTlsConfig) GetMode() PrometheusTlsConfig_Mode

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) Descriptor() protoreflect.EnumDescriptor

func (PrometheusTlsConfig_Mode) Enum 

func (x PrometheusTlsConfig_Mode) Enum() *PrometheusTlsConfig_Mode

func (PrometheusTlsConfig_Mode) EnumDescriptor deprecated 

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

Deprecated: Use PrometheusTlsConfig_Mode.Descriptor instead.

func (PrometheusTlsConfig_Mode) Number 

func (x PrometheusTlsConfig_Mode) Number() protoreflect.EnumNumber

func (PrometheusTlsConfig_Mode) String 

func (x PrometheusTlsConfig_Mode) String() string

func (PrometheusTlsConfig_Mode) Type 

func (PrometheusTlsConfig_Mode) Type() protoreflect.EnumType

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 ServiceNameMappingServiceClient 

type ServiceNameMappingServiceClient 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)
	// 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) (ServiceNameMappingService_MappingSyncClient, error)
}

ServiceNameMappingServiceClient is the client API for ServiceNameMappingService service.

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

func NewServiceNameMappingServiceClient 

func NewServiceNameMappingServiceClient(cc grpc.ClientConnInterface) ServiceNameMappingServiceClient

type ServiceNameMappingServiceServer 

type ServiceNameMappingServiceServer interface {
	// MappingRegister from dp to cp, data plane register snp information to
	// control plane.
	MappingRegister(context.Context, *MappingRegisterRequest) (*MappingRegisterResponse, 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(ServiceNameMappingService_MappingSyncServer) error
	// contains filtered or unexported methods
}

ServiceNameMappingServiceServer is the server API for ServiceNameMappingService service. All implementations must embed UnimplementedServiceNameMappingServiceServer for forward compatibility

type ServiceNameMappingService_MappingSyncClient 

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

type ServiceNameMappingService_MappingSyncServer 

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

type SingleValueTagSet 

type SingleValueTagSet map[string]string

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

func (SingleValueTagSet) Exclude 

func (t SingleValueTagSet) Exclude(key string) SingleValueTagSet

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"`
	// 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) 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) ProtoMessage 

func (*TagRoute) ProtoMessage()

func (*TagRoute) ProtoReflect 

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

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) GlobalToZoneSync(DDSSyncService_GlobalToZoneSyncServer) error

func (UnimplementedDDSSyncServiceServer) ZoneToGlobalSync 

func (UnimplementedDDSSyncServiceServer) ZoneToGlobalSync(DDSSyncService_ZoneToGlobalSyncServer) error

type UnimplementedDubboDiscoveryServiceServer 

type UnimplementedDubboDiscoveryServiceServer struct {
}

UnimplementedDubboDiscoveryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDubboDiscoveryServiceServer) StreamDubboResources 

func (UnimplementedDubboDiscoveryServiceServer) StreamDubboResources(DubboDiscoveryService_StreamDubboResourcesServer) error

type UnimplementedGlobalDDSServiceServer 

type UnimplementedGlobalDDSServiceServer struct {
}

UnimplementedGlobalDDSServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGlobalDDSServiceServer) HealthCheck 

func (UnimplementedGlobalDDSServiceServer) HealthCheck(context.Context, *ZoneHealthCheckRequest) (*ZoneHealthCheckResponse, error)

type UnimplementedMetadataServiceServer 

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetadataServiceServer) MetadataRegister 

func (UnimplementedMetadataServiceServer) MetadataRegister(context.Context, *MetaDataRegisterRequest) (*MetaDataRegisterResponse, error)

func (UnimplementedMetadataServiceServer) MetadataSync 

func (UnimplementedMetadataServiceServer) MetadataSync(MetadataService_MetadataSyncServer) error

type UnimplementedServiceNameMappingServiceServer 

type UnimplementedServiceNameMappingServiceServer struct {
}

UnimplementedServiceNameMappingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceNameMappingServiceServer) MappingRegister 

func (UnimplementedServiceNameMappingServiceServer) MappingRegister(context.Context, *MappingRegisterRequest) (*MappingRegisterResponse, error)

func (UnimplementedServiceNameMappingServiceServer) MappingSync 

func (UnimplementedServiceNameMappingServiceServer) MappingSync(ServiceNameMappingService_MappingSyncServer) error

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 UnsafeDubboDiscoveryServiceServer 

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

UnsafeDubboDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DubboDiscoveryServiceServer 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 UnsafeMetadataServiceServer 

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

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

type UnsafeServiceNameMappingServiceServer 

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

UnsafeServiceNameMappingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceNameMappingServiceServer 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 (x *ZipkinTracingBackendConfig) ProtoReflect() protoreflect.Message

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 (x *ZoneIngressInsight) Sum(v func(*DiscoverySubscription) uint64) uint64

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 (x *ZoneIngress_AvailableService) ProtoReflect() protoreflect.Message

func (*ZoneIngress_AvailableService) Reset 

func (x *ZoneIngress_AvailableService) Reset()

func (*ZoneIngress_AvailableService) String 

func (x *ZoneIngress_AvailableService) String() 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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