apiextensions

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HTTPAPIExtension_Configure_FullMethodName = "/apiextensions.HTTPAPIExtension/Configure"
)
View Source 
const (
	ManagementAPIExtension_Descriptors_FullMethodName = "/apiextensions.ManagementAPIExtension/Descriptors"
)
View Source 
const (
	StreamAPIExtension_ConnectInternal_FullMethodName = "/apiextensions.StreamAPIExtension/ConnectInternal"
)
View Source 
const (
	UnaryAPIExtension_UnaryDescriptor_FullMethodName = "/apiextensions.UnaryAPIExtension/UnaryDescriptor"
)

Variables

View Source 
var File_github_com_rancher_opni_pkg_plugins_apis_apiextensions_apiextensions_proto protoreflect.FileDescriptor
View Source 
var HTTPAPIExtension_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apiextensions.HTTPAPIExtension",
	HandlerType: (*HTTPAPIExtensionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Configure",
			Handler:    _HTTPAPIExtension_Configure_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/apiextensions/apiextensions.proto",
}

HTTPAPIExtension_ServiceDesc is the grpc.ServiceDesc for HTTPAPIExtension 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 ManagementAPIExtension_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apiextensions.ManagementAPIExtension",
	HandlerType: (*ManagementAPIExtensionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Descriptors",
			Handler:    _ManagementAPIExtension_Descriptors_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/apiextensions/apiextensions.proto",
}

ManagementAPIExtension_ServiceDesc is the grpc.ServiceDesc for ManagementAPIExtension 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 StreamAPIExtension_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apiextensions.StreamAPIExtension",
	HandlerType: (*StreamAPIExtensionServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ConnectInternal",
			Handler:       _StreamAPIExtension_ConnectInternal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/apiextensions/apiextensions.proto",
}

StreamAPIExtension_ServiceDesc is the grpc.ServiceDesc for StreamAPIExtension 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 UnaryAPIExtension_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "apiextensions.UnaryAPIExtension",
	HandlerType: (*UnaryAPIExtensionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UnaryDescriptor",
			Handler:    _UnaryAPIExtension_UnaryDescriptor_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/plugins/apis/apiextensions/apiextensions.proto",
}

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

Functions

func RegisterHTTPAPIExtensionServer added in v0.6.0 

func RegisterHTTPAPIExtensionServer(s grpc.ServiceRegistrar, srv HTTPAPIExtensionServer)

func RegisterManagementAPIExtensionServer 

func RegisterManagementAPIExtensionServer(s grpc.ServiceRegistrar, srv ManagementAPIExtensionServer)

func RegisterStreamAPIExtensionServer added in v0.5.4 

func RegisterStreamAPIExtensionServer(s grpc.ServiceRegistrar, srv StreamAPIExtensionServer)

func RegisterUnaryAPIExtensionServer added in v0.5.4 

func RegisterUnaryAPIExtensionServer(s grpc.ServiceRegistrar, srv UnaryAPIExtensionServer)

Types

type CertConfig 

type CertConfig struct {
	Ca       string `protobuf:"bytes,1,opt,name=ca,proto3" json:"ca,omitempty"`
	CaData   []byte `protobuf:"bytes,2,opt,name=caData,proto3" json:"caData,omitempty"`
	Cert     string `protobuf:"bytes,3,opt,name=cert,proto3" json:"cert,omitempty"`
	CertData []byte `protobuf:"bytes,4,opt,name=certData,proto3" json:"certData,omitempty"`
	Key      string `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	KeyData  []byte `protobuf:"bytes,6,opt,name=keyData,proto3" json:"keyData,omitempty"`
	Insecure bool   `protobuf:"varint,7,opt,name=insecure,proto3" json:"insecure,omitempty"`
	// contains filtered or unexported fields
}

func NewCertConfig 

func NewCertConfig(certs v1beta1.CertsSpec) *CertConfig

func NewInsecureCertConfig added in v0.6.0 

func NewInsecureCertConfig() *CertConfig

func (*CertConfig) Descriptor deprecated 

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

Deprecated: Use CertConfig.ProtoReflect.Descriptor instead.

func (*CertConfig) GetCa 

func (x *CertConfig) GetCa() string

func (*CertConfig) GetCaData 

func (x *CertConfig) GetCaData() []byte

func (*CertConfig) GetCert 

func (x *CertConfig) GetCert() string

func (*CertConfig) GetCertData 

func (x *CertConfig) GetCertData() []byte

func (*CertConfig) GetInsecure added in v0.6.0 

func (x *CertConfig) GetInsecure() bool

func (*CertConfig) GetKey 

func (x *CertConfig) GetKey() string

func (*CertConfig) GetKeyData 

func (x *CertConfig) GetKeyData() []byte

func (*CertConfig) ProtoMessage 

func (*CertConfig) ProtoMessage()

func (*CertConfig) ProtoReflect 

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

func (*CertConfig) Reset 

func (x *CertConfig) Reset()

func (*CertConfig) String 

func (x *CertConfig) String() string

func (*CertConfig) TLSConfig 

func (tc *CertConfig) TLSConfig() (*tls.Config, error)

type HTTPAPIExtensionClient added in v0.6.0 

type HTTPAPIExtensionClient interface {
	Configure(ctx context.Context, in *CertConfig, opts ...grpc.CallOption) (*HTTPAPIExtensionConfig, error)
}

HTTPAPIExtensionClient is the client API for HTTPAPIExtension 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 NewHTTPAPIExtensionClient added in v0.6.0 

func NewHTTPAPIExtensionClient(cc grpc.ClientConnInterface) HTTPAPIExtensionClient

type HTTPAPIExtensionConfig added in v0.6.0 

type HTTPAPIExtensionConfig struct {
	HttpAddr string       `protobuf:"bytes,1,opt,name=httpAddr,proto3" json:"httpAddr,omitempty"`
	Routes   []*RouteInfo `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*HTTPAPIExtensionConfig) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use HTTPAPIExtensionConfig.ProtoReflect.Descriptor instead.

func (*HTTPAPIExtensionConfig) GetHttpAddr added in v0.6.0 

func (x *HTTPAPIExtensionConfig) GetHttpAddr() string

func (*HTTPAPIExtensionConfig) GetRoutes added in v0.6.0 

func (x *HTTPAPIExtensionConfig) GetRoutes() []*RouteInfo

func (*HTTPAPIExtensionConfig) ProtoMessage added in v0.6.0 

func (*HTTPAPIExtensionConfig) ProtoMessage()

func (*HTTPAPIExtensionConfig) ProtoReflect added in v0.6.0 

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

func (*HTTPAPIExtensionConfig) Reset added in v0.6.0 

func (x *HTTPAPIExtensionConfig) Reset()

func (*HTTPAPIExtensionConfig) String added in v0.6.0 

func (x *HTTPAPIExtensionConfig) String() string

type HTTPAPIExtensionServer added in v0.6.0 

type HTTPAPIExtensionServer interface {
	Configure(context.Context, *CertConfig) (*HTTPAPIExtensionConfig, error)
	// contains filtered or unexported methods
}

HTTPAPIExtensionServer is the server API for HTTPAPIExtension service. All implementations must embed UnimplementedHTTPAPIExtensionServer for forward compatibility

type ManagementAPIExtensionClient 

type ManagementAPIExtensionClient interface {
	Descriptors(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServiceDescriptorProtoList, error)
}

ManagementAPIExtensionClient is the client API for ManagementAPIExtension 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 NewManagementAPIExtensionClient 

func NewManagementAPIExtensionClient(cc grpc.ClientConnInterface) ManagementAPIExtensionClient

type ManagementAPIExtensionServer 

type ManagementAPIExtensionServer interface {
	Descriptors(context.Context, *emptypb.Empty) (*ServiceDescriptorProtoList, error)
	// contains filtered or unexported methods
}

ManagementAPIExtensionServer is the server API for ManagementAPIExtension service. All implementations must embed UnimplementedManagementAPIExtensionServer for forward compatibility

type RouteInfo added in v0.5.4 

type RouteInfo struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*RouteInfo) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use RouteInfo.ProtoReflect.Descriptor instead.

func (*RouteInfo) GetMethod added in v0.5.4 

func (x *RouteInfo) GetMethod() string

func (*RouteInfo) GetPath added in v0.5.4 

func (x *RouteInfo) GetPath() string

func (*RouteInfo) ProtoMessage added in v0.5.4 

func (*RouteInfo) ProtoMessage()

func (*RouteInfo) ProtoReflect added in v0.5.4 

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

func (*RouteInfo) Reset added in v0.5.4 

func (x *RouteInfo) Reset()

func (*RouteInfo) String added in v0.5.4 

func (x *RouteInfo) String() string

type ServiceDescriptor added in v0.6.0 

type ServiceDescriptor struct {
	ServiceDescriptor *descriptorpb.ServiceDescriptorProto `protobuf:"bytes,1,opt,name=serviceDescriptor,proto3" json:"serviceDescriptor,omitempty"`
	Options           *ServiceOptions                      `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceDescriptor) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use ServiceDescriptor.ProtoReflect.Descriptor instead.

func (*ServiceDescriptor) GetOptions added in v0.6.0 

func (x *ServiceDescriptor) GetOptions() *ServiceOptions

func (*ServiceDescriptor) GetServiceDescriptor added in v0.6.0 

func (x *ServiceDescriptor) GetServiceDescriptor() *descriptorpb.ServiceDescriptorProto

func (*ServiceDescriptor) ProtoMessage added in v0.6.0 

func (*ServiceDescriptor) ProtoMessage()

func (*ServiceDescriptor) ProtoReflect added in v0.6.0 

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

func (*ServiceDescriptor) Reset added in v0.6.0 

func (x *ServiceDescriptor) Reset()

func (*ServiceDescriptor) String added in v0.6.0 

func (x *ServiceDescriptor) String() string

type ServiceDescriptorList added in v0.5.4 

type ServiceDescriptorList struct {
	Items []*ServiceDescriptor `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceDescriptorList) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use ServiceDescriptorList.ProtoReflect.Descriptor instead.

func (*ServiceDescriptorList) GetItems added in v0.6.0 

func (x *ServiceDescriptorList) GetItems() []*ServiceDescriptor

func (*ServiceDescriptorList) ProtoMessage added in v0.5.4 

func (*ServiceDescriptorList) ProtoMessage()

func (*ServiceDescriptorList) ProtoReflect added in v0.5.4 

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

func (*ServiceDescriptorList) Reset added in v0.5.4 

func (x *ServiceDescriptorList) Reset()

func (*ServiceDescriptorList) String added in v0.5.4 

func (x *ServiceDescriptorList) String() string

type ServiceDescriptorProtoList added in v0.6.0 

type ServiceDescriptorProtoList struct {
	Items []*descriptorpb.ServiceDescriptorProto `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceDescriptorProtoList) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use ServiceDescriptorProtoList.ProtoReflect.Descriptor instead.

func (*ServiceDescriptorProtoList) GetItems added in v0.6.0 

func (x *ServiceDescriptorProtoList) GetItems() []*descriptorpb.ServiceDescriptorProto

func (*ServiceDescriptorProtoList) ProtoMessage added in v0.6.0 

func (*ServiceDescriptorProtoList) ProtoMessage()

func (*ServiceDescriptorProtoList) ProtoReflect added in v0.6.0 

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

func (*ServiceDescriptorProtoList) Reset added in v0.6.0 

func (x *ServiceDescriptorProtoList) Reset()

func (*ServiceDescriptorProtoList) String added in v0.6.0 

func (x *ServiceDescriptorProtoList) String() string

type ServiceOptions added in v0.6.0 

type ServiceOptions struct {

	// If set, the service will only be available to clusters that have this
	// capability.
	RequireCapability string `protobuf:"bytes,1,opt,name=requireCapability,proto3" json:"requireCapability,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceOptions) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use ServiceOptions.ProtoReflect.Descriptor instead.

func (*ServiceOptions) GetRequireCapability added in v0.6.0 

func (x *ServiceOptions) GetRequireCapability() string

func (*ServiceOptions) ProtoMessage added in v0.6.0 

func (*ServiceOptions) ProtoMessage()

func (*ServiceOptions) ProtoReflect added in v0.6.0 

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

func (*ServiceOptions) Reset added in v0.6.0 

func (x *ServiceOptions) Reset()

func (*ServiceOptions) String added in v0.6.0 

func (x *ServiceOptions) String() string

type StreamAPIExtensionClient added in v0.5.4 

type StreamAPIExtensionClient interface {
	ConnectInternal(ctx context.Context, opts ...grpc.CallOption) (StreamAPIExtension_ConnectInternalClient, error)
}

StreamAPIExtensionClient is the client API for StreamAPIExtension 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 NewStreamAPIExtensionClient added in v0.5.4 

func NewStreamAPIExtensionClient(cc grpc.ClientConnInterface) StreamAPIExtensionClient

type StreamAPIExtensionServer added in v0.5.4 

type StreamAPIExtensionServer interface {
	ConnectInternal(StreamAPIExtension_ConnectInternalServer) error
	// contains filtered or unexported methods
}

StreamAPIExtensionServer is the server API for StreamAPIExtension service. All implementations must embed UnimplementedStreamAPIExtensionServer for forward compatibility

type StreamAPIExtension_ConnectInternalClient added in v0.9.2 

type StreamAPIExtension_ConnectInternalClient interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ClientStream
}

type StreamAPIExtension_ConnectInternalServer added in v0.9.2 

type StreamAPIExtension_ConnectInternalServer interface {
	Send(*totem.RPC) error
	Recv() (*totem.RPC, error)
	grpc.ServerStream
}

type UnaryAPIExtensionClient added in v0.5.4 

type UnaryAPIExtensionClient interface {
	UnaryDescriptor(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*descriptorpb.ServiceDescriptorProto, error)
}

UnaryAPIExtensionClient is the client API for UnaryAPIExtension 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 NewUnaryAPIExtensionClient added in v0.5.4 

func NewUnaryAPIExtensionClient(cc grpc.ClientConnInterface) UnaryAPIExtensionClient

type UnaryAPIExtensionServer added in v0.5.4 

type UnaryAPIExtensionServer interface {
	UnaryDescriptor(context.Context, *emptypb.Empty) (*descriptorpb.ServiceDescriptorProto, error)
	// contains filtered or unexported methods
}

UnaryAPIExtensionServer is the server API for UnaryAPIExtension service. All implementations must embed UnimplementedUnaryAPIExtensionServer for forward compatibility

type UnimplementedHTTPAPIExtensionServer added in v0.6.0 

type UnimplementedHTTPAPIExtensionServer struct {
}

UnimplementedHTTPAPIExtensionServer must be embedded to have forward compatible implementations.

func (UnimplementedHTTPAPIExtensionServer) Configure added in v0.6.0 

func (UnimplementedHTTPAPIExtensionServer) Configure(context.Context, *CertConfig) (*HTTPAPIExtensionConfig, error)

type UnimplementedManagementAPIExtensionServer 

type UnimplementedManagementAPIExtensionServer struct {
}

UnimplementedManagementAPIExtensionServer must be embedded to have forward compatible implementations.

func (UnimplementedManagementAPIExtensionServer) Descriptors added in v0.6.0 

func (UnimplementedManagementAPIExtensionServer) Descriptors(context.Context, *emptypb.Empty) (*ServiceDescriptorProtoList, error)

type UnimplementedStreamAPIExtensionServer added in v0.5.4 

type UnimplementedStreamAPIExtensionServer struct {
}

UnimplementedStreamAPIExtensionServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamAPIExtensionServer) ConnectInternal added in v0.9.2 

func (UnimplementedStreamAPIExtensionServer) ConnectInternal(StreamAPIExtension_ConnectInternalServer) error

type UnimplementedUnaryAPIExtensionServer added in v0.5.4 

type UnimplementedUnaryAPIExtensionServer struct {
}

UnimplementedUnaryAPIExtensionServer must be embedded to have forward compatible implementations.

func (UnimplementedUnaryAPIExtensionServer) UnaryDescriptor added in v0.5.4 

func (UnimplementedUnaryAPIExtensionServer) UnaryDescriptor(context.Context, *emptypb.Empty) (*descriptorpb.ServiceDescriptorProto, error)

type UnsafeHTTPAPIExtensionServer added in v0.6.0 

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

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

type UnsafeManagementAPIExtensionServer 

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

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

type UnsafeStreamAPIExtensionServer added in v0.5.4 

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

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

type UnsafeUnaryAPIExtensionServer added in v0.5.4 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.