package executorinfo

import "k8s.io/kubernetes/contrib/mesos/pkg/scheduler/executorinfo"

Package executorinfo provides a lru-based executor info registry as well as some utility methods.

Index ¶

• func DecodeResources(r io.Reader) (rs []*mesosproto.Resource, err error)
• func EncodeResources(w io.Writer, rs []*mesosproto.Resource) error
• func NewID(info *mesosproto.ExecutorInfo) *mesosproto.ExecutorID
• type Cache
• func NewCache(maxEntries int) (*Cache, error)
• func (c *Cache) Add(hostname string, e *mesosproto.ExecutorInfo)
• func (c *Cache) Get(hostname string) (e *mesosproto.ExecutorInfo, ok bool)
• func (c *Cache) Remove(hostname string)
• func (c *Cache) RemoveOldest()
• type Registry
• func NewRegistry( lookupNode node.LookupFunc, prototype *mesosproto.ExecutorInfo, cache *Cache, ) (Registry, error)

Functions ¶

func DecodeResources ¶

func DecodeResources(r io.Reader) (rs []*mesosproto.Resource, err error)

DecodeResources decodes a resource slice from the given reader. The format is expected to be the same as in EncodeResources.

func EncodeResources ¶

func EncodeResources(w io.Writer, rs []*mesosproto.Resource) error

EncodeResources encodes the given resource slice to the given writer. The resource slice is encoded as a comma separated string of base64 encoded resource protobufs.

func NewID ¶

func NewID(info *mesosproto.ExecutorInfo) *mesosproto.ExecutorID

Types ¶

type Cache ¶

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

Cache is an LRU cache for executor info objects. It is not safe for concurrent use.

func NewCache ¶

func NewCache(maxEntries int) (*Cache, error)

NewCache creates a new cache. If maxEntries is zero, an error is being returned.

func (*Cache) Add ¶

func (c *Cache) Add(hostname string, e *mesosproto.ExecutorInfo)

Add adds an executor info associated with the given hostname to the cache.

func (*Cache) Get ¶

func (c *Cache) Get(hostname string) (e *mesosproto.ExecutorInfo, ok bool)

Get looks up a hostname's executor info from the cache.

func (*Cache) Remove ¶

func (c *Cache) Remove(hostname string)

Remove removes the provided hostname from the cache.

func (*Cache) RemoveOldest ¶

func (c *Cache) RemoveOldest()

RemoveOldest removes the oldest item from the cache.

type Registry ¶

type Registry interface {
	New(hostname string, resources []*mesosproto.Resource) *mesosproto.ExecutorInfo
	Get(hostname string) (*mesosproto.ExecutorInfo, error)
	Invalidate(hostname string)
}

Registry is the interface that provides methods for interacting with a registry of ExecutorInfo objects

Get looks up an ExecutorInfo object for the given hostname

New returns an ExecutorInfo object based on a given hostname and resources

Invalidate invalidates the given hostname from this registry. Note that a subsequent Get may recover the executor info.

func NewRegistry ¶

func NewRegistry(
	lookupNode node.LookupFunc,
	prototype *mesosproto.ExecutorInfo,
	cache *Cache,
) (Registry, error)

NewRegistry returns a new executorinfo registry. The given prototype is being used for properties other than resources.

Source Files ¶

codec.go doc.go id.go lru_cache.go registry.go