v1alpha1

package
v0.0.0-...-de7669e Latest Latest
Warning

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

Go to latest
Published: May 21, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Code generated by protoc-gen-jsonshim. DO NOT EDIT.

Code generated by protoc-gen-deepcopy. DO NOT EDIT.

Code generated by protoc-gen-jsonshim. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source
var (
	ServiceMetadataMarshaler   = &jsonpb.Marshaler{}
	ServiceMetadataUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source
var (
	SnpMarshaler   = &jsonpb.Marshaler{}
	SnpUnmarshaler = &jsonpb.Unmarshaler{AllowUnknownFields: true}
)
View Source
var File_dubbo_v1alpha1_service_metadata_proto protoreflect.FileDescriptor
View Source
var File_dubbo_v1alpha1_snp_proto protoreflect.FileDescriptor
View Source
var ServiceMetadataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dubbo.networking.v1alpha1.ServiceMetadataService",
	HandlerType: (*ServiceMetadataServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _ServiceMetadataService_Publish_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ServiceMetadataService_Get_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dubbo/v1alpha1/service_metadata.proto",
}

ServiceMetadataService_ServiceDesc is the grpc.ServiceDesc for ServiceMetadataService 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.networking.v1alpha1.ServiceNameMappingService",
	HandlerType: (*ServiceNameMappingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "registerServiceAppMapping",
			Handler:    _ServiceNameMappingService_RegisterServiceAppMapping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dubbo/v1alpha1/snp.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 RegisterServiceMetadataServiceServer

func RegisterServiceMetadataServiceServer(s grpc.ServiceRegistrar, srv ServiceMetadataServiceServer)

func RegisterServiceNameMappingServiceServer

func RegisterServiceNameMappingServiceServer(s grpc.ServiceRegistrar, srv ServiceNameMappingServiceServer)

Types

type GetServiceMetadataRequest

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

func (*GetServiceMetadataRequest) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetServiceMetadataRequest. Required by controller-gen.

func (*GetServiceMetadataRequest) DeepCopyInterface

func (in *GetServiceMetadataRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetServiceMetadataRequest. Required by controller-gen.

func (*GetServiceMetadataRequest) DeepCopyInto

DeepCopyInto supports using GetServiceMetadataRequest within kubernetes types, where deepcopy-gen is used.

func (*GetServiceMetadataRequest) Descriptor deprecated

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

Deprecated: Use GetServiceMetadataRequest.ProtoReflect.Descriptor instead.

func (*GetServiceMetadataRequest) GetApplicationName

func (x *GetServiceMetadataRequest) GetApplicationName() string

func (*GetServiceMetadataRequest) GetNamespace

func (x *GetServiceMetadataRequest) GetNamespace() string

func (*GetServiceMetadataRequest) GetRevision

func (x *GetServiceMetadataRequest) GetRevision() string

func (*GetServiceMetadataRequest) MarshalJSON

func (this *GetServiceMetadataRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for GetServiceMetadataRequest

func (*GetServiceMetadataRequest) ProtoMessage

func (*GetServiceMetadataRequest) ProtoMessage()

func (*GetServiceMetadataRequest) ProtoReflect

func (*GetServiceMetadataRequest) Reset

func (x *GetServiceMetadataRequest) Reset()

func (*GetServiceMetadataRequest) String

func (x *GetServiceMetadataRequest) String() string

func (*GetServiceMetadataRequest) UnmarshalJSON

func (this *GetServiceMetadataRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for GetServiceMetadataRequest

type GetServiceMetadataResponse

type GetServiceMetadataResponse struct {
	MetadataInfo string `protobuf:"bytes,1,opt,name=metadata_info,json=metadataInfo,proto3" json:"metadata_info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServiceMetadataResponse) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetServiceMetadataResponse. Required by controller-gen.

func (*GetServiceMetadataResponse) DeepCopyInterface

func (in *GetServiceMetadataResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetServiceMetadataResponse. Required by controller-gen.

func (*GetServiceMetadataResponse) DeepCopyInto

DeepCopyInto supports using GetServiceMetadataResponse within kubernetes types, where deepcopy-gen is used.

func (*GetServiceMetadataResponse) Descriptor deprecated

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

Deprecated: Use GetServiceMetadataResponse.ProtoReflect.Descriptor instead.

func (*GetServiceMetadataResponse) GetMetadataInfo

func (x *GetServiceMetadataResponse) GetMetadataInfo() string

func (*GetServiceMetadataResponse) MarshalJSON

func (this *GetServiceMetadataResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for GetServiceMetadataResponse

func (*GetServiceMetadataResponse) ProtoMessage

func (*GetServiceMetadataResponse) ProtoMessage()

func (*GetServiceMetadataResponse) ProtoReflect

func (*GetServiceMetadataResponse) Reset

func (x *GetServiceMetadataResponse) Reset()

func (*GetServiceMetadataResponse) String

func (x *GetServiceMetadataResponse) String() string

func (*GetServiceMetadataResponse) UnmarshalJSON

func (this *GetServiceMetadataResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for GetServiceMetadataResponse

type PublishServiceMetadataRequest

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

func (*PublishServiceMetadataRequest) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublishServiceMetadataRequest. Required by controller-gen.

func (*PublishServiceMetadataRequest) DeepCopyInterface

func (in *PublishServiceMetadataRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new PublishServiceMetadataRequest. Required by controller-gen.

func (*PublishServiceMetadataRequest) DeepCopyInto

DeepCopyInto supports using PublishServiceMetadataRequest within kubernetes types, where deepcopy-gen is used.

func (*PublishServiceMetadataRequest) Descriptor deprecated

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

Deprecated: Use PublishServiceMetadataRequest.ProtoReflect.Descriptor instead.

func (*PublishServiceMetadataRequest) GetApplicationName

func (x *PublishServiceMetadataRequest) GetApplicationName() string

func (*PublishServiceMetadataRequest) GetMetadataInfo

func (x *PublishServiceMetadataRequest) GetMetadataInfo() string

func (*PublishServiceMetadataRequest) GetNamespace

func (x *PublishServiceMetadataRequest) GetNamespace() string

func (*PublishServiceMetadataRequest) GetRevision

func (x *PublishServiceMetadataRequest) GetRevision() string

func (*PublishServiceMetadataRequest) MarshalJSON

func (this *PublishServiceMetadataRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for PublishServiceMetadataRequest

func (*PublishServiceMetadataRequest) ProtoMessage

func (*PublishServiceMetadataRequest) ProtoMessage()

func (*PublishServiceMetadataRequest) ProtoReflect

func (*PublishServiceMetadataRequest) Reset

func (x *PublishServiceMetadataRequest) Reset()

func (*PublishServiceMetadataRequest) String

func (*PublishServiceMetadataRequest) UnmarshalJSON

func (this *PublishServiceMetadataRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for PublishServiceMetadataRequest

type PublishServiceMetadataResponse

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

func (*PublishServiceMetadataResponse) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublishServiceMetadataResponse. Required by controller-gen.

func (*PublishServiceMetadataResponse) DeepCopyInterface

func (in *PublishServiceMetadataResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new PublishServiceMetadataResponse. Required by controller-gen.

func (*PublishServiceMetadataResponse) DeepCopyInto

DeepCopyInto supports using PublishServiceMetadataResponse within kubernetes types, where deepcopy-gen is used.

func (*PublishServiceMetadataResponse) Descriptor deprecated

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

Deprecated: Use PublishServiceMetadataResponse.ProtoReflect.Descriptor instead.

func (*PublishServiceMetadataResponse) MarshalJSON

func (this *PublishServiceMetadataResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for PublishServiceMetadataResponse

func (*PublishServiceMetadataResponse) ProtoMessage

func (*PublishServiceMetadataResponse) ProtoMessage()

func (*PublishServiceMetadataResponse) ProtoReflect

func (*PublishServiceMetadataResponse) Reset

func (x *PublishServiceMetadataResponse) Reset()

func (*PublishServiceMetadataResponse) String

func (*PublishServiceMetadataResponse) UnmarshalJSON

func (this *PublishServiceMetadataResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for PublishServiceMetadataResponse

type ServiceMappingRequest

type ServiceMappingRequest struct {

	// This is namespace of proxyless dubbo server
	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"`
	// contains filtered or unexported fields
}

When dubbo provider start up, it reports its applicationName and its interfaceName, and Dubbo consumer will get the service name mapping info by xDS.

func (*ServiceMappingRequest) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingRequest. Required by controller-gen.

func (*ServiceMappingRequest) DeepCopyInterface

func (in *ServiceMappingRequest) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingRequest. Required by controller-gen.

func (*ServiceMappingRequest) DeepCopyInto

func (in *ServiceMappingRequest) DeepCopyInto(out *ServiceMappingRequest)

DeepCopyInto supports using ServiceMappingRequest within kubernetes types, where deepcopy-gen is used.

func (*ServiceMappingRequest) Descriptor deprecated

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

Deprecated: Use ServiceMappingRequest.ProtoReflect.Descriptor instead.

func (*ServiceMappingRequest) GetApplicationName

func (x *ServiceMappingRequest) GetApplicationName() string

func (*ServiceMappingRequest) GetInterfaceNames

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

func (*ServiceMappingRequest) GetNamespace

func (x *ServiceMappingRequest) GetNamespace() string

func (*ServiceMappingRequest) MarshalJSON

func (this *ServiceMappingRequest) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ServiceMappingRequest

func (*ServiceMappingRequest) ProtoMessage

func (*ServiceMappingRequest) ProtoMessage()

func (*ServiceMappingRequest) ProtoReflect

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

func (*ServiceMappingRequest) Reset

func (x *ServiceMappingRequest) Reset()

func (*ServiceMappingRequest) String

func (x *ServiceMappingRequest) String() string

func (*ServiceMappingRequest) UnmarshalJSON

func (this *ServiceMappingRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ServiceMappingRequest

type ServiceMappingResponse

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

func (*ServiceMappingResponse) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingResponse. Required by controller-gen.

func (*ServiceMappingResponse) DeepCopyInterface

func (in *ServiceMappingResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingResponse. Required by controller-gen.

func (*ServiceMappingResponse) DeepCopyInto

func (in *ServiceMappingResponse) DeepCopyInto(out *ServiceMappingResponse)

DeepCopyInto supports using ServiceMappingResponse within kubernetes types, where deepcopy-gen is used.

func (*ServiceMappingResponse) Descriptor deprecated

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

Deprecated: Use ServiceMappingResponse.ProtoReflect.Descriptor instead.

func (*ServiceMappingResponse) MarshalJSON

func (this *ServiceMappingResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ServiceMappingResponse

func (*ServiceMappingResponse) ProtoMessage

func (*ServiceMappingResponse) ProtoMessage()

func (*ServiceMappingResponse) ProtoReflect

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

func (*ServiceMappingResponse) Reset

func (x *ServiceMappingResponse) Reset()

func (*ServiceMappingResponse) String

func (x *ServiceMappingResponse) String() string

func (*ServiceMappingResponse) UnmarshalJSON

func (this *ServiceMappingResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ServiceMappingResponse

type ServiceMappingXdsResponse

type ServiceMappingXdsResponse struct {

	// This is namespace of proxyless dubbo server
	Namespace        string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,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 (*ServiceMappingXdsResponse) DeepCopy

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingXdsResponse. Required by controller-gen.

func (*ServiceMappingXdsResponse) DeepCopyInterface

func (in *ServiceMappingXdsResponse) DeepCopyInterface() interface{}

DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new ServiceMappingXdsResponse. Required by controller-gen.

func (*ServiceMappingXdsResponse) DeepCopyInto

DeepCopyInto supports using ServiceMappingXdsResponse within kubernetes types, where deepcopy-gen is used.

func (*ServiceMappingXdsResponse) Descriptor deprecated

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

Deprecated: Use ServiceMappingXdsResponse.ProtoReflect.Descriptor instead.

func (*ServiceMappingXdsResponse) GetApplicationNames

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

func (*ServiceMappingXdsResponse) GetInterfaceName

func (x *ServiceMappingXdsResponse) GetInterfaceName() string

func (*ServiceMappingXdsResponse) GetNamespace

func (x *ServiceMappingXdsResponse) GetNamespace() string

func (*ServiceMappingXdsResponse) MarshalJSON

func (this *ServiceMappingXdsResponse) MarshalJSON() ([]byte, error)

MarshalJSON is a custom marshaler for ServiceMappingXdsResponse

func (*ServiceMappingXdsResponse) ProtoMessage

func (*ServiceMappingXdsResponse) ProtoMessage()

func (*ServiceMappingXdsResponse) ProtoReflect

func (*ServiceMappingXdsResponse) Reset

func (x *ServiceMappingXdsResponse) Reset()

func (*ServiceMappingXdsResponse) String

func (x *ServiceMappingXdsResponse) String() string

func (*ServiceMappingXdsResponse) UnmarshalJSON

func (this *ServiceMappingXdsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON is a custom unmarshaler for ServiceMappingXdsResponse

type ServiceMetadataServiceClient

type ServiceMetadataServiceClient interface {
	Publish(ctx context.Context, in *PublishServiceMetadataRequest, opts ...grpc.CallOption) (*PublishServiceMetadataResponse, error)
	Get(ctx context.Context, in *GetServiceMetadataRequest, opts ...grpc.CallOption) (*GetServiceMetadataResponse, error)
}

ServiceMetadataServiceClient is the client API for ServiceMetadataService service.

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

type ServiceMetadataServiceServer

type ServiceMetadataServiceServer interface {
	Publish(context.Context, *PublishServiceMetadataRequest) (*PublishServiceMetadataResponse, error)
	Get(context.Context, *GetServiceMetadataRequest) (*GetServiceMetadataResponse, error)
	// contains filtered or unexported methods
}

ServiceMetadataServiceServer is the server API for ServiceMetadataService service. All implementations must embed UnimplementedServiceMetadataServiceServer for forward compatibility

type ServiceNameMappingServiceClient

type ServiceNameMappingServiceClient interface {
	RegisterServiceAppMapping(ctx context.Context, in *ServiceMappingRequest, opts ...grpc.CallOption) (*ServiceMappingResponse, 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.

type ServiceNameMappingServiceServer

type ServiceNameMappingServiceServer interface {
	RegisterServiceAppMapping(context.Context, *ServiceMappingRequest) (*ServiceMappingResponse, error)
	// contains filtered or unexported methods
}

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

type UnimplementedServiceMetadataServiceServer

type UnimplementedServiceMetadataServiceServer struct {
}

UnimplementedServiceMetadataServiceServer must be embedded to have forward compatible implementations.

type UnimplementedServiceNameMappingServiceServer

type UnimplementedServiceNameMappingServiceServer struct {
}

UnimplementedServiceNameMappingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceNameMappingServiceServer) RegisterServiceAppMapping

type UnsafeServiceMetadataServiceServer

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

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

Jump to

Keyboard shortcuts

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