Versions in this module Expand all Collapse all v1 v1.0.0 Oct 12, 2021 Changes in this version + const Action_ANY + const Action_DELETE + const Action_PUBLISH + const Action_READ + const Action_WRITE + const Domain_ALL + const Domain_APP + const Domain_CLUSTER + const Object_ACL + const Object_ALL + const Object_APP + const Object_CLUSTER + const Object_ELEMENT + const Object_ENV + const Object_USER + const Role_ADMIN + const Role_APPOWNER + const Role_DEVELOPER + const Role_SUPERADMIN + const Role_VISITOR + var AppMetadata_Status_name = map[int32]string + var AppMetadata_Status_value = map[string]int32 + var ChangeOp_name = map[int32]string + var ChangeOp_value = map[string]int32 + var ContentType_name = map[int32]string + var ContentType_value = map[string]int32 + var ElementOperation_Op_name = map[int32]string + var ElementOperation_Op_value = map[string]int32 + var User_Status_name = map[int32]string + var User_Status_value = map[string]int32 + func MarshalProto(v proto.Message) ([]byte, error) + func UnmarshalProto(data []byte, v proto.Message) error + type AdmAggregate interface + func NewAdmAggregate(endpoints []string) (AdmAggregate, error) + type AgentAggregate interface + func NewAgentAggregate(endpoints []string) (AgentAggregate, error) + type AgentHybrid interface + GetAgents func(ctx context.Context, seek string, limit int) (*getAgentsResult, error) + Register func(ctx context.Context, ins *AgentInstance, ttl int32) error + Renew func(ctx context.Context, ins *AgentInstance, ttl int32) error + Unregister func(ctx context.Context, agentId string) error + Watch func(ctx context.Context, ch chan<- *AgentInstanceChange) error + type AgentInstance struct + Addr string + AgentId string + Annotations map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AgentInstance) Descriptor() ([]byte, []int) + func (*AgentInstance) ProtoMessage() + func (m *AgentInstance) GetAddr() string + func (m *AgentInstance) GetAgentId() string + func (m *AgentInstance) GetAnnotations() map[string]string + func (m *AgentInstance) Reset() + func (m *AgentInstance) String() string + func (m *AgentInstance) Validate() error + func (m *AgentInstance) XXX_DiscardUnknown() + func (m *AgentInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AgentInstance) XXX_Merge(src proto.Message) + func (m *AgentInstance) XXX_Size() int + func (m *AgentInstance) XXX_Unmarshal(b []byte) error + type AgentInstanceChange struct + Ins *AgentInstance + Op ChangeOp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AgentInstanceChange) Descriptor() ([]byte, []int) + func (*AgentInstanceChange) ProtoMessage() + func (m *AgentInstanceChange) GetIns() *AgentInstance + func (m *AgentInstanceChange) GetOp() ChangeOp + func (m *AgentInstanceChange) Reset() + func (m *AgentInstanceChange) String() string + func (m *AgentInstanceChange) Validate() error + func (m *AgentInstanceChange) XXX_DiscardUnknown() + func (m *AgentInstanceChange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AgentInstanceChange) XXX_Merge(src proto.Message) + func (m *AgentInstanceChange) XXX_Size() int + func (m *AgentInstanceChange) XXX_Unmarshal(b []byte) error + type AgentInstanceChangeValidationError struct + func (e AgentInstanceChangeValidationError) Cause() error + func (e AgentInstanceChangeValidationError) Error() string + func (e AgentInstanceChangeValidationError) ErrorName() string + func (e AgentInstanceChangeValidationError) Field() string + func (e AgentInstanceChangeValidationError) Key() bool + func (e AgentInstanceChangeValidationError) Reason() string + type AgentInstanceValidationError struct + func (e AgentInstanceValidationError) Cause() error + func (e AgentInstanceValidationError) Error() string + func (e AgentInstanceValidationError) ErrorName() string + func (e AgentInstanceValidationError) Field() string + func (e AgentInstanceValidationError) Key() bool + func (e AgentInstanceValidationError) Reason() string + type AppMetadata struct + CreatedAt int64 + Creator string + Description string + Id string + Owner string + Secrets map[string]string + Status AppMetadata_Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AppMetadata) Descriptor() ([]byte, []int) + func (*AppMetadata) ProtoMessage() + func (m *AppMetadata) GetCreatedAt() int64 + func (m *AppMetadata) GetCreator() string + func (m *AppMetadata) GetDescription() string + func (m *AppMetadata) GetId() string + func (m *AppMetadata) GetOwner() string + func (m *AppMetadata) GetSecrets() map[string]string + func (m *AppMetadata) GetStatus() AppMetadata_Status + func (m *AppMetadata) Reset() + func (m *AppMetadata) String() string + func (m *AppMetadata) Validate() error + func (m *AppMetadata) XXX_DiscardUnknown() + func (m *AppMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AppMetadata) XXX_Merge(src proto.Message) + func (m *AppMetadata) XXX_Size() int + func (m *AppMetadata) XXX_Unmarshal(b []byte) error + type AppMetadataValidationError struct + func (e AppMetadataValidationError) Cause() error + func (e AppMetadataValidationError) Error() string + func (e AppMetadataValidationError) ErrorName() string + func (e AppMetadataValidationError) Field() string + func (e AppMetadataValidationError) Key() bool + func (e AppMetadataValidationError) Reason() string + type AppMetadata_Status int32 + const AppMetadata_DEPRECATED + const AppMetadata_INUSE + func (AppMetadata_Status) EnumDescriptor() ([]byte, []int) + func (x AppMetadata_Status) String() string + type Casbin struct + Policies []*Casbin_Policy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Casbin) Descriptor() ([]byte, []int) + func (*Casbin) ProtoMessage() + func (m *Casbin) GetPolicies() []*Casbin_Policy + func (m *Casbin) Reset() + func (m *Casbin) String() string + func (m *Casbin) Validate() error + func (m *Casbin) XXX_DiscardUnknown() + func (m *Casbin) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Casbin) XXX_Merge(src proto.Message) + func (m *Casbin) XXX_Size() int + func (m *Casbin) XXX_Unmarshal(b []byte) error + type CasbinValidationError struct + func (e CasbinValidationError) Cause() error + func (e CasbinValidationError) Error() string + func (e CasbinValidationError) ErrorName() string + func (e CasbinValidationError) Field() string + func (e CasbinValidationError) Key() bool + func (e CasbinValidationError) Reason() string + type Casbin_Policy struct + Ptype string + V0 string + V1 string + V2 string + V3 string + V4 string + V5 string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Casbin_Policy) Descriptor() ([]byte, []int) + func (*Casbin_Policy) ProtoMessage() + func (m *Casbin_Policy) GetPtype() string + func (m *Casbin_Policy) GetV0() string + func (m *Casbin_Policy) GetV1() string + func (m *Casbin_Policy) GetV2() string + func (m *Casbin_Policy) GetV3() string + func (m *Casbin_Policy) GetV4() string + func (m *Casbin_Policy) GetV5() string + func (m *Casbin_Policy) Reset() + func (m *Casbin_Policy) String() string + func (m *Casbin_Policy) Validate() error + func (m *Casbin_Policy) XXX_DiscardUnknown() + func (m *Casbin_Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Casbin_Policy) XXX_Merge(src proto.Message) + func (m *Casbin_Policy) XXX_Size() int + func (m *Casbin_Policy) XXX_Unmarshal(b []byte) error + type Casbin_PolicyValidationError struct + func (e Casbin_PolicyValidationError) Cause() error + func (e Casbin_PolicyValidationError) Error() string + func (e Casbin_PolicyValidationError) ErrorName() string + func (e Casbin_PolicyValidationError) Field() string + func (e Casbin_PolicyValidationError) Key() bool + func (e Casbin_PolicyValidationError) Reason() string + type ChangeOp int32 + const ChangeOp_DELETE + const ChangeOp_NEW + const ChangeOp_UNDEFINED + const ChangeOp_UPDATE + func (ChangeOp) EnumDescriptor() ([]byte, []int) + func (x ChangeOp) String() string + type ContentType int32 + const ContentType_INI + const ContentType_JSON + const ContentType_PLAINTEXT + const ContentType_TOML + const ContentType_UNKNOWN + func (ContentType) EnumDescriptor() ([]byte, []int) + func (x ContentType) String() string + type Element struct + Metadata *ElementMetadata + Published bool + Raw []byte + Version int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Element) Descriptor() ([]byte, []int) + func (*Element) ProtoMessage() + func (m *Element) GetMetadata() *ElementMetadata + func (m *Element) GetPublished() bool + func (m *Element) GetRaw() []byte + func (m *Element) GetVersion() int32 + func (m *Element) MarshalJSON() ([]byte, error) + func (m *Element) Reset() + func (m *Element) String() string + func (m *Element) Validate() error + func (m *Element) XXX_DiscardUnknown() + func (m *Element) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Element) XXX_Merge(src proto.Message) + func (m *Element) XXX_Size() int + func (m *Element) XXX_Unmarshal(b []byte) error + type ElementMetadata struct + App string + ContentType ContentType + Env string + Key string + LatestVersion int32 + UnpublishedVersion int32 + UsingFingerprint string + UsingVersion int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ElementMetadata) Descriptor() ([]byte, []int) + func (*ElementMetadata) ProtoMessage() + func (m *ElementMetadata) GetApp() string + func (m *ElementMetadata) GetContentType() ContentType + func (m *ElementMetadata) GetEnv() string + func (m *ElementMetadata) GetKey() string + func (m *ElementMetadata) GetLatestVersion() int32 + func (m *ElementMetadata) GetUnpublishedVersion() int32 + func (m *ElementMetadata) GetUsingFingerprint() string + func (m *ElementMetadata) GetUsingVersion() int32 + func (m *ElementMetadata) MarshalJSON() ([]byte, error) + func (m *ElementMetadata) Reset() + func (m *ElementMetadata) String() string + func (m *ElementMetadata) Validate() error + func (m *ElementMetadata) XXX_DiscardUnknown() + func (m *ElementMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ElementMetadata) XXX_Merge(src proto.Message) + func (m *ElementMetadata) XXX_Size() int + func (m *ElementMetadata) XXX_Unmarshal(b []byte) error + type ElementMetadataValidationError struct + func (e ElementMetadataValidationError) Cause() error + func (e ElementMetadataValidationError) Error() string + func (e ElementMetadataValidationError) ErrorName() string + func (e ElementMetadataValidationError) Field() string + func (e ElementMetadataValidationError) Key() bool + func (e ElementMetadataValidationError) Reason() string + type ElementOperation struct + CurrentVersion int32 + LastVersion int32 + Op ElementOperation_Op + OperatedAt int64 + OperatedKey string + Operator string + Remark string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ElementOperation) Descriptor() ([]byte, []int) + func (*ElementOperation) ProtoMessage() + func (m *ElementOperation) GetCurrentVersion() int32 + func (m *ElementOperation) GetLastVersion() int32 + func (m *ElementOperation) GetOp() ElementOperation_Op + func (m *ElementOperation) GetOperatedAt() int64 + func (m *ElementOperation) GetOperatedKey() string + func (m *ElementOperation) GetOperator() string + func (m *ElementOperation) GetRemark() string + func (m *ElementOperation) Reset() + func (m *ElementOperation) String() string + func (m *ElementOperation) Validate() error + func (m *ElementOperation) XXX_DiscardUnknown() + func (m *ElementOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ElementOperation) XXX_Merge(src proto.Message) + func (m *ElementOperation) XXX_Size() int + func (m *ElementOperation) XXX_Unmarshal(b []byte) error + type ElementOperationValidationError struct + func (e ElementOperationValidationError) Cause() error + func (e ElementOperationValidationError) Error() string + func (e ElementOperationValidationError) ErrorName() string + func (e ElementOperationValidationError) Field() string + func (e ElementOperationValidationError) Key() bool + func (e ElementOperationValidationError) Reason() string + type ElementOperation_Op int32 + const ElementOperation_INVALID + const ElementOperation_PUBLISH + const ElementOperation_SET + const ElementOperation_UNSET + func (ElementOperation_Op) EnumDescriptor() ([]byte, []int) + func (x ElementOperation_Op) String() string + type ElementValidationError struct + func (e ElementValidationError) Cause() error + func (e ElementValidationError) Error() string + func (e ElementValidationError) ErrorName() string + func (e ElementValidationError) Field() string + func (e ElementValidationError) Key() bool + func (e ElementValidationError) Reason() string + type Instance struct + AgentId string + ClientId string + ClientIp string + LastRenewTimestamp int64 + Watching []*Instance_Watching + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Instance) Descriptor() ([]byte, []int) + func (*Instance) ProtoMessage() + func (m *Instance) GetAgentId() string + func (m *Instance) GetClientId() string + func (m *Instance) GetClientIp() string + func (m *Instance) GetLastRenewTimestamp() int64 + func (m *Instance) GetWatching() []*Instance_Watching + func (m *Instance) Id() string + func (m *Instance) Reset() + func (m *Instance) String() string + func (m *Instance) Validate() error + func (m *Instance) XXX_DiscardUnknown() + func (m *Instance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Instance) XXX_Merge(src proto.Message) + func (m *Instance) XXX_Size() int + func (m *Instance) XXX_Unmarshal(b []byte) error + type InstanceHybrid interface + GetInstance func(ctx context.Context, insId string) (*Instance, error) + GetInstances func(ctx context.Context, seek string, limit int) (*getInstancesResult, error) + GetInstancesByElement func(ctx context.Context, app, env, key string) (*getInstancesResult, error) + RegisterInstance func(ctx context.Context, ins *Instance) error + RenewInstance func(ctx context.Context, ins *Instance) error + UnregisterInstance func(ctx context.Context, insId string) error + type InstanceValidationError struct + func (e InstanceValidationError) Cause() error + func (e InstanceValidationError) Error() string + func (e InstanceValidationError) ErrorName() string + func (e InstanceValidationError) Field() string + func (e InstanceValidationError) Key() bool + func (e InstanceValidationError) Reason() string + type Instance_Watching struct + App string + Env string + WatchKeys []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Instance_Watching) Descriptor() ([]byte, []int) + func (*Instance_Watching) ProtoMessage() + func (m *Instance_Watching) GetApp() string + func (m *Instance_Watching) GetEnv() string + func (m *Instance_Watching) GetWatchKeys() []string + func (m *Instance_Watching) Reset() + func (m *Instance_Watching) String() string + func (m *Instance_Watching) Validate() error + func (m *Instance_Watching) XXX_DiscardUnknown() + func (m *Instance_Watching) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Instance_Watching) XXX_Merge(src proto.Message) + func (m *Instance_Watching) XXX_Size() int + func (m *Instance_Watching) XXX_Unmarshal(b []byte) error + type Instance_WatchingValidationError struct + func (e Instance_WatchingValidationError) Cause() error + func (e Instance_WatchingValidationError) Error() string + func (e Instance_WatchingValidationError) ErrorName() string + func (e Instance_WatchingValidationError) Field() string + func (e Instance_WatchingValidationError) Key() bool + func (e Instance_WatchingValidationError) Reason() string + type KVReadOnly interface + GetApp func(ctx context.Context, app string) (*AppMetadata, error) + GetApps func(ctx context.Context, seek string, limit int) (*getAppsResult, error) + GetElementOperations func(ctx context.Context, app, env, key string, start int) (ops []*ElementOperation, next int, err error) + GetElementVersions func(ctx context.Context, app, env, key string, seek string, limit int) (*getElementsResult, error) + GetElementWithVersion func(ctx context.Context, app, env, key string, version int) (*Element, error) + GetElements func(ctx context.Context, app, env string, seek string, limit int) (*getElementsResult, error) + GetElementsByKeys func(ctx context.Context, app, env string, keys []string) (*getElementsResult, error) + GetEnvironments func(ctx context.Context, app, seek string, limit int) (*getAppEnvsResult, error) + func NewKVReader(endpoints []string) (KVReadOnly, error) + type KVWriteOnly interface + CreateApp func(ctx context.Context, md *AppMetadata) error + CreateElement func(ctx context.Context, app, env, key string, raw []byte, contentTyp ContentType) error + CreateEnvironment func(ctx context.Context, app, env string) error + DeleteApp func(ctx context.Context, appId string) error + DeleteElement func(ctx context.Context, app, env, key string) error + DeleteEnvironment func(ctx context.Context, app, env string) error + PublishElementVersion func(ctx context.Context, app string, env string, key string, publishVersion uint32) (*Element, error) + RollbackElementVersion func(ctx context.Context, app string, env string, key string, ...) error + UpdateElement func(ctx context.Context, app, env, key string, raw []byte) error + func NewKVHybrid(endpoints []string) (KVWriteOnly, error) + type PublishingMode uint8 + const PublishMode_FULL + const PublishMode_GRAY + type RBAC interface + AddUser func(u *User) error + AssignRole func(account, role string, domain ...string) error + DisableUser func(account string) error + Enforce func(subject, domain, object, act string) (bool, error) + GetUser func(account string) (*User, error) + RevokeRole func(account, role string, domain ...string) error + type User struct + Account string + HashedPassword string + Nickname string + Salt string + Status User_Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*User) Descriptor() ([]byte, []int) + func (*User) ProtoMessage() + func (m *User) GetAccount() string + func (m *User) GetHashedPassword() string + func (m *User) GetNickname() string + func (m *User) GetSalt() string + func (m *User) GetStatus() User_Status + func (m *User) Reset() + func (m *User) String() string + func (m *User) Validate() error + func (m *User) XXX_DiscardUnknown() + func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *User) XXX_Merge(src proto.Message) + func (m *User) XXX_Size() int + func (m *User) XXX_Unmarshal(b []byte) error + type UserValidationError struct + func (e UserValidationError) Cause() error + func (e UserValidationError) Error() string + func (e UserValidationError) ErrorName() string + func (e UserValidationError) Field() string + func (e UserValidationError) Key() bool + func (e UserValidationError) Reason() string + type User_Status int32 + const User_FORBIDDEN + const User_NORMAL + func (User_Status) EnumDescriptor() ([]byte, []int) + func (x User_Status) String() string