Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterControlPlaneServiceServer(s grpc.ServiceRegistrar, srv ControlPlaneServiceServer)
- type ControlPlaneServiceClient
- type ControlPlaneServiceServer
- type EvictRouteRequest
- type EvictRouteResponse
- type GetLastActiveRequest
- type GetLastActiveResponse
- func (*GetLastActiveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLastActiveResponse) GetLastActive() map[string]string
- func (*GetLastActiveResponse) ProtoMessage()
- func (x *GetLastActiveResponse) ProtoReflect() protoreflect.Message
- func (x *GetLastActiveResponse) Reset()
- func (x *GetLastActiveResponse) String() string
- type PushRouteRequest
- func (*PushRouteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushRouteRequest) GetNamespace() string
- func (x *PushRouteRequest) GetPodName() string
- func (x *PushRouteRequest) GetSandboxId() string
- func (*PushRouteRequest) ProtoMessage()
- func (x *PushRouteRequest) ProtoReflect() protoreflect.Message
- func (x *PushRouteRequest) Reset()
- func (x *PushRouteRequest) String() string
- type PushRouteResponse
- type UnimplementedControlPlaneServiceServer
- func (UnimplementedControlPlaneServiceServer) EvictRoute(context.Context, *EvictRouteRequest) (*EvictRouteResponse, error)
- func (UnimplementedControlPlaneServiceServer) GetLastActive(context.Context, *GetLastActiveRequest) (*GetLastActiveResponse, error)
- func (UnimplementedControlPlaneServiceServer) PushRoute(context.Context, *PushRouteRequest) (*PushRouteResponse, error)
- type UnsafeControlPlaneServiceServer
Constants ¶
const ( ControlPlaneService_PushRoute_FullMethodName = "/sandbox.ctrlplane.v1.ControlPlaneService/PushRoute" ControlPlaneService_EvictRoute_FullMethodName = "/sandbox.ctrlplane.v1.ControlPlaneService/EvictRoute" ControlPlaneService_GetLastActive_FullMethodName = "/sandbox.ctrlplane.v1.ControlPlaneService/GetLastActive" )
Variables ¶
var ControlPlaneService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "sandbox.ctrlplane.v1.ControlPlaneService", HandlerType: (*ControlPlaneServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PushRoute", Handler: _ControlPlaneService_PushRoute_Handler, }, { MethodName: "EvictRoute", Handler: _ControlPlaneService_EvictRoute_Handler, }, { MethodName: "GetLastActive", Handler: _ControlPlaneService_GetLastActive_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "sandbox/ctrlplane/v1/ctrlplane.proto", }
ControlPlaneService_ServiceDesc is the grpc.ServiceDesc for ControlPlaneService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_sandbox_ctrlplane_v1_ctrlplane_proto protoreflect.FileDescriptor
Functions ¶
func RegisterControlPlaneServiceServer ¶
func RegisterControlPlaneServiceServer(s grpc.ServiceRegistrar, srv ControlPlaneServiceServer)
Types ¶
type ControlPlaneServiceClient ¶
type ControlPlaneServiceClient interface {
// PushRoute registers a sandbox_id -> (namespace, pod_name) mapping in the
// ExtProc in-memory cache so router queries can bypass the informer's
// sandbox-id index. The mapping carries NO phase and NO PodIP: those are
// read live from the Pod informer on each request, so the cache never goes
// stale across Pod lifecycle transitions (Starting -> Running -> Stopping).
PushRoute(ctx context.Context, in *PushRouteRequest, opts ...grpc.CallOption) (*PushRouteResponse, error)
// EvictRoute removes a sandbox_id from the ExtProc cache. Called by the
// Controller when a Pod completes Stopping -> Idle, so subsequent router
// queries for the released sandbox_id fall through to "not found" instead
// of briefly hitting a stale cache entry.
EvictRoute(ctx context.Context, in *EvictRouteRequest, opts ...grpc.CallOption) (*EvictRouteResponse, error)
// GetLastActive returns the per-sandbox last-activity timestamps tracked
// by ExtProc. Used by the Controller's IdleTimeoutReconciler.
GetLastActive(ctx context.Context, in *GetLastActiveRequest, opts ...grpc.CallOption) (*GetLastActiveResponse, error)
}
ControlPlaneServiceClient is the client API for ControlPlaneService 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.
ControlPlaneService is the private RPC channel between the Controller and the ExtProc gateway. It is NOT exposed to end users; the server binds to an in-cluster port and authenticates callers with the shared admin key.
func NewControlPlaneServiceClient ¶
func NewControlPlaneServiceClient(cc grpc.ClientConnInterface) ControlPlaneServiceClient
type ControlPlaneServiceServer ¶
type ControlPlaneServiceServer interface {
// PushRoute registers a sandbox_id -> (namespace, pod_name) mapping in the
// ExtProc in-memory cache so router queries can bypass the informer's
// sandbox-id index. The mapping carries NO phase and NO PodIP: those are
// read live from the Pod informer on each request, so the cache never goes
// stale across Pod lifecycle transitions (Starting -> Running -> Stopping).
PushRoute(context.Context, *PushRouteRequest) (*PushRouteResponse, error)
// EvictRoute removes a sandbox_id from the ExtProc cache. Called by the
// Controller when a Pod completes Stopping -> Idle, so subsequent router
// queries for the released sandbox_id fall through to "not found" instead
// of briefly hitting a stale cache entry.
EvictRoute(context.Context, *EvictRouteRequest) (*EvictRouteResponse, error)
// GetLastActive returns the per-sandbox last-activity timestamps tracked
// by ExtProc. Used by the Controller's IdleTimeoutReconciler.
GetLastActive(context.Context, *GetLastActiveRequest) (*GetLastActiveResponse, error)
// contains filtered or unexported methods
}
ControlPlaneServiceServer is the server API for ControlPlaneService service. All implementations must embed UnimplementedControlPlaneServiceServer for forward compatibility.
ControlPlaneService is the private RPC channel between the Controller and the ExtProc gateway. It is NOT exposed to end users; the server binds to an in-cluster port and authenticates callers with the shared admin key.
type EvictRouteRequest ¶
type EvictRouteRequest struct {
SandboxId string `protobuf:"bytes,1,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
// contains filtered or unexported fields
}
func (*EvictRouteRequest) Descriptor
deprecated
func (*EvictRouteRequest) Descriptor() ([]byte, []int)
Deprecated: Use EvictRouteRequest.ProtoReflect.Descriptor instead.
func (*EvictRouteRequest) GetSandboxId ¶
func (x *EvictRouteRequest) GetSandboxId() string
func (*EvictRouteRequest) ProtoMessage ¶
func (*EvictRouteRequest) ProtoMessage()
func (*EvictRouteRequest) ProtoReflect ¶
func (x *EvictRouteRequest) ProtoReflect() protoreflect.Message
func (*EvictRouteRequest) Reset ¶
func (x *EvictRouteRequest) Reset()
func (*EvictRouteRequest) String ¶
func (x *EvictRouteRequest) String() string
type EvictRouteResponse ¶
type EvictRouteResponse struct {
// contains filtered or unexported fields
}
func (*EvictRouteResponse) Descriptor
deprecated
func (*EvictRouteResponse) Descriptor() ([]byte, []int)
Deprecated: Use EvictRouteResponse.ProtoReflect.Descriptor instead.
func (*EvictRouteResponse) ProtoMessage ¶
func (*EvictRouteResponse) ProtoMessage()
func (*EvictRouteResponse) ProtoReflect ¶
func (x *EvictRouteResponse) ProtoReflect() protoreflect.Message
func (*EvictRouteResponse) Reset ¶
func (x *EvictRouteResponse) Reset()
func (*EvictRouteResponse) String ¶
func (x *EvictRouteResponse) String() string
type GetLastActiveRequest ¶
type GetLastActiveRequest struct {
// contains filtered or unexported fields
}
func (*GetLastActiveRequest) Descriptor
deprecated
func (*GetLastActiveRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLastActiveRequest.ProtoReflect.Descriptor instead.
func (*GetLastActiveRequest) ProtoMessage ¶
func (*GetLastActiveRequest) ProtoMessage()
func (*GetLastActiveRequest) ProtoReflect ¶
func (x *GetLastActiveRequest) ProtoReflect() protoreflect.Message
func (*GetLastActiveRequest) Reset ¶
func (x *GetLastActiveRequest) Reset()
func (*GetLastActiveRequest) String ¶
func (x *GetLastActiveRequest) String() string
type GetLastActiveResponse ¶
type GetLastActiveResponse struct {
// sandbox_id -> RFC3339 timestamp
LastActive map[string]string `` /* 165-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetLastActiveResponse) Descriptor
deprecated
func (*GetLastActiveResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLastActiveResponse.ProtoReflect.Descriptor instead.
func (*GetLastActiveResponse) GetLastActive ¶
func (x *GetLastActiveResponse) GetLastActive() map[string]string
func (*GetLastActiveResponse) ProtoMessage ¶
func (*GetLastActiveResponse) ProtoMessage()
func (*GetLastActiveResponse) ProtoReflect ¶
func (x *GetLastActiveResponse) ProtoReflect() protoreflect.Message
func (*GetLastActiveResponse) Reset ¶
func (x *GetLastActiveResponse) Reset()
func (*GetLastActiveResponse) String ¶
func (x *GetLastActiveResponse) String() string
type PushRouteRequest ¶
type PushRouteRequest struct {
// Raw sandbox UUID (no cluster prefix).
SandboxId string `protobuf:"bytes,1,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
PodName string `protobuf:"bytes,3,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
// contains filtered or unexported fields
}
func (*PushRouteRequest) Descriptor
deprecated
func (*PushRouteRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushRouteRequest.ProtoReflect.Descriptor instead.
func (*PushRouteRequest) GetNamespace ¶
func (x *PushRouteRequest) GetNamespace() string
func (*PushRouteRequest) GetPodName ¶
func (x *PushRouteRequest) GetPodName() string
func (*PushRouteRequest) GetSandboxId ¶
func (x *PushRouteRequest) GetSandboxId() string
func (*PushRouteRequest) ProtoMessage ¶
func (*PushRouteRequest) ProtoMessage()
func (*PushRouteRequest) ProtoReflect ¶
func (x *PushRouteRequest) ProtoReflect() protoreflect.Message
func (*PushRouteRequest) Reset ¶
func (x *PushRouteRequest) Reset()
func (*PushRouteRequest) String ¶
func (x *PushRouteRequest) String() string
type PushRouteResponse ¶
type PushRouteResponse struct {
// contains filtered or unexported fields
}
func (*PushRouteResponse) Descriptor
deprecated
func (*PushRouteResponse) Descriptor() ([]byte, []int)
Deprecated: Use PushRouteResponse.ProtoReflect.Descriptor instead.
func (*PushRouteResponse) ProtoMessage ¶
func (*PushRouteResponse) ProtoMessage()
func (*PushRouteResponse) ProtoReflect ¶
func (x *PushRouteResponse) ProtoReflect() protoreflect.Message
func (*PushRouteResponse) Reset ¶
func (x *PushRouteResponse) Reset()
func (*PushRouteResponse) String ¶
func (x *PushRouteResponse) String() string
type UnimplementedControlPlaneServiceServer ¶
type UnimplementedControlPlaneServiceServer struct{}
UnimplementedControlPlaneServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedControlPlaneServiceServer) EvictRoute ¶
func (UnimplementedControlPlaneServiceServer) EvictRoute(context.Context, *EvictRouteRequest) (*EvictRouteResponse, error)
func (UnimplementedControlPlaneServiceServer) GetLastActive ¶
func (UnimplementedControlPlaneServiceServer) GetLastActive(context.Context, *GetLastActiveRequest) (*GetLastActiveResponse, error)
func (UnimplementedControlPlaneServiceServer) PushRoute ¶
func (UnimplementedControlPlaneServiceServer) PushRoute(context.Context, *PushRouteRequest) (*PushRouteResponse, error)
type UnsafeControlPlaneServiceServer ¶
type UnsafeControlPlaneServiceServer interface {
// contains filtered or unexported methods
}
UnsafeControlPlaneServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlPlaneServiceServer will result in compilation errors.