storage

package
v1.29.0-alpha.75 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package storage xxx

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppHandler 

type AppHandler struct {
	ClusterID    string
	DoCheckDirty bool
	// contains filtered or unexported fields
}

AppHandler handle for Application

func (*AppHandler) Add 

func (handler *AppHandler) Add(data interface{}) error

Add add event

func (*AppHandler) CheckDirty 

func (handler *AppHandler) CheckDirty() error

CheckDirty clean remote dirty data

func (*AppHandler) Delete 

func (handler *AppHandler) Delete(data interface{}) error

Delete delete info

func (*AppHandler) FormatConv 

func (handler *AppHandler) FormatConv(app *schedtypes.Application) (*commtypes.BcsReplicaControllerStatus, error)

FormatConv convert format for status info

func (*AppHandler) GetType 

func (handler *AppHandler) GetType() string

GetType get handler type

func (*AppHandler) Update 

func (handler *AppHandler) Update(data interface{}) error

Update update in zookeeper

type CCListData 

type CCListData struct {
	Apps          []map[string]*schedtypes.Application `json:"application,omitempty"`
	TaskGroup     []map[string]*schedtypes.TaskGroup   `json:"taskgroup,omitempty"`
	ExportService []map[string]*lbtypes.ExportService  `json:"exportservice,omitempty"`
}

CCListData hold all data

type CCResponse 

type CCResponse struct {
	Result  bool   `json:"result"`
	Code    int    `json:"code"`
	Message string `json:"message,omitempty"`
	Data    string `json:"data,omitempty"`
}

CCResponse response struct from CC

type CCStorage 

type CCStorage struct {
	ClusterID string //
	// contains filtered or unexported fields
}

CCStorage writing data to CC

func (*CCStorage) CreateDCNode 

func (cc *CCStorage) CreateDCNode(node string, value interface{}, action string) error

CreateDCNode bcs-storage create operation

func (*CCStorage) DeleteDCNode 

func (cc *CCStorage) DeleteDCNode(node, action string) error

DeleteDCNode storage delete operation

func (*CCStorage) DeleteDCNodes 

func (cc *CCStorage) DeleteDCNodes(node string, value interface{}, action string) error

DeleteDCNodes bcs-storage delete operation

func (*CCStorage) GetDCAddress 

func (cc *CCStorage) GetDCAddress() string

GetDCAddress get bcs-storage address

func (*CCStorage) Run 

func (cc *CCStorage) Run(ctx context.Context) error

Run start point for StorageWriter

func (*CCStorage) SetDCAddress 

func (cc *CCStorage) SetDCAddress(address []string)

SetDCAddress had better add rwlock

func (*CCStorage) Sync 

func (cc *CCStorage) Sync(data *types.BcsSyncData) error

Sync sync data to storage queue

func (*CCStorage) SyncTimeout 

func (cc *CCStorage) SyncTimeout(data *types.BcsSyncData, timeout time.Duration) error

SyncTimeout send data to CCStorage queue with timeout

func (*CCStorage) Worker 

func (cc *CCStorage) Worker()

Worker storage writer worker goroutine

type ChannelProxy 

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

ChannelProxy Proxy offer particular channel for handling data in private goroutine

func (*ChannelProxy) Handle 

func (proxy *ChannelProxy) Handle(data *types.BcsSyncData)

Handle for handling data action like Add, Delete, Update

func (*ChannelProxy) HandleWithTimeOut 

func (proxy *ChannelProxy) HandleWithTimeOut(data *types.BcsSyncData, timeout time.Duration)

HandleWithTimeOut send data to proxy.dataQueue with timeout

func (*ChannelProxy) Run 

func (proxy *ChannelProxy) Run(ctx context.Context)

Run ChannelProxy running a dataType handler channel, stop Run() By external context

type ConfigMapHandler 

type ConfigMapHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

ConfigMapHandler handler for configmap synchronize to bcs-storage

func (*ConfigMapHandler) Add 

func (handler *ConfigMapHandler) Add(data interface{}) error

Add add new configmap to bcs-storage

func (*ConfigMapHandler) CheckDirty 

func (handler *ConfigMapHandler) CheckDirty() error

CheckDirty clean remote storage dirty data

func (*ConfigMapHandler) Delete 

func (handler *ConfigMapHandler) Delete(data interface{}) error

Delete delete configmap in storage

func (*ConfigMapHandler) GetType 

func (handler *ConfigMapHandler) GetType() string

GetType get datatype

func (*ConfigMapHandler) Update 

func (handler *ConfigMapHandler) Update(data interface{}) error

Update update configmap in storage

type DataOperator 

type DataOperator interface {
	CreateDCNode(node string, value interface{}, action string) error
	DeleteDCNode(node, action string) error
	DeleteDCNodes(node string, value interface{}, action string) error
}

DataOperator is Interface to Operator data for storage

type DeploymentHandler 

type DeploymentHandler struct {
	ClusterID    string
	DoCheckDirty bool
	// contains filtered or unexported fields
}

DeploymentHandler event handler for Deployment

func (*DeploymentHandler) Add 

func (handler *DeploymentHandler) Add(data interface{}) error

Add data add event implementation

func (*DeploymentHandler) CheckDirty 

func (handler *DeploymentHandler) CheckDirty() error

CheckDirty clean dirty data in remote bcs-storage

func (*DeploymentHandler) Delete 

func (handler *DeploymentHandler) Delete(data interface{}) error

Delete data Delete event implementation

func (*DeploymentHandler) GetType 

func (handler *DeploymentHandler) GetType() string

GetType implementation

func (*DeploymentHandler) Update 

func (handler *DeploymentHandler) Update(data interface{}) error

Update handle data update event implementation

type EndpointHandler 

type EndpointHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

EndpointHandler handler for Endpoint event

func (*EndpointHandler) Add 

func (handler *EndpointHandler) Add(data interface{}) error

Add add event storage implementation

func (*EndpointHandler) CheckDirty 

func (handler *EndpointHandler) CheckDirty() error

CheckDirty clean dirty data in remote bcs-storage

func (*EndpointHandler) Delete 

func (handler *EndpointHandler) Delete(data interface{}) error

Delete delete event implementation

func (*EndpointHandler) GetType 

func (handler *EndpointHandler) GetType() string

GetType implementation

func (*EndpointHandler) Update 

func (handler *EndpointHandler) Update(data interface{}) error

Update update event implementation

type ExpServiceHandler 

type ExpServiceHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

ExpServiceHandler handle for taskgroup

func (*ExpServiceHandler) Add 

func (handler *ExpServiceHandler) Add(data interface{}) error

Add handler to add

func (*ExpServiceHandler) CheckDirty 

func (handler *ExpServiceHandler) CheckDirty() error

CheckDirty clean dirty data implementation

func (*ExpServiceHandler) Delete 

func (handler *ExpServiceHandler) Delete(data interface{}) error

Delete delete info

func (*ExpServiceHandler) GetType 

func (handler *ExpServiceHandler) GetType() string

GetType implementation

func (*ExpServiceHandler) Update 

func (handler *ExpServiceHandler) Update(data interface{}) error

Update update in zookeeper

type InfoHandler 

type InfoHandler interface {
	// Add xxx
	// List(key interface{}) map[string]interface{}
	Add(data interface{}) error
	Update(data interface{}) error
	Delete(data interface{}) error
	GetType() string

	CheckDirty() error
}

InfoHandler is interface for handle detail data

type NetServiceHandler 

type NetServiceHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

NetServiceHandler handle netservice resources for storage.

func (*NetServiceHandler) Add 

func (h *NetServiceHandler) Add(data interface{}) error

Add handle add event for netservice resources.

func (*NetServiceHandler) CheckDirty 

func (h *NetServiceHandler) CheckDirty() error

CheckDirty cleans dirty data in remote bcs-storage.

func (*NetServiceHandler) Delete 

func (h *NetServiceHandler) Delete(data interface{}) error

Delete handle delete event for netservice resources.

func (*NetServiceHandler) GetType 

func (h *NetServiceHandler) GetType() string

GetType returns data type.

func (*NetServiceHandler) Update 

func (h *NetServiceHandler) Update(data interface{}) error

Update xxx Delete handle delete event for netservice resources.

type SecretHandler 

type SecretHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

SecretHandler handler secret event

func (*SecretHandler) Add 

func (handler *SecretHandler) Add(data interface{}) error

Add event implementation

func (*SecretHandler) CheckDirty 

func (handler *SecretHandler) CheckDirty() error

CheckDirty implementation

func (*SecretHandler) Delete 

func (handler *SecretHandler) Delete(data interface{}) error

Delete event implementation

func (*SecretHandler) GetType 

func (handler *SecretHandler) GetType() string

GetType implementation

func (*SecretHandler) Update 

func (handler *SecretHandler) Update(data interface{}) error

Update event implementation

type ServiceHandler 

type ServiceHandler struct {
	ClusterID string
	// contains filtered or unexported fields
}

ServiceHandler service event handler

func (*ServiceHandler) Add 

func (handler *ServiceHandler) Add(data interface{}) error

Add event implementation

func (*ServiceHandler) CheckDirty 

func (handler *ServiceHandler) CheckDirty() error

CheckDirty implementation

func (*ServiceHandler) Delete 

func (handler *ServiceHandler) Delete(data interface{}) error

Delete event implementation

func (*ServiceHandler) GetType 

func (handler *ServiceHandler) GetType() string

GetType implementation

func (*ServiceHandler) Update 

func (handler *ServiceHandler) Update(data interface{}) error

Update event implementation

type Storage 

type Storage interface {
	// DataLister                          //embed DataLister interface for requesting data from Storage
	DataOperator                        // CREATE, DELETE, LIST operation for storage
	Sync(data *types.BcsSyncData) error // sync data
	SyncTimeout(data *types.BcsSyncData, timeout time.Duration) error
	Run(cxt context.Context) error // start point for StorageWriter
	Worker()                       // storage writer worker goroutine
	SetDCAddress(address []string) // set storage server address
	GetDCAddress() string
}

Storage is writer interface for all database such as zookeeper, Mysql, redis, CC and etc.

func NewCCStorage 

func NewCCStorage(config *types.CmdConfig) (Storage, error)

NewCCStorage create storage for cc

type TaskGroupHandler 

type TaskGroupHandler struct {
	ClusterID string

	DoCheckDirty bool
	// contains filtered or unexported fields
}

TaskGroupHandler handle for taskgroup

func (*TaskGroupHandler) Add 

func (handler *TaskGroupHandler) Add(data interface{}) error

Add handler to add

func (*TaskGroupHandler) CheckDirty 

func (handler *TaskGroupHandler) CheckDirty() error

CheckDirty implementation

func (*TaskGroupHandler) Delete 

func (handler *TaskGroupHandler) Delete(data interface{}) error

Delete delete info

func (*TaskGroupHandler) FormatConv 

func (handler *TaskGroupHandler) FormatConv(taskgroup *schedtypes.TaskGroup) (*commtypes.BcsPodStatus, error)

FormatConv convert taskgroup to pod status for storage

func (*TaskGroupHandler) GetType 

func (handler *TaskGroupHandler) GetType() string

GetType implementation

func (*TaskGroupHandler) Update 

func (handler *TaskGroupHandler) Update(data interface{}) error

Update update in zookeeper

Source Files

View all Source files

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.