api

package
v1.18.5 Latest Latest
Warning

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

 Go to latest Published: Dec 17, 2025 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Cell = cell.Module(
	endpointAPIModuleID,
	"Provides Endpoint API",

	cell.Provide(newEndpointAPIHandler),

	cell.Provide(newEndpointAPIManager),

	cell.ProvidePrivate(newEndpointCreationManager),

	cell.ProvidePrivate(newDeletionQueue),

	cell.Invoke(unlockAfterAPIServer),

	cell.Provide(newFence),
)

Cell provides the Endpoint API.

Functions

This section is empty.

Types

type DeletionQueue 

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

DeletionQueue manages the processing of persisted CNI delete requests. This state is populated by CNI when the API is unreachable (agent restart), and is only processed *once* as a hive lifecycle job during startup.

func (*DeletionQueue) Wait added in v1.18.2 

func (dq *DeletionQueue) Wait(ctx context.Context) error

Wait until the DeletionQueue processing is complete or the context is cancelled.

type EndpointAPIManager 

type EndpointAPIManager interface {
	CreateEndpoint(ctx context.Context, epTemplate *models.EndpointChangeRequest) (*endpoint.Endpoint, int, error)
	DeleteEndpoint(id string) (int, error)
	DeleteEndpointByContainerID(containerID string) (nErrors int, err error)
	EndpointUpdate(id string, cfg *models.EndpointConfigurationSpec) error
	ModifyEndpointIdentityLabelsFromAPI(id string, add, del labels.Labels) (int, error)
}

type EndpointCreationManager 

type EndpointCreationManager interface {
	NewCreateRequest(ep *endpoint.Endpoint, cancel context.CancelFunc)
	EndCreateRequest(ep *endpoint.Endpoint) bool
	CancelCreateRequest(ep *endpoint.Endpoint)
}

type EndpointDeleteEndpointHandler 

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

func (*EndpointDeleteEndpointHandler) Handle 

func (h *EndpointDeleteEndpointHandler) Handle(params endpointapi.DeleteEndpointParams) middleware.Responder

type EndpointDeleteEndpointIDHandler 

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

func (*EndpointDeleteEndpointIDHandler) Handle 

func (h *EndpointDeleteEndpointIDHandler) Handle(params endpointapi.DeleteEndpointIDParams) middleware.Responder

type EndpointGetEndpointHandler 

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

func (*EndpointGetEndpointHandler) Handle 

func (h *EndpointGetEndpointHandler) Handle(params endpointapi.GetEndpointParams) middleware.Responder

type EndpointGetEndpointIDConfigHandler 

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

func (*EndpointGetEndpointIDConfigHandler) Handle 

func (h *EndpointGetEndpointIDConfigHandler) Handle(params endpointapi.GetEndpointIDConfigParams) middleware.Responder

type EndpointGetEndpointIDHandler 

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

func (*EndpointGetEndpointIDHandler) Handle 

func (h *EndpointGetEndpointIDHandler) Handle(params endpointapi.GetEndpointIDParams) middleware.Responder

type EndpointGetEndpointIDHealthzHandler 

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

func (*EndpointGetEndpointIDHealthzHandler) Handle 

func (h *EndpointGetEndpointIDHealthzHandler) Handle(params endpointapi.GetEndpointIDHealthzParams) middleware.Responder

type EndpointGetEndpointIDLabelsHandler 

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

func (*EndpointGetEndpointIDLabelsHandler) Handle 

func (h *EndpointGetEndpointIDLabelsHandler) Handle(params endpointapi.GetEndpointIDLabelsParams) middleware.Responder

type EndpointGetEndpointIDLogHandler 

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

func (*EndpointGetEndpointIDLogHandler) Handle 

func (h *EndpointGetEndpointIDLogHandler) Handle(params endpointapi.GetEndpointIDLogParams) middleware.Responder

type EndpointPatchEndpointIDConfigHandler 

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

func (*EndpointPatchEndpointIDConfigHandler) Handle 

func (h *EndpointPatchEndpointIDConfigHandler) Handle(params endpointapi.PatchEndpointIDConfigParams) middleware.Responder

type EndpointPatchEndpointIDHandler 

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

func (*EndpointPatchEndpointIDHandler) Handle 

func (h *EndpointPatchEndpointIDHandler) Handle(params endpointapi.PatchEndpointIDParams) middleware.Responder

type EndpointPatchEndpointIDLabelsHandler 

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

func (*EndpointPatchEndpointIDLabelsHandler) Handle 

func (h *EndpointPatchEndpointIDLabelsHandler) Handle(params endpointapi.PatchEndpointIDLabelsParams) middleware.Responder

type EndpointPutEndpointIDHandler 

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

func (*EndpointPutEndpointIDHandler) Handle 

func (h *EndpointPutEndpointIDHandler) Handle(params endpointapi.PutEndpointIDParams) (resp middleware.Responder)

type Fence added in v1.18.2 

type Fence hive.Fence

A new type around hive.Fence to give it a unique type that can be provided to Hive.

Source Files

View all Source files

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.