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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_system_v1alpha1_config_proto protoreflect.FileDescriptor
View Source 
var File_api_system_v1alpha1_datasource_proto protoreflect.FileDescriptor
View Source 
var File_api_system_v1alpha1_inter_cp_ping_proto protoreflect.FileDescriptor
View Source 
var File_api_system_v1alpha1_secret_proto protoreflect.FileDescriptor
View Source 
var File_api_system_v1alpha1_zone_insight_proto protoreflect.FileDescriptor
View Source 
var File_api_system_v1alpha1_zone_proto protoreflect.FileDescriptor
View Source 
var InterCpPingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.system.v1alpha1.InterCpPingService",
	HandlerType: (*InterCpPingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _InterCpPingService_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/system/v1alpha1/inter_cp_ping.proto",
}

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

Functions

func RegisterInterCpPingServiceServer 

func RegisterInterCpPingServiceServer(s grpc.ServiceRegistrar, srv InterCpPingServiceServer)

Types

type Config 

type Config struct {

	// configuration that is stored (ex. in JSON)
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Config is a entity that represents dynamic configuration that is stored in underlying storage. For now it's used only for internal mechanisms.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetConfig 

func (x *Config) GetConfig() string

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type DDSServiceStats 

type DDSServiceStats 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 (*DDSServiceStats) Descriptor deprecated 

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

Deprecated: Use DDSServiceStats.ProtoReflect.Descriptor instead.

func (*DDSServiceStats) GetResponsesAcknowledged 

func (x *DDSServiceStats) GetResponsesAcknowledged() uint64

func (*DDSServiceStats) GetResponsesRejected 

func (x *DDSServiceStats) GetResponsesRejected() uint64

func (*DDSServiceStats) GetResponsesSent 

func (x *DDSServiceStats) GetResponsesSent() uint64

func (*DDSServiceStats) ProtoMessage 

func (*DDSServiceStats) ProtoMessage()

func (*DDSServiceStats) ProtoReflect 

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

func (*DDSServiceStats) Reset 

func (x *DDSServiceStats) Reset()

func (*DDSServiceStats) String 

func (x *DDSServiceStats) String() string

type DDSSubscription 

type DDSSubscription struct {

	// Unique id per DDS subscription.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Global CP instance that handled given subscription.
	GlobalInstanceId string `protobuf:"bytes,2,opt,name=global_instance_id,json=globalInstanceId,proto3" json:"global_instance_id,omitempty"`
	// Time when a given Zone connected to the Global.
	ConnectTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"`
	// Time when a given Zone disconnected from the Global.
	DisconnectTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=disconnect_time,json=disconnectTime,proto3" json:"disconnect_time,omitempty"`
	// Status of the DDS subscription.
	Status *DDSSubscriptionStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,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"`
	// Config of Zone Dubbo CP
	Config string `protobuf:"bytes,8,opt,name=config,proto3" json:"config,omitempty"`
	// Indicates if subscription provided auth token
	AuthTokenProvided bool `protobuf:"varint,9,opt,name=auth_token_provided,json=authTokenProvided,proto3" json:"auth_token_provided,omitempty"`
	// Zone CP instance that handled the given subscription (This is the leader at
	// time of connection).
	ZoneInstanceId string `protobuf:"bytes,10,opt,name=zone_instance_id,json=zoneInstanceId,proto3" json:"zone_instance_id,omitempty"`
	// contains filtered or unexported fields
}

DDSSubscription describes a single DDS subscription created by a Zone to the Global. Ideally, there should be only one such subscription per Zone lifecycle. Presence of multiple subscriptions might indicate one of the following events: - transient loss of network connection between Zone and Global Control Planes - Zone Dubbo CP restarts (i.e. hot restart or crash) - Global Dubbo CP restarts (i.e. rolling update or crash) - etc

func (*DDSSubscription) Descriptor deprecated 

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

Deprecated: Use DDSSubscription.ProtoReflect.Descriptor instead.

func (*DDSSubscription) GetAuthTokenProvided 

func (x *DDSSubscription) GetAuthTokenProvided() bool

func (*DDSSubscription) GetConfig 

func (x *DDSSubscription) GetConfig() string

func (*DDSSubscription) GetConnectTime 

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

func (*DDSSubscription) GetDisconnectTime 

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

func (*DDSSubscription) GetGeneration 

func (x *DDSSubscription) GetGeneration() uint32

func (*DDSSubscription) GetGlobalInstanceId 

func (x *DDSSubscription) GetGlobalInstanceId() string

func (*DDSSubscription) GetId 

func (x *DDSSubscription) GetId() string

func (*DDSSubscription) GetStatus 

func (x *DDSSubscription) GetStatus() *DDSSubscriptionStatus

func (*DDSSubscription) GetZoneInstanceId 

func (x *DDSSubscription) GetZoneInstanceId() string

func (*DDSSubscription) ProtoMessage 

func (*DDSSubscription) ProtoMessage()

func (*DDSSubscription) ProtoReflect 

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

func (*DDSSubscription) Reset 

func (x *DDSSubscription) Reset()

func (*DDSSubscription) String 

func (x *DDSSubscription) String() string

type DDSSubscriptionStatus 

type DDSSubscriptionStatus struct {

	// Time when status of a given DDS 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 DDS stats.
	Total *DDSServiceStats            `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"`
	Stat  map[string]*DDSServiceStats `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

DDSSubscriptionStatus defines status of an DDS subscription.

func (*DDSSubscriptionStatus) Descriptor deprecated 

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

Deprecated: Use DDSSubscriptionStatus.ProtoReflect.Descriptor instead.

func (*DDSSubscriptionStatus) GetLastUpdateTime 

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

func (*DDSSubscriptionStatus) GetStat 

func (x *DDSSubscriptionStatus) GetStat() map[string]*DDSServiceStats

func (*DDSSubscriptionStatus) GetTotal 

func (x *DDSSubscriptionStatus) GetTotal() *DDSServiceStats

func (*DDSSubscriptionStatus) ProtoMessage 

func (*DDSSubscriptionStatus) ProtoMessage()

func (*DDSSubscriptionStatus) ProtoReflect 

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

func (*DDSSubscriptionStatus) Reset 

func (x *DDSSubscriptionStatus) Reset()

func (*DDSSubscriptionStatus) String 

func (x *DDSSubscriptionStatus) String() string

type DataSource 

type DataSource struct {

	// Types that are assignable to Type:
	//
	//	*DataSource_Secret
	//	*DataSource_File
	//	*DataSource_Inline
	//	*DataSource_InlineString
	Type isDataSource_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

DataSource defines the source of bytes to use.

func (*DataSource) Descriptor deprecated 

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetFile 

func (x *DataSource) GetFile() string

func (*DataSource) GetInline 

func (x *DataSource) GetInline() *wrapperspb.BytesValue

func (*DataSource) GetInlineString 

func (x *DataSource) GetInlineString() string

func (*DataSource) GetSecret 

func (x *DataSource) GetSecret() string

func (*DataSource) GetType 

func (m *DataSource) GetType() isDataSource_Type

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect 

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

func (*DataSource) Reset 

func (x *DataSource) Reset()

func (*DataSource) String 

func (x *DataSource) String() string

type DataSource_File 

type DataSource_File struct {
	// Data source is a path to a file.
	// Deprecated, use other sources of a data.
	File string `protobuf:"bytes,2,opt,name=file,proto3,oneof"`
}

type DataSource_Inline 

type DataSource_Inline struct {
	// Data source is inline bytes.
	Inline *wrapperspb.BytesValue `protobuf:"bytes,3,opt,name=inline,proto3,oneof"`
}

type DataSource_InlineString 

type DataSource_InlineString struct {
	// Data source is inline string
	InlineString string `protobuf:"bytes,4,opt,name=inlineString,proto3,oneof"`
}

type DataSource_Secret 

type DataSource_Secret struct {
	// Data source is a secret with given Secret key.
	Secret string `protobuf:"bytes,1,opt,name=secret,proto3,oneof"`
}

type EnvoyAdminStreams 

type EnvoyAdminStreams struct {

	// Global instance ID that handles XDS Config Dump streams.
	ConfigDumpGlobalInstanceId string `` /* 145-byte string literal not displayed */
	// Global instance ID that handles Stats streams.
	StatsGlobalInstanceId string `` /* 128-byte string literal not displayed */
	// Global instance ID that handles Clusters streams.
	ClustersGlobalInstanceId string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EnvoyAdminStreams) Descriptor deprecated 

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

Deprecated: Use EnvoyAdminStreams.ProtoReflect.Descriptor instead.

func (*EnvoyAdminStreams) GetClustersGlobalInstanceId 

func (x *EnvoyAdminStreams) GetClustersGlobalInstanceId() string

func (*EnvoyAdminStreams) GetConfigDumpGlobalInstanceId 

func (x *EnvoyAdminStreams) GetConfigDumpGlobalInstanceId() string

func (*EnvoyAdminStreams) GetStatsGlobalInstanceId 

func (x *EnvoyAdminStreams) GetStatsGlobalInstanceId() string

func (*EnvoyAdminStreams) ProtoMessage 

func (*EnvoyAdminStreams) ProtoMessage()

func (*EnvoyAdminStreams) ProtoReflect 

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

func (*EnvoyAdminStreams) Reset 

func (x *EnvoyAdminStreams) Reset()

func (*EnvoyAdminStreams) String 

func (x *EnvoyAdminStreams) String() string

type HealthCheck 

type HealthCheck struct {

	// Time last health check received
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

HealthCheck holds information about the received zone health check

func (*HealthCheck) Descriptor deprecated 

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

Deprecated: Use HealthCheck.ProtoReflect.Descriptor instead.

func (*HealthCheck) GetTime 

func (x *HealthCheck) GetTime() *timestamppb.Timestamp

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) ProtoReflect 

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

func (*HealthCheck) Reset 

func (x *HealthCheck) Reset()

func (*HealthCheck) String 

func (x *HealthCheck) String() string

type InterCpPingServiceClient 

type InterCpPingServiceClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

InterCpPingServiceClient is the client API for InterCpPingService 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 NewInterCpPingServiceClient 

func NewInterCpPingServiceClient(cc grpc.ClientConnInterface) InterCpPingServiceClient

type InterCpPingServiceServer 

type InterCpPingServiceServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// contains filtered or unexported methods
}

InterCpPingServiceServer is the server API for InterCpPingService service. All implementations must embed UnimplementedInterCpPingServiceServer for forward compatibility

type PingRequest 

type PingRequest struct {
	InstanceId  string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	Address     string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	InterCpPort uint32 `protobuf:"varint,3,opt,name=inter_cp_port,json=interCpPort,proto3" json:"inter_cp_port,omitempty"`
	Ready       bool   `protobuf:"varint,4,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetAddress 

func (x *PingRequest) GetAddress() string

func (*PingRequest) GetInstanceId 

func (x *PingRequest) GetInstanceId() string

func (*PingRequest) GetInterCpPort 

func (x *PingRequest) GetInterCpPort() uint32

func (*PingRequest) GetReady 

func (x *PingRequest) GetReady() bool

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	Leader bool `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetLeader 

func (x *PingResponse) GetLeader() bool

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type Secret 

type Secret struct {

	// Value of the secret
	Data *wrapperspb.BytesValue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Secret defines an encrypted value in Dubbo.

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetData 

func (x *Secret) GetData() *wrapperspb.BytesValue

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type UnimplementedInterCpPingServiceServer 

type UnimplementedInterCpPingServiceServer struct {
}

UnimplementedInterCpPingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInterCpPingServiceServer) Ping 

func (UnimplementedInterCpPingServiceServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnsafeInterCpPingServiceServer 

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

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

type Zone 

type Zone struct {

	// enable allows to turn the zone on/off and exclude the whole zone from
	// balancing traffic on it
	Enabled *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

Zone defines the Zone configuration used at the Global Control Plane within a distributed deployment

func (*Zone) Descriptor deprecated 

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

Deprecated: Use Zone.ProtoReflect.Descriptor instead.

func (*Zone) GetEnabled 

func (x *Zone) GetEnabled() *wrapperspb.BoolValue

func (*Zone) IsEnabled 

func (x *Zone) IsEnabled() bool

func (*Zone) ProtoMessage 

func (*Zone) ProtoMessage()

func (*Zone) ProtoReflect 

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

func (*Zone) Reset 

func (x *Zone) Reset()

func (*Zone) String 

func (x *Zone) String() string

type ZoneInsight 

type ZoneInsight struct {

	// List of DDS subscriptions created by a given Zone Dubbo CP.
	Subscriptions []*DDSSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Statistics about Envoy Admin Streams
	EnvoyAdminStreams *EnvoyAdminStreams `protobuf:"bytes,2,opt,name=envoy_admin_streams,json=envoyAdminStreams,proto3" json:"envoy_admin_streams,omitempty"`
	HealthCheck       *HealthCheck       `protobuf:"bytes,3,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	// contains filtered or unexported fields
}

func (*ZoneInsight) Descriptor deprecated 

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

Deprecated: Use ZoneInsight.ProtoReflect.Descriptor instead.

func (*ZoneInsight) GetEnvoyAdminStreams 

func (x *ZoneInsight) GetEnvoyAdminStreams() *EnvoyAdminStreams

func (*ZoneInsight) GetHealthCheck 

func (x *ZoneInsight) GetHealthCheck() *HealthCheck

func (*ZoneInsight) GetSubscriptions 

func (x *ZoneInsight) GetSubscriptions() []*DDSSubscription

func (*ZoneInsight) IsOnline 

func (x *ZoneInsight) IsOnline() bool

func (*ZoneInsight) ProtoMessage 

func (*ZoneInsight) ProtoMessage()

func (*ZoneInsight) ProtoReflect 

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

func (*ZoneInsight) Reset 

func (x *ZoneInsight) Reset()

func (*ZoneInsight) String 

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