kubernetes

Documentation

Index

• func NewDatastore(thisClusterID string, stopCh <-chan struct{}) (datastore.Datastore, error)
• type Datastore
  • func (k *Datastore) GetEndpoints(clusterID string) ([]types.SubmarinerEndpoint, 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

Functions

func NewDatastore

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

Types

type Datastore

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

func (*Datastore) GetEndpoints

func (k *Datastore) GetEndpoints(clusterID string) ([]types.SubmarinerEndpoint, 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 datastore.OnClusterChange) error

func (*Datastore) WatchEndpoints

func (k *Datastore) WatchEndpoints(ctx context.Context, selfClusterID string, colorCodes []string, onEndpointChange datastore.OnEndpointChange) error