ctrlplanev1

package
v0.0.7 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
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)

View Source
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.

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) GetLastActive

func (UnimplementedControlPlaneServiceServer) PushRoute

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.

Jump to

Keyboard shortcuts

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