import "github.com/cilium/cilium/pkg/client"
client.go config.go endpoint.go identity.go ipam.go policy.go prefilter.go service.go
const (
AddressFamilyIPv6 = "ipv6"
AddressFamilyIPv4 = "ipv4"
)DefaultSockPath returns deafult UNIX domain socket path or path set using CILIUM_SOCK env variable
func FormatStatusResponse(w io.Writer, sr *models.StatusResponse, allAddresses, allControllers, allNodes, allRedirects bool)
FormatStatusResponse writes a StatusResponse as a string to the writer.
The parameters 'allAddresses', 'allControllers', 'allNodes', respectively, cause all details about that aspect of the status to be printed to the terminal. For each of these, if they are false then only a summary will be printed, with perhaps some detail if there are errors.
func FormatStatusResponseBrief(w io.Writer, sr *models.StatusResponse)
FormatStatusResponseBrief writes a one-line status to the writer. If everything ok, this is "ok", otherwise a message of the form "error in ..."
Hint tries to improve the error message displayed to the user.
NewClient creates a client for the given `host`. If host is nil then use SockPath provided by CILIUM_SOCK or the cilium default SockPath
NewDefaultClient creates a client with default parameters connecting to UNIX domain socket.
NewDefaultClientWithTimeout creates a client with default parameters connecting to UNIX domain socket and waits for cilium-agent availability.
func (c *Client) ConfigGet() (*models.DaemonConfiguration, error)
ConfigGet returns a daemon configuration.
func (c *Client) ConfigPatch(cfg models.DaemonConfigurationSpec) error
ConfigPatch modifies the daemon configuration.
func (c *Client) DeletePrefilter(spec *models.PrefilterSpec) error
DeletePrefilter deletes a list of CIDR prefixes
DeleteServiceID deletes a service by ID.
EndpointConfigGet returns endpoint configuration
EndpointConfigPatch modifies endpoint configuration
func (c *Client) EndpointCreate(ep *models.EndpointChangeRequest) error
EndpointCreate creates a new endpoint
EndpointDelete deletes endpoint
EndpointGet returns endpoint by ID
EndpointHealthGet returns endpoint healthz
EndpointLabelsGet returns endpoint label configuration
EndpointLabelsPut modifies endpoint label configuration add: List of labels to add and enable. If the label is an orchestration system label which has been disabled before, it will be removed from the disabled list and readded to the orchestration list. Otherwise it will be added to the custom label list.
delete: List of labels to delete. If the label is an orchestration system label, then it will be deleted from the orchestration list and added to the disabled list. Otherwise it will be removed from the custom list.
EndpointList returns a list of all endpoints
EndpointLogGet returns endpoint log
EndpointPatch modifies the endpoint
GetPrefilter returns a list of all CIDR prefixes
GetServiceID returns a service by ID.
GetServices returns a list of all services.
IPAMAllocate allocates an IP address out of address family specific pool.
IPAMAllocateIP tries to allocate a particular IP address.
IPAMReleaseIP releases a IP address back to the pool.
IdentityGet returns a security identity.
PatchPrefilter sets a list of CIDR prefixes
PolicyDelete deletes policy rules
PolicyGet returns policy rules
PolicyPut inserts the `policyJSON`
func (c *Client) PolicyResolveGet(traceSelector *models.TraceSelector) (*models.PolicyTraceResult, error)
PolicyResolveGet resolves policy for a Trace Selector with source and destination identity.
PutServiceID creates or updates a service. Returns true if service was created.
type ClientError struct {
// contains filtered or unexported fields
}ClientError is the error returned by all client functions which use Hint()
func (c ClientError) Error() string
Error returns the error message representing the error
func (c ClientError) Recoverable() bool
Recoverable returns true if the error is likely to be recoverable
Package client imports 26 packages (graph) and is imported by 17 packages. Updated 2019-04-14. Refresh now. Tools for package owners.