pkg

type AppConfigStore interface {
	GetAppConfigs(key string) (AppConfigsJSONStr, int64, error)
	PutAppConfigs(key string, value AppConfigsJSONStr) error
	WatchAppConfigs(key string, rev int64, ctx context.Context) (chan *ConfigEvent, error)
	WatchAppConfigsWithPrefix(ctx context.Context) (chan *ConfigEvent, error)
}

type AppConfigs map[string]*Configs

type AppConfigsJSONStr string

type AppConfigsMap struct {
	AppConfigs
	// contains filtered or unexported fields
}

type Appkey string

type Client struct {
	Id      ClientId
	MsgChan chan interface{}
}

type ClientChanMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ClientId int32

type Config struct {
	Schema     string `json:"schema"`
	Config     string `json:"config"`
	CreateTime int64  `json:"create_time"`
	UpdateTime int64  `json:"update_time"`
}

type ConfigEvent struct {
	Key       Appkey
	Value     AppConfigsJSONStr
	EventType EventType
}

type Configs struct {
	Configs    ConfigsMap        `json:"configs"`
	Desc       string            `json:"desc"`
	CreateTime int64             `json:"create_time"`
	UpdateTime int64             `json:"update_time"`
	ABFilters  map[string]string `json:"ABFilters"`
}

type ConfigsMap struct {
	Entry map[string]*Config `json:"entry"`
	// contains filtered or unexported fields
}

type EventType int

type MConfig struct {
	Namspace        *string
	RegistryAddress *string
	RegistryType    *string
	StoreAddress    *string
	StoreType       *string
	ServerIp        *string
	ServerPort      *int
}

type MConfigCLI struct {
}

type MConfigSDK struct {
}

type MconfigCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type StorePlugin struct {
	Name string
	Init func(address string) (AppConfigStore, error)
}