configs

package
v0.0.0-...-df8b58b Latest Latest
Warning

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

Go to latest
Published: Aug 11, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// ConfigStatusOk config status ok
	ConfigStatusOk = 0
	// ConfigStatusDeleted config status deleted
	ConfigStatusDeleted = -1
)

Variables

This section is empty.

Functions

func GetDBConfigCount

func GetDBConfigCount(db *sql.DB, tag, prefix string) (int64, error)

GetDBConfigCount get db config count

Types

type AppConfigState

type AppConfigState struct {
	ID         int64     `json:"id"`
	AppID      int64     `json:"app_id"`
	AppNode    string    `json:"app_node"`
	ConfigName string    `json:"config_name"`
	Version    int64     `json:"version"`
	CreateTime time.Time `json:"create_time"`
	ModifyTime time.Time `json:"modify_time"`
}

AppConfigState app config state table

type Config

type Config struct {
	KeyPrefix string            `default:"/configs" yaml:"key_prefix"`
	Etcd      *utils.ETCDConfig `default:"-"`
}

Config module config

type ConfigCtrl

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

ConfigCtrl config ctrl

func NewConfigCtrl

func NewConfigCtrl(config *Config, db *sql.DB, etcdClient *clientv3.Client) *ConfigCtrl

NewConfigCtrl new config ctrl

func (*ConfigCtrl) Delete

func (ctrl *ConfigCtrl) Delete(ctx context.Context, name string) error

Delete delete config

func (*ConfigCtrl) Get

func (ctrl *ConfigCtrl) Get(ctx context.Context, appID int64, node, name string) (*ConfigItem, int64, error)

Get get config

func (*ConfigCtrl) ListDBConfigs

func (ctrl *ConfigCtrl) ListDBConfigs(ctx context.Context,
	tag, prefix string, skip, limit int) (int64, []ConfigInfo, error)

ListDBConfigs list db configs

func (*ConfigCtrl) Put

func (ctrl *ConfigCtrl) Put(ctx context.Context, tag, name string, appID int64, remark, value string, version int64) (int64, error)

Put put config

func (*ConfigCtrl) Range

func (ctrl *ConfigCtrl) Range(ctx context.Context, from, end string, sortOption *clientv3.SortOption) ([]ConfigItem, bool, error)

Range range

func (*ConfigCtrl) Watch

func (ctrl *ConfigCtrl) Watch(ctx context.Context, appID int64, node, name string, revision int64) (*ConfigItem, int64, error)

Watch watch config

type ConfigHistory

type ConfigHistory struct {
	ID         int64     `json:"id"`
	Tag        string    `json:"tag"`
	Name       string    `json:"name"`
	AppID      int64     `json:"modified_by"`
	Remark     string    `json:"remark"`
	Value      string    `json:"value"`
	CreateTime time.Time `json:"create_time"`
}

ConfigHistory config history

type ConfigInfo

type ConfigInfo struct {
	Tag        *string   `json:"tag"`
	Name       string    `json:"name"`
	ModifyTime time.Time `json:"modify_time"`
}

ConfigInfo config info

func ListDBConfigs

func ListDBConfigs(db *sql.DB, tag, prefix string, skip, limit int) ([]ConfigInfo, error)

ListDBConfigs list db configs

type ConfigItem

type ConfigItem struct {
	Name    string `json:"name"`
	Value   string `json:"value"`
	Version int64  `json:"version"`
}

ConfigItem config item

type DBConfigItem

type DBConfigItem struct {
	ID         int64     `json:"id"`
	Status     int       `json:"-"`
	Tag        string    `json:"tag"`
	Name       string    `json:"name"`
	Value      string    `json:"value"`
	CreateTime time.Time `json:"create_time"`
	ModifyTime time.Time `json:"modify_time"`
}

DBConfigItem db config table

func GetDBConfig

func GetDBConfig(db *sql.DB, name string) (*DBConfigItem, error)

GetDBConfig get db config

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL