cluster_metadata_persist

Documentation

Index

• type AggregatedClusterMetadataStorage
  • func (c *AggregatedClusterMetadataStorage) ClearAndSet(metas []*protos.AggregatedClusterMetadata)
  • func (c *AggregatedClusterMetadataStorage) DeleteAggrMetadata(clusterName string) error
  • func (c *AggregatedClusterMetadataStorage) GetAggrMetadata(clusterName string) (*protos.AggregatedClusterMetadata, bool)
  • func (c *AggregatedClusterMetadataStorage) InitStorage()
  • func (c *AggregatedClusterMetadataStorage) ListAggrMetadata() []*protos.AggregatedClusterMetadata
  • func (c *AggregatedClusterMetadataStorage) LoadStorage() (bool, error)
  • func (c *AggregatedClusterMetadataStorage) SaveStorage() error
  • func (c *AggregatedClusterMetadataStorage) SetAggrMetadata(meta *protos.AggregatedClusterMetadata) error
• type ClusterMetadataStorage
  • func (c *ClusterMetadataStorage) ClearStorage()
  • func (c *ClusterMetadataStorage) DeleteMetadata(clusterName string) error
  • func (c *ClusterMetadataStorage) GetMetadata(clusterName string) (*protos.ClusterMetadata, bool)
  • func (c *ClusterMetadataStorage) ListMetadata() []*protos.ClusterMetadata
  • func (c *ClusterMetadataStorage) LoadStorage() (bool, error)
  • func (c *ClusterMetadataStorage) SaveStorage() error
  • func (c *ClusterMetadataStorage) SetMetadata(meta *protos.ClusterMetadata) error

Types

type AggregatedClusterMetadataStorage

type AggregatedClusterMetadataStorage struct {
	StoragePath string
	// contains filtered or unexported fields
}

func (*AggregatedClusterMetadataStorage) ClearAndSet

func (c *AggregatedClusterMetadataStorage) ClearAndSet(metas []*protos.AggregatedClusterMetadata)

func (*AggregatedClusterMetadataStorage) DeleteAggrMetadata

func (c *AggregatedClusterMetadataStorage) DeleteAggrMetadata(clusterName string) error

func (*AggregatedClusterMetadataStorage) GetAggrMetadata

func (c *AggregatedClusterMetadataStorage) GetAggrMetadata(clusterName string) (*protos.AggregatedClusterMetadata, bool)

func (*AggregatedClusterMetadataStorage) InitStorage

func (c *AggregatedClusterMetadataStorage) InitStorage()

func (*AggregatedClusterMetadataStorage) ListAggrMetadata

func (c *AggregatedClusterMetadataStorage) ListAggrMetadata() []*protos.AggregatedClusterMetadata

func (*AggregatedClusterMetadataStorage) LoadStorage

func (c *AggregatedClusterMetadataStorage) LoadStorage() (bool, error)

FirstLoad, Error

func (*AggregatedClusterMetadataStorage) SaveStorage

func (c *AggregatedClusterMetadataStorage) SaveStorage() error

func (*AggregatedClusterMetadataStorage) SetAggrMetadata

func (c *AggregatedClusterMetadataStorage) SetAggrMetadata(meta *protos.AggregatedClusterMetadata) error

type ClusterMetadataStorage

type ClusterMetadataStorage struct {
	StoragePath string
	// contains filtered or unexported fields
}

func (*ClusterMetadataStorage) ClearStorage

func (c *ClusterMetadataStorage) ClearStorage()

func (*ClusterMetadataStorage) DeleteMetadata

func (c *ClusterMetadataStorage) DeleteMetadata(clusterName string) error

func (*ClusterMetadataStorage) GetMetadata

func (c *ClusterMetadataStorage) GetMetadata(clusterName string) (*protos.ClusterMetadata, bool)

func (*ClusterMetadataStorage) ListMetadata

func (c *ClusterMetadataStorage) ListMetadata() []*protos.ClusterMetadata

func (*ClusterMetadataStorage) LoadStorage

func (c *ClusterMetadataStorage) LoadStorage() (bool, error)

FirstLoad, Error

func (*ClusterMetadataStorage) SaveStorage

func (c *ClusterMetadataStorage) SaveStorage() error

func (*ClusterMetadataStorage) SetMetadata

func (c *ClusterMetadataStorage) SetMetadata(meta *protos.ClusterMetadata) error