kubernetes

Documentation

Index

• type Datastore
  • func NewDatastore(thisClusterID string, stopCh <-chan struct{}) (*Datastore, error)
  • func (k *Datastore) GetCluster(clusterID string) (*types.SubmarinerCluster, error)
  • func (k *Datastore) GetClusters(colorCodes []string) ([]types.SubmarinerCluster, error)
  • func (k *Datastore) GetEndpoint(clusterID string, cableName string) (*types.SubmarinerEndpoint, error)
  • func (k *Datastore) GetEndpoints(clusterID string) ([]types.SubmarinerEndpoint, error)
  • func (k *Datastore) RemoveCluster(clusterID string) error
  • func (k *Datastore) RemoveEndpoint(clusterID, cableName string) error
  • func (k *Datastore) SetCluster(cluster *types.SubmarinerCluster) error
  • func (k *Datastore) SetEndpoint(endpoint *types.SubmarinerEndpoint) error
  • func (k *Datastore) WatchClusters(ctx context.Context, selfClusterID string, colorCodes []string, ...) error
  • func (k *Datastore) WatchEndpoints(ctx context.Context, selfClusterID string, colorCodes []string, ...) error

Types

type Datastore

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

func NewDatastore

func NewDatastore(thisClusterID string, stopCh <-chan struct{}) (*Datastore, error)

func (*Datastore) GetCluster

func (k *Datastore) GetCluster(clusterID string) (*types.SubmarinerCluster, error)

func (*Datastore) GetClusters

func (k *Datastore) GetClusters(colorCodes []string) ([]types.SubmarinerCluster, error)

func (*Datastore) GetEndpoint

func (k *Datastore) GetEndpoint(clusterID string, cableName string) (*types.SubmarinerEndpoint, error)

func (*Datastore) GetEndpoints

func (k *Datastore) GetEndpoints(clusterID string) ([]types.SubmarinerEndpoint, error)

func (*Datastore) RemoveCluster

func (k *Datastore) RemoveCluster(clusterID string) error

func (*Datastore) RemoveEndpoint

func (k *Datastore) RemoveEndpoint(clusterID, cableName string) error

func (*Datastore) SetCluster

func (k *Datastore) SetCluster(cluster *types.SubmarinerCluster) error

func (*Datastore) SetEndpoint

func (k *Datastore) SetEndpoint(endpoint *types.SubmarinerEndpoint) error

func (*Datastore) WatchClusters

func (k *Datastore) WatchClusters(ctx context.Context, selfClusterID string, colorCodes []string, onClusterChange func(cluster *types.SubmarinerCluster, deleted bool) error) error

func (*Datastore) WatchEndpoints

func (k *Datastore) WatchEndpoints(ctx context.Context, selfClusterID string, colorCodes []string, onEndpointChange func(endpoint *types.SubmarinerEndpoint, deleted bool) error) error