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.