Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
- type Bucket
- type BucketSet
- func (s *BucketSet) Add(items ...any)
- func (s *BucketSet) AddSet(set *BucketSet)
- func (*BucketSet) Descriptor() ([]byte, []int)deprecated
- func (x *BucketSet) GetItems() []*Bucket
- func (x *BucketSet) GetTotal() int64
- func (s *BucketSet) Length() int64
- func (*BucketSet) ProtoMessage()
- func (x *BucketSet) ProtoReflect() protoreflect.Message
- func (x *BucketSet) Reset()
- func (x *BucketSet) String() string
- func (s *BucketSet) ToAny() (items []any)
- type Describe
- type QueryBucketRequest
- func (*QueryBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryBucketRequest) GetPage() *request.PageRequest
- func (*QueryBucketRequest) ProtoMessage()
- func (x *QueryBucketRequest) ProtoReflect() protoreflect.Message
- func (x *QueryBucketRequest) Reset()
- func (x *QueryBucketRequest) String() string
- type ServiceClient
- type ServiceServer
- type UnimplementedServiceServer
- type UnsafeServiceServer
Constants ¶
const (
AppName = "oss"
)
Variables ¶
var File_apps_oss_pb_oss_proto protoreflect.FileDescriptor
var File_apps_oss_pb_rpc_proto protoreflect.FileDescriptor
var Service_ServiceDesc = grpc.ServiceDesc{ ServiceName: "infraboard.cmdb.oss.Service", HandlerType: (*ServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SyncBucket", Handler: _Service_SyncBucket_Handler, }, { MethodName: "QueryBucket", Handler: _Service_QueryBucket_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "apps/oss/pb/rpc.proto", }
Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterServiceServer ¶
func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)
Types ¶
type Bucket ¶
type Bucket struct { // @gotags: json:"resource" Resource *resource.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource"` // @gotags: json:"describe" Describe *Describe `protobuf:"bytes,3,opt,name=describe,proto3" json:"describe"` // contains filtered or unexported fields }
func NewDefaultBucket ¶
func NewDefaultBucket() *Bucket
func (*Bucket) Descriptor
deprecated
func (*Bucket) GetDescribe ¶
func (*Bucket) GetResource ¶
func (*Bucket) ProtoMessage ¶
func (*Bucket) ProtoMessage()
func (*Bucket) ProtoReflect ¶
func (x *Bucket) ProtoReflect() protoreflect.Message
type BucketSet ¶
type BucketSet struct { // 总数量 // @gotags: json:"total" Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total"` // 列表项 // @gotags: json:"items" Items []*Bucket `protobuf:"bytes,2,rep,name=items,proto3" json:"items"` // contains filtered or unexported fields }
func NewBucketSet ¶
func NewBucketSet() *BucketSet
func (*BucketSet) Descriptor
deprecated
func (*BucketSet) ProtoMessage ¶
func (*BucketSet) ProtoMessage()
func (*BucketSet) ProtoReflect ¶
func (x *BucketSet) ProtoReflect() protoreflect.Message
type Describe ¶
type Describe struct { // 存储类型 // @gotags: json:"storage_class" StorageClass string `protobuf:"bytes,1,opt,name=storage_class,json=storageClass,proto3" json:"storage_class"` // contains filtered or unexported fields }
func (*Describe) Descriptor
deprecated
func (*Describe) GetStorageClass ¶
func (*Describe) ProtoMessage ¶
func (*Describe) ProtoMessage()
func (*Describe) ProtoReflect ¶
func (x *Describe) ProtoReflect() protoreflect.Message
type QueryBucketRequest ¶
type QueryBucketRequest struct { // 分页参数 // @gotags: json:"page" Page *request.PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"` // contains filtered or unexported fields }
func (*QueryBucketRequest) Descriptor
deprecated
func (*QueryBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryBucketRequest.ProtoReflect.Descriptor instead.
func (*QueryBucketRequest) GetPage ¶
func (x *QueryBucketRequest) GetPage() *request.PageRequest
func (*QueryBucketRequest) ProtoMessage ¶
func (*QueryBucketRequest) ProtoMessage()
func (*QueryBucketRequest) ProtoReflect ¶
func (x *QueryBucketRequest) ProtoReflect() protoreflect.Message
func (*QueryBucketRequest) Reset ¶
func (x *QueryBucketRequest) Reset()
func (*QueryBucketRequest) String ¶
func (x *QueryBucketRequest) String() string
type ServiceClient ¶
type ServiceClient interface { SyncBucket(ctx context.Context, in *Bucket, opts ...grpc.CallOption) (*Bucket, error) QueryBucket(ctx context.Context, in *QueryBucketRequest, opts ...grpc.CallOption) (*BucketSet, error) }
ServiceClient is the client API for Service 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 NewServiceClient ¶
func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient
type ServiceServer ¶
type ServiceServer interface { SyncBucket(context.Context, *Bucket) (*Bucket, error) QueryBucket(context.Context, *QueryBucketRequest) (*BucketSet, error) // contains filtered or unexported methods }
ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility
type UnimplementedServiceServer ¶
type UnimplementedServiceServer struct { }
UnimplementedServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedServiceServer) QueryBucket ¶
func (UnimplementedServiceServer) QueryBucket(context.Context, *QueryBucketRequest) (*BucketSet, error)
func (UnimplementedServiceServer) SyncBucket ¶
type UnsafeServiceServer ¶
type UnsafeServiceServer interface {
// contains filtered or unexported methods
}
UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.