import "github.com/cilium/cilium/pkg/service"
config.go const.go id.go id_kvstore.go id_local.go logfields.go store.go zz_generated.deepcopy.go
const (
// ServiceIDKeyPath is the base path where the IDs are stored in the kvstore.
ServiceIDKeyPath = common.OperationalPath + "/ServicesV2/IDs"
// LastFreeServiceIDKeyPath is the path where the Last free UUID is stored in the kvstore.
LastFreeServiceIDKeyPath = common.OperationalPath + "/ServicesV2/LastUUID"
// FirstFreeServiceID is the first ID for which the services should be assigned.
FirstFreeServiceID = uint32(1)
// MaxSetOfServiceID is maximum number of set of service IDs that can be stored
// in the kvstore or the local ID allocator.
MaxSetOfServiceID = uint32(0xFFFF)
// FirstFreeBackendID is the first ID for which the backend should be assigned.
FirstFreeBackendID = uint32(1)
// MaxSetOfBackendID is maximum number of set of backendIDs IDs that can be
// stored in the local ID allocator.
MaxSetOfBackendID = uint32(0xFFFFFFFF)
)var (
// ServiceStorePrefix is the kvstore prefix of the shared store
//
// WARNING - STABLE API: Changing the structure or values of this will
// break backwards compatibility
ServiceStorePrefix = path.Join(kvstore.BaseKeyPrefix, "state", "services", "v1")
)func AcquireBackendID(l3n4Addr loadbalancer.L3n4Addr) (loadbalancer.BackendID, error)
AcquireBackendID acquires a new local ID for the given backend.
func AcquireID(l3n4Addr loadbalancer.L3n4Addr, baseID uint32) (*loadbalancer.L3n4AddrID, error)
AcquireID acquires a service ID
func DeleteBackendID(id loadbalancer.BackendID)
DeleteBackendID releases the given backend ID. TODO(brb) maybe provide l3n4Addr as an arg for the extra safety.
DeleteID deletes the L3n4AddrID belonging to the given id from the kvstore.
EnableGlobalServiceID enables or disables the use of global service IDs. When global service IDs are enabled, a kvstore interaction is used to allocate service IDs in the scope of the entire kvstore domain to enable transfer of service ID context between nodes.
func GetID(id uint32) (*loadbalancer.L3n4AddrID, error)
GetID returns the L3n4AddrID that belongs to the given id.
func LookupBackendID(l3n4Addr loadbalancer.L3n4Addr) (loadbalancer.BackendID, error)
LookupBackendID looks up already allocated backend ID for the given backend addr. If such cannot be found, returns an error.
func RestoreBackendID(l3n4Addr loadbalancer.L3n4Addr, id loadbalancer.BackendID) error
RestoreBackendID tries to restore the given local ID for the given backend.
If ID cannot be restored (ID already taken), returns an error.
func RestoreID(l3n4Addr loadbalancer.L3n4Addr, baseID uint32) (*loadbalancer.L3n4AddrID, error)
RestoreID restores previously used service ID
type ClusterService struct {
// Cluster is the cluster name the service is configured in
Cluster string `json:"cluster"`
// Namespace is the cluster namespace the service is configured in
Namespace string `json:"namespace"`
// Name is the name of the service. It must be unique within the
// namespace of the cluster
Name string `json:"name"`
// Frontends is a map indexed by the frontend IP address
Frontends map[string]PortConfiguration `json:"frontends"`
// Backends is is map indexed by the backend IP address
Backends map[string]PortConfiguration `json:"backends"`
// Labels are the labels of the service
Labels map[string]string `json:"labels"`
// Selector is the label selector used to select backends
Selector map[string]string `json:"selector"`
}ClusterService is the definition of a service in a cluster
WARNING - STABLE API: Any change to this structure must be done in a backwards compatible way.
+k8s:deepcopy-gen=true
func NewClusterService(name, namespace string) ClusterService
NewClusterService returns a new cluster service definition
func (in *ClusterService) DeepCopy() *ClusterService
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterService.
func (in *ClusterService) DeepCopyInto(out *ClusterService)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (s *ClusterService) DeepKeyCopy() store.LocalKey
DeepKeyCopy creates a deep copy of the LocalKey
func (s *ClusterService) GetKeyName() string
GetKeyName returns the kvstore key to be used for the global service
func (s *ClusterService) Marshal() ([]byte, error)
Marshal returns the global service object as JSON byte slice
func (s *ClusterService) NamespaceServiceName() string
NamespaceServiceName returns the namespace and service name
func (s *ClusterService) String() string
func (s *ClusterService) Unmarshal(data []byte) error
Unmarshal parses the JSON byte slice and updates the global service receiver
type IDAllocator struct {
// Protects entitiesID, entities, nextID and maxID
lock.RWMutex
// contains filtered or unexported fields
}IDAllocator contains an internal state of the ID allocator.
func NewIDAllocator(nextID uint32, maxID uint32) *IDAllocator
NewIDAllocator creates a new ID allocator instance.
type PortConfiguration map[string]*loadbalancer.L4Addr
PortConfiguration is the L4 port configuration of a frontend or backend. The map is indexed by the name of the port and the value constains the L4 port and protocol.
func (p PortConfiguration) DeepEquals(o PortConfiguration) bool
DeepEquals returns true if both PortConfigurations are identical
Package service imports 12 packages (graph) and is imported by 8 packages. Updated 2019-04-27. Refresh now. Tools for package owners.