fake

Documentation

Index

• type Datastore
  • func New() *Datastore
  • func (d *Datastore) GetCluster(clusterID string) (*types.SubmarinerCluster, error)
  • func (d *Datastore) GetClusters(colorCodes []string) ([]types.SubmarinerCluster, error)
  • func (d *Datastore) GetEndpoint(clusterID, cableName string) (*types.SubmarinerEndpoint, error)
  • func (d *Datastore) GetEndpoints(clusterID string) ([]types.SubmarinerEndpoint, error)
  • func (d *Datastore) RemoveCluster(clusterID string) error
  • func (d *Datastore) RemoveEndpoint(clusterID, cableName string) error
  • func (d *Datastore) SetCluster(cluster *types.SubmarinerCluster) error
  • func (d *Datastore) SetEndpoint(endpoint *types.SubmarinerEndpoint) error
  • func (d *Datastore) SetupErrOnFirstRemoveEndpoint(err error)
  • func (d *Datastore) SetupErrOnFirstSetCluster() error
  • func (d *Datastore) SetupErrOnFirstSetEndpoint(err error)
  • func (d *Datastore) SetupGetEndpoints(clusterID string, err error, endpoints ...types.SubmarinerEndpoint)
  • func (d *Datastore) VerifyNoSetCluster()
  • func (d *Datastore) VerifyNoSetEndpoint()
  • func (d *Datastore) VerifyRemoveEndpoint(clusterID, cableName string)
  • func (d *Datastore) VerifySetCluster(expected *types.SubmarinerCluster)
  • func (d *Datastore) VerifySetEndpoint(expected *types.SubmarinerEndpoint)
  • func (d *Datastore) VerifyWatchClusters() datastore.OnClusterChange
  • func (d *Datastore) VerifyWatchEndpoints() datastore.OnEndpointChange
  • func (d *Datastore) WatchClusters(ctx context.Context, selfClusterID string, icolorCodes []string, ...) error
  • func (d *Datastore) WatchEndpoints(ctx context.Context, selfClusterID string, colorCodes []string, ...) error

Types

type Datastore

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

func New

func New() *Datastore

func (*Datastore) GetCluster

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

func (*Datastore) GetClusters

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

func (*Datastore) GetEndpoint

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

func (*Datastore) GetEndpoints

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

func (*Datastore) RemoveCluster

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

func (*Datastore) RemoveEndpoint

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

func (*Datastore) SetCluster

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

func (*Datastore) SetEndpoint

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

func (*Datastore) SetupErrOnFirstRemoveEndpoint

func (d *Datastore) SetupErrOnFirstRemoveEndpoint(err error)

func (*Datastore) SetupErrOnFirstSetCluster

func (d *Datastore) SetupErrOnFirstSetCluster() error

func (*Datastore) SetupErrOnFirstSetEndpoint

func (d *Datastore) SetupErrOnFirstSetEndpoint(err error)

func (*Datastore) SetupGetEndpoints

func (d *Datastore) SetupGetEndpoints(clusterID string, err error, endpoints ...types.SubmarinerEndpoint)

func (*Datastore) VerifyNoSetCluster

func (d *Datastore) VerifyNoSetCluster()

func (*Datastore) VerifyNoSetEndpoint

func (d *Datastore) VerifyNoSetEndpoint()

func (*Datastore) VerifyRemoveEndpoint

func (d *Datastore) VerifyRemoveEndpoint(clusterID, cableName string)

func (*Datastore) VerifySetCluster

func (d *Datastore) VerifySetCluster(expected *types.SubmarinerCluster)

func (*Datastore) VerifySetEndpoint

func (d *Datastore) VerifySetEndpoint(expected *types.SubmarinerEndpoint)

func (*Datastore) VerifyWatchClusters

func (d *Datastore) VerifyWatchClusters() datastore.OnClusterChange

func (*Datastore) VerifyWatchEndpoints

func (d *Datastore) VerifyWatchEndpoints() datastore.OnEndpointChange

func (*Datastore) WatchClusters

func (d *Datastore) WatchClusters(ctx context.Context, selfClusterID string, icolorCodes []string,
	onClusterChange datastore.OnClusterChange) error

func (*Datastore) WatchEndpoints

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