k8sconfigdb

package
v0.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 5, 2018 License: Apache-2.0 Imports: 15 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type K8sConfigDB 

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

K8sConfigDB implements DB interface using k8s configmap.

func NewK8sConfigDB 

func NewK8sConfigDB(namespace string) (*K8sConfigDB, error)

NewK8sConfigDB creates a K8sConfigDB instance.

func NewK8sConfigDBWithConfig 

func NewK8sConfigDBWithConfig(namespace string, config *rest.Config) (*K8sConfigDB, error)

NewK8sConfigDBWithConfig creates a K8sConfigDB instance.

func (*K8sConfigDB) CreateConfigFile 

func (s *K8sConfigDB) CreateConfigFile(ctx context.Context, cfg *common.ConfigFile) error

CreateConfigFile creates one config file in DB

func (*K8sConfigDB) CreateDevice 

func (s *K8sConfigDB) CreateDevice(ctx context.Context, dev *common.Device) error

CreateDevice creates a device.

func (*K8sConfigDB) CreateService 

func (s *K8sConfigDB) CreateService(ctx context.Context, svc *common.Service) error

CreateService creates a service.

func (*K8sConfigDB) CreateServiceAttr 

func (s *K8sConfigDB) CreateServiceAttr(ctx context.Context, attr *common.ServiceAttr) error

CreateServiceAttr creates a service attr.

func (*K8sConfigDB) CreateServiceMember 

func (s *K8sConfigDB) CreateServiceMember(ctx context.Context, member *common.ServiceMember) error

CreateServiceMember creates one EBS serviceMember in DB

func (*K8sConfigDB) CreateServiceStaticIP 

func (s *K8sConfigDB) CreateServiceStaticIP(ctx context.Context, serviceip *common.ServiceStaticIP) error

CreateServiceStaticIP creates one ServiceStaticIP in DB

func (*K8sConfigDB) CreateSystemTables 

func (s *K8sConfigDB) CreateSystemTables(ctx context.Context) error

CreateSystemTables is a non-op.

func (*K8sConfigDB) DeleteConfigFile 

func (s *K8sConfigDB) DeleteConfigFile(ctx context.Context, serviceUUID string, fileID string) error

DeleteConfigFile deletes the config file from DB

func (*K8sConfigDB) DeleteDevice 

func (s *K8sConfigDB) DeleteDevice(ctx context.Context, clusterName string, deviceName string) error

DeleteDevice deletes one device.

func (*K8sConfigDB) DeleteService 

func (s *K8sConfigDB) DeleteService(ctx context.Context, clusterName string, serviceName string) error

DeleteService deletes one service.

func (*K8sConfigDB) DeleteServiceAttr 

func (s *K8sConfigDB) DeleteServiceAttr(ctx context.Context, serviceUUID string) error

DeleteServiceAttr deletes one service attr.

func (*K8sConfigDB) DeleteServiceMember 

func (s *K8sConfigDB) DeleteServiceMember(ctx context.Context, serviceUUID string, memberIndex int64) error

DeleteServiceMember deletes the serviceMember from DB

func (*K8sConfigDB) DeleteServiceStaticIP 

func (s *K8sConfigDB) DeleteServiceStaticIP(ctx context.Context, staticIP string) error

DeleteServiceStaticIP deletes the service static ip from DB

func (*K8sConfigDB) DeleteSystemTables 

func (s *K8sConfigDB) DeleteSystemTables(ctx context.Context) error

DeleteSystemTables is a non-op. Assume all records are already deleted.

func (*K8sConfigDB) GetConfigFile 

func (s *K8sConfigDB) GetConfigFile(ctx context.Context, serviceUUID string, fileID string) (cfg *common.ConfigFile, err error)

GetConfigFile gets the config fileItem from DB

func (*K8sConfigDB) GetDevice 

func (s *K8sConfigDB) GetDevice(ctx context.Context, clusterName string, deviceName string) (dev *common.Device, err error)

GetDevice gets the device.

func (*K8sConfigDB) GetService 

func (s *K8sConfigDB) GetService(ctx context.Context, clusterName string, serviceName string) (svc *common.Service, err error)

GetService gets the service.

func (*K8sConfigDB) GetServiceAttr 

func (s *K8sConfigDB) GetServiceAttr(ctx context.Context, serviceUUID string) (attr *common.ServiceAttr, err error)

GetServiceAttr gets the service attr.

func (*K8sConfigDB) GetServiceMember 

func (s *K8sConfigDB) GetServiceMember(ctx context.Context, serviceUUID string, memberIndex int64) (member *common.ServiceMember, err error)

GetServiceMember gets the serviceMemberItem from DB

func (*K8sConfigDB) GetServiceStaticIP 

func (s *K8sConfigDB) GetServiceStaticIP(ctx context.Context, staticIP string) (serviceip *common.ServiceStaticIP, err error)

GetServiceStaticIP gets the ServiceStaticIP from DB

func (*K8sConfigDB) ListDevices 

func (s *K8sConfigDB) ListDevices(ctx context.Context, clusterName string) (devs []*common.Device, err error)

ListDevices lists all devices.

func (*K8sConfigDB) ListDevicesWithLimit 

func (s *K8sConfigDB) ListDevicesWithLimit(ctx context.Context, clusterName string, limit int64) (devs []*common.Device, err error)

ListDevicesWithLimit does pagination list.

func (*K8sConfigDB) ListServiceMembers 

func (s *K8sConfigDB) ListServiceMembers(ctx context.Context, serviceUUID string) (serviceMembers []*common.ServiceMember, err error)

ListServiceMembers lists all serviceMembers of the service

func (*K8sConfigDB) ListServiceMembersWithLimit 

func (s *K8sConfigDB) ListServiceMembersWithLimit(ctx context.Context, serviceUUID string, limit int64) (serviceMembers []*common.ServiceMember, err error)

ListServiceMembersWithLimit limits the returned db.ServiceMembers at one query. This is for testing the pagination list.

func (*K8sConfigDB) ListServices 

func (s *K8sConfigDB) ListServices(ctx context.Context, clusterName string) (svcs []*common.Service, err error)

ListServices lists all services.

func (*K8sConfigDB) ListServicesWithLimit 

func (s *K8sConfigDB) ListServicesWithLimit(ctx context.Context, clusterName string, limit int64) (svcs []*common.Service, err error)

ListServicesWithLimit does pagination list.

func (*K8sConfigDB) SystemTablesReady 

func (s *K8sConfigDB) SystemTablesReady(ctx context.Context) (tableStatus string, ready bool, err error)

SystemTablesReady is a non-op.

func (*K8sConfigDB) UpdateServiceAttr 

func (s *K8sConfigDB) UpdateServiceAttr(ctx context.Context, oldAttr *common.ServiceAttr, newAttr *common.ServiceAttr) error

UpdateServiceAttr updates the ServiceAttr in DB.

func (*K8sConfigDB) UpdateServiceMember 

func (s *K8sConfigDB) UpdateServiceMember(ctx context.Context, oldMember *common.ServiceMember, newMember *common.ServiceMember) error

UpdateServiceMember updates the ServiceMember in DB

func (*K8sConfigDB) UpdateServiceMemberVolume 

func (s *K8sConfigDB) UpdateServiceMemberVolume(ctx context.Context, member *common.ServiceMember, newVolID string, badVolID string) error

UpdateServiceMemberVolume updates the ServiceMember's volume in DB

func (*K8sConfigDB) UpdateServiceStaticIP 

func (s *K8sConfigDB) UpdateServiceStaticIP(ctx context.Context, oldIP *common.ServiceStaticIP, newIP *common.ServiceStaticIP) error

UpdateServiceStaticIP updates the ServiceStaticIP in DB

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.