apiextensions

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(certs v1beta1.CertsSpec) *CertConfig

func NewInsecureCertConfig() *CertConfig

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

func (x *CertConfig) GetCa() string

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

func (x *CertConfig) GetCert() string

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

func (x *CertConfig) GetInsecure() bool

func (x *CertConfig) GetKey() string

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

func (*CertConfig) ProtoMessage()

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

func (x *CertConfig) Reset()

func (x *CertConfig) String() string

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(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() ([]byte, []int)

func (x *HTTPAPIExtensionConfig) GetHttpAddr() string

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

func (*HTTPAPIExtensionConfig) ProtoMessage()

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

func (x *HTTPAPIExtensionConfig) Reset()

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(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() ([]byte, []int)

func (x *RouteInfo) GetMethod() string

func (x *RouteInfo) GetPath() string

func (*RouteInfo) ProtoMessage()

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

func (x *RouteInfo) Reset()

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() ([]byte, []int)

func (x *ServiceDescriptor) GetOptions() *ServiceOptions

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

func (*ServiceDescriptor) ProtoMessage()

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

func (x *ServiceDescriptor) Reset()

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() ([]byte, []int)

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

func (*ServiceDescriptorList) ProtoMessage()

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

func (x *ServiceDescriptorList) Reset()

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() ([]byte, []int)

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

func (*ServiceDescriptorProtoList) ProtoMessage()

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

func (x *ServiceDescriptorProtoList) Reset()

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() ([]byte, []int)

func (x *ServiceOptions) GetRequireCapability() string

func (*ServiceOptions) ProtoMessage()

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

func (x *ServiceOptions) Reset()

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(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(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(context.Context, *CertConfig) (*HTTPAPIExtensionConfig, error)

type UnimplementedManagementAPIExtensionServer ¶

type UnimplementedManagementAPIExtensionServer struct {
}

UnimplementedManagementAPIExtensionServer must be embedded to have forward compatible implementations.

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(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(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.