Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRPCServer(s grpc.ServiceRegistrar, srv RPCServer)
- type CreateSecretRequest
- func (s *CreateSecretRequest) AllowRegionString() string
- func (s *CreateSecretRequest) DecryptAPISecret(key string) error
- func (s *CreateSecretRequest) DensenseKey() string
- func (*CreateSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (s *CreateSecretRequest) Desense()
- func (s *CreateSecretRequest) EncryptAPISecret(key string) error
- func (x *CreateSecretRequest) GetAddress() string
- func (x *CreateSecretRequest) GetApiKey() string
- func (x *CreateSecretRequest) GetApiSecret() string
- func (x *CreateSecretRequest) GetCrendentialType() TYPE
- func (x *CreateSecretRequest) GetDescription() string
- func (x *CreateSecretRequest) GetDomain() string
- func (x *CreateSecretRequest) GetNamespace() string
- func (x *CreateSecretRequest) GetRegions() []string
- func (x *CreateSecretRequest) GetRequestRate() int32
- func (x *CreateSecretRequest) GetVendor() resource.VENDOR
- func (s *CreateSecretRequest) IsAllowRegion(region string) bool
- func (s *CreateSecretRequest) LoadAllowRegionFromString(regions string)
- func (*CreateSecretRequest) ProtoMessage()
- func (x *CreateSecretRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSecretRequest) Reset()
- func (req *CreateSecretRequest) SetOwner(tk *token.Token)
- func (s *CreateSecretRequest) ShortDesc() string
- func (x *CreateSecretRequest) String() string
- func (req *CreateSecretRequest) Validate() error
- type DeleteSecretRequest
- func (*DeleteSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteSecretRequest) GetId() string
- func (*DeleteSecretRequest) ProtoMessage()
- func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteSecretRequest) Reset()
- func (x *DeleteSecretRequest) String() string
- type DescribeSecretRequest
- func (*DescribeSecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DescribeSecretRequest) GetId() string
- func (*DescribeSecretRequest) ProtoMessage()
- func (x *DescribeSecretRequest) ProtoReflect() protoreflect.Message
- func (x *DescribeSecretRequest) Reset()
- func (x *DescribeSecretRequest) String() string
- type Meta
- type QuerySecretRequest
- func (*QuerySecretRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QuerySecretRequest) GetDomain() string
- func (x *QuerySecretRequest) GetKeywords() string
- func (x *QuerySecretRequest) GetNamespace() string
- func (x *QuerySecretRequest) GetPage() *request.PageRequest
- func (*QuerySecretRequest) ProtoMessage()
- func (x *QuerySecretRequest) ProtoReflect() protoreflect.Message
- func (x *QuerySecretRequest) Reset()
- func (x *QuerySecretRequest) String() string
- func (req *QuerySecretRequest) WithNamespace(tk *token.Token)
- type RPCClient
- type RPCServer
- type Secret
- func (*Secret) Descriptor() ([]byte, []int)deprecated
- func (x *Secret) GetMeta() *Meta
- func (x *Secret) GetSpec() *CreateSecretRequest
- func (c *Secret) MarshalJSON() ([]byte, error)
- func (*Secret) ProtoMessage()
- func (x *Secret) ProtoReflect() protoreflect.Message
- func (x *Secret) Reset()
- func (x *Secret) String() string
- func (s *Secret) TableName() string
- type SecretSet
- func (s *SecretSet) Add(item *Secret)
- func (*SecretSet) Descriptor() ([]byte, []int)deprecated
- func (s *SecretSet) Desense()
- func (x *SecretSet) GetItems() []*Secret
- func (x *SecretSet) GetTotal() int64
- func (*SecretSet) ProtoMessage()
- func (x *SecretSet) ProtoReflect() protoreflect.Message
- func (x *SecretSet) Reset()
- func (x *SecretSet) String() string
- type Service
- type TYPE
- func (TYPE) Descriptor() protoreflect.EnumDescriptor
- func (x TYPE) Enum() *TYPE
- func (TYPE) EnumDescriptor() ([]byte, []int)deprecated
- func (t TYPE) Equal(target TYPE) bool
- func (t TYPE) IsIn(targets ...TYPE) bool
- func (t TYPE) MarshalJSON() ([]byte, error)
- func (x TYPE) Number() protoreflect.EnumNumber
- func (x TYPE) String() string
- func (TYPE) Type() protoreflect.EnumType
- func (t *TYPE) UnmarshalJSON(b []byte) error
- type UnimplementedRPCServer
- type UnsafeRPCServer
Constants ¶
const (
AppName = "secrets"
)
Variables ¶
var ( TYPE_name = map[int32]string{ 0: "API_KEY", 1: "PASSWORD", } TYPE_value = map[string]int32{ "API_KEY": 0, "PASSWORD": 1, } )
Enum value maps for TYPE.
var File_apps_secret_pb_rpc_proto protoreflect.FileDescriptor
var File_apps_secret_pb_secret_proto protoreflect.FileDescriptor
var RPC_ServiceDesc = grpc.ServiceDesc{ ServiceName: "infraboard.cmdb.secret.RPC", HandlerType: (*RPCServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QuerySecret", Handler: _RPC_QuerySecret_Handler, }, { MethodName: "DescribeSecret", Handler: _RPC_DescribeSecret_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "apps/secret/pb/rpc.proto", }
RPC_ServiceDesc is the grpc.ServiceDesc for RPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRPCServer ¶
func RegisterRPCServer(s grpc.ServiceRegistrar, srv RPCServer)
Types ¶
type CreateSecretRequest ¶
type CreateSecretRequest struct {
// 描述
// @gotags: json:"description" validate:"required,lte=100"
Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description" validate:"required,lte=100"`
// 厂商
// @gotags: json:"vendor"
Vendor resource.VENDOR `protobuf:"varint,2,opt,name=vendor,proto3,enum=infraboard.cmdb.resource.VENDOR" json:"vendor"`
// 资源所在的Region列表
// @gotags: json:"regions"
Regions []string `protobuf:"bytes,3,rep,name=regions,proto3" json:"regions"`
// 凭证类型
// @gotags: json:"crendential_type"
CrendentialType TYPE `` /* 130-byte string literal not displayed */
// 服务地址, 云商不用填写
// @gotags: json:"address"
Address string `protobuf:"bytes,5,opt,name=address,proto3" json:"address"`
// key
// @gotags: json:"api_key" validate:"required,lte=100"
ApiKey string `protobuf:"bytes,6,opt,name=api_key,json=apiKey,proto3" json:"api_key" validate:"required,lte=100"`
// api_secret
// @gotags: json:"api_secret" validate:"required,lte=100"
ApiSecret string `protobuf:"bytes,7,opt,name=api_secret,json=apiSecret,proto3" json:"api_secret" validate:"required,lte=100"`
// 请求速率限制, 默认1秒5个
// @gotags: json:"request_rate"
RequestRate int32 `protobuf:"varint,8,opt,name=request_rate,json=requestRate,proto3" json:"request_rate"`
// 所属Domain
// @gotags: json:"domain" validate:"required"
Domain string `protobuf:"bytes,9,opt,name=domain,proto3" json:"domain" validate:"required"`
// 所属Namespace
// @gotags: json:"namespace" validate:"required"
Namespace string `protobuf:"bytes,10,opt,name=namespace,proto3" json:"namespace" validate:"required"`
// contains filtered or unexported fields
}
func NewCreateSecretRequest ¶
func NewCreateSecretRequest() *CreateSecretRequest
func (*CreateSecretRequest) AllowRegionString ¶
func (s *CreateSecretRequest) AllowRegionString() string
func (*CreateSecretRequest) DecryptAPISecret ¶
func (s *CreateSecretRequest) DecryptAPISecret(key string) error
func (*CreateSecretRequest) DensenseKey ¶
func (s *CreateSecretRequest) DensenseKey() string
func (*CreateSecretRequest) Descriptor
deprecated
func (*CreateSecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSecretRequest.ProtoReflect.Descriptor instead.
func (*CreateSecretRequest) Desense ¶
func (s *CreateSecretRequest) Desense()
func (*CreateSecretRequest) EncryptAPISecret ¶
func (s *CreateSecretRequest) EncryptAPISecret(key string) error
func (*CreateSecretRequest) GetAddress ¶
func (x *CreateSecretRequest) GetAddress() string
func (*CreateSecretRequest) GetApiKey ¶
func (x *CreateSecretRequest) GetApiKey() string
func (*CreateSecretRequest) GetApiSecret ¶
func (x *CreateSecretRequest) GetApiSecret() string
func (*CreateSecretRequest) GetCrendentialType ¶
func (x *CreateSecretRequest) GetCrendentialType() TYPE
func (*CreateSecretRequest) GetDescription ¶
func (x *CreateSecretRequest) GetDescription() string
func (*CreateSecretRequest) GetDomain ¶
func (x *CreateSecretRequest) GetDomain() string
func (*CreateSecretRequest) GetNamespace ¶
func (x *CreateSecretRequest) GetNamespace() string
func (*CreateSecretRequest) GetRegions ¶
func (x *CreateSecretRequest) GetRegions() []string
func (*CreateSecretRequest) GetRequestRate ¶
func (x *CreateSecretRequest) GetRequestRate() int32
func (*CreateSecretRequest) GetVendor ¶
func (x *CreateSecretRequest) GetVendor() resource.VENDOR
func (*CreateSecretRequest) IsAllowRegion ¶
func (s *CreateSecretRequest) IsAllowRegion(region string) bool
func (*CreateSecretRequest) LoadAllowRegionFromString ¶
func (s *CreateSecretRequest) LoadAllowRegionFromString(regions string)
func (*CreateSecretRequest) ProtoMessage ¶
func (*CreateSecretRequest) ProtoMessage()
func (*CreateSecretRequest) ProtoReflect ¶
func (x *CreateSecretRequest) ProtoReflect() protoreflect.Message
func (*CreateSecretRequest) Reset ¶
func (x *CreateSecretRequest) Reset()
func (*CreateSecretRequest) SetOwner ¶
func (req *CreateSecretRequest) SetOwner(tk *token.Token)
func (*CreateSecretRequest) ShortDesc ¶
func (s *CreateSecretRequest) ShortDesc() string
func (*CreateSecretRequest) String ¶
func (x *CreateSecretRequest) String() string
func (*CreateSecretRequest) Validate ¶
func (req *CreateSecretRequest) Validate() error
type DeleteSecretRequest ¶
type DeleteSecretRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func NewDeleteSecretRequestWithID ¶
func NewDeleteSecretRequestWithID(id string) *DeleteSecretRequest
func (*DeleteSecretRequest) Descriptor
deprecated
func (*DeleteSecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteSecretRequest.ProtoReflect.Descriptor instead.
func (*DeleteSecretRequest) GetId ¶
func (x *DeleteSecretRequest) GetId() string
func (*DeleteSecretRequest) ProtoMessage ¶
func (*DeleteSecretRequest) ProtoMessage()
func (*DeleteSecretRequest) ProtoReflect ¶
func (x *DeleteSecretRequest) ProtoReflect() protoreflect.Message
func (*DeleteSecretRequest) Reset ¶
func (x *DeleteSecretRequest) Reset()
func (*DeleteSecretRequest) String ¶
func (x *DeleteSecretRequest) String() string
type DescribeSecretRequest ¶
type DescribeSecretRequest struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func NewDescribeSecretRequest ¶
func NewDescribeSecretRequest(id string) *DescribeSecretRequest
func (*DescribeSecretRequest) Descriptor
deprecated
func (*DescribeSecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use DescribeSecretRequest.ProtoReflect.Descriptor instead.
func (*DescribeSecretRequest) GetId ¶
func (x *DescribeSecretRequest) GetId() string
func (*DescribeSecretRequest) ProtoMessage ¶
func (*DescribeSecretRequest) ProtoMessage()
func (*DescribeSecretRequest) ProtoReflect ¶
func (x *DescribeSecretRequest) ProtoReflect() protoreflect.Message
func (*DescribeSecretRequest) Reset ¶
func (x *DescribeSecretRequest) Reset()
func (*DescribeSecretRequest) String ¶
func (x *DescribeSecretRequest) String() string
type Meta ¶
type Meta struct {
// 全局唯一Id
// @gotags: json:"id"
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
// 创建时间
// @gotags: json:"create_at"
CreateAt int64 `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at"`
// contains filtered or unexported fields
}
func (*Meta) Descriptor
deprecated
func (*Meta) GetCreateAt ¶
func (*Meta) ProtoMessage ¶
func (*Meta) ProtoMessage()
func (*Meta) ProtoReflect ¶
func (x *Meta) ProtoReflect() protoreflect.Message
type QuerySecretRequest ¶
type QuerySecretRequest struct {
// 分页参数
// @gotags: json:"page"
Page *request.PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"`
// 关键字参数
// @gotags: json:"keywords"
Keywords string `protobuf:"bytes,2,opt,name=keywords,proto3" json:"keywords"`
// 所属Domain
// @gotags: json:"domain"
Domain string `protobuf:"bytes,14,opt,name=domain,proto3" json:"domain"`
// 所属Namespace
// @gotags: json:"namespace"
Namespace string `protobuf:"bytes,15,opt,name=namespace,proto3" json:"namespace"`
// contains filtered or unexported fields
}
func NewQuerySecretRequest ¶
func NewQuerySecretRequest() *QuerySecretRequest
func NewQuerySecretRequestFromHTTP ¶
func NewQuerySecretRequestFromHTTP(r *http.Request) *QuerySecretRequest
func (*QuerySecretRequest) Descriptor
deprecated
func (*QuerySecretRequest) Descriptor() ([]byte, []int)
Deprecated: Use QuerySecretRequest.ProtoReflect.Descriptor instead.
func (*QuerySecretRequest) GetDomain ¶
func (x *QuerySecretRequest) GetDomain() string
func (*QuerySecretRequest) GetKeywords ¶
func (x *QuerySecretRequest) GetKeywords() string
func (*QuerySecretRequest) GetNamespace ¶
func (x *QuerySecretRequest) GetNamespace() string
func (*QuerySecretRequest) GetPage ¶
func (x *QuerySecretRequest) GetPage() *request.PageRequest
func (*QuerySecretRequest) ProtoMessage ¶
func (*QuerySecretRequest) ProtoMessage()
func (*QuerySecretRequest) ProtoReflect ¶
func (x *QuerySecretRequest) ProtoReflect() protoreflect.Message
func (*QuerySecretRequest) Reset ¶
func (x *QuerySecretRequest) Reset()
func (*QuerySecretRequest) String ¶
func (x *QuerySecretRequest) String() string
func (*QuerySecretRequest) WithNamespace ¶
func (req *QuerySecretRequest) WithNamespace(tk *token.Token)
type RPCClient ¶
type RPCClient interface {
QuerySecret(ctx context.Context, in *QuerySecretRequest, opts ...grpc.CallOption) (*SecretSet, error)
DescribeSecret(ctx context.Context, in *DescribeSecretRequest, opts ...grpc.CallOption) (*Secret, error)
}
RPCClient is the client API for RPC service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRPCClient ¶
func NewRPCClient(cc grpc.ClientConnInterface) RPCClient
type RPCServer ¶
type RPCServer interface {
QuerySecret(context.Context, *QuerySecretRequest) (*SecretSet, error)
DescribeSecret(context.Context, *DescribeSecretRequest) (*Secret, error)
// contains filtered or unexported methods
}
RPCServer is the server API for RPC service. All implementations must embed UnimplementedRPCServer for forward compatibility
type Secret ¶
type Secret struct {
// 额外信息
// @gotags: json:"meta" gorm:"embedded"
Meta *Meta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta" gorm:"embedded"`
// 创建信息
// @gotags: json:"spec" gorm:"embedded"
Spec *CreateSecretRequest `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec" gorm:"embedded"`
// contains filtered or unexported fields
}
func NewDefaultSecret ¶
func NewDefaultSecret() *Secret
func NewSecret ¶
func NewSecret(req *CreateSecretRequest) (*Secret, error)
func (*Secret) Descriptor
deprecated
func (*Secret) GetSpec ¶
func (x *Secret) GetSpec() *CreateSecretRequest
func (*Secret) MarshalJSON ¶
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶
func (x *Secret) ProtoReflect() protoreflect.Message
type SecretSet ¶
type SecretSet struct {
// @gotags: json:"total"
Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total"`
// @gotags: json:"items"
Items []*Secret `protobuf:"bytes,2,rep,name=items,proto3" json:"items"`
// contains filtered or unexported fields
}
func NewSecretSet ¶
func NewSecretSet() *SecretSet
func (*SecretSet) Descriptor
deprecated
func (*SecretSet) ProtoMessage ¶
func (*SecretSet) ProtoMessage()
func (*SecretSet) ProtoReflect ¶
func (x *SecretSet) ProtoReflect() protoreflect.Message
type TYPE ¶
type TYPE int32
func ParseTYPEFromString ¶
ParseTYPEFromString Parse TYPE from string
func (TYPE) Descriptor ¶
func (TYPE) Descriptor() protoreflect.EnumDescriptor
func (TYPE) EnumDescriptor
deprecated
func (TYPE) Number ¶
func (x TYPE) Number() protoreflect.EnumNumber
func (TYPE) Type ¶
func (TYPE) Type() protoreflect.EnumType
type UnimplementedRPCServer ¶
type UnimplementedRPCServer struct {
}
UnimplementedRPCServer must be embedded to have forward compatible implementations.
func (UnimplementedRPCServer) DescribeSecret ¶
func (UnimplementedRPCServer) DescribeSecret(context.Context, *DescribeSecretRequest) (*Secret, error)
func (UnimplementedRPCServer) QuerySecret ¶
func (UnimplementedRPCServer) QuerySecret(context.Context, *QuerySecretRequest) (*SecretSet, error)
type UnsafeRPCServer ¶
type UnsafeRPCServer interface {
// contains filtered or unexported methods
}
UnsafeRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RPCServer will result in compilation errors.