rds

package
v0.0.0-...-7aae7b9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 12, 2023 License: MIT Imports: 16 Imported by: 0

README

Rds管理

统一状态

各厂商状态

阿里云: 实例状态表

  • Creating 创建中

  • Running 使用中

  • Deleting 删除中

  • Released 已释放实例

  • Rebooting 重启中

  • Restoring 备份恢复中

  • TRANSING 迁移中

  • DBInstanceClassChanging 升降级中

  • GuardSwitching 容灾切换中

  • GuardDBInstanceCreating 生产灾备实例中

  • Importing 数据导入中

  • INS_CLONING 实例克隆中

  • EngineVersionUpgrading 迁移版本中

  • DBInstanceNetTypeChanging 内外网切换中

  • TransingToOthers 迁移数据到其他RDS中

  • ImportingFromOthers 从其他RDS实例导入数据中

腾讯云: DescribeDBInstancesAPI文档

实例状态，可取值：

  • 0 - 创建中
  • 1 - 运行中
  • 4 - 正在进行隔离操作
  • 5 - 隔离中（可在回收站恢复开机）

实例任务状态，可能取值：

  • 0 - 没有任务

  • 1 - 升级中

  • 2 - 数据导入中

  • 6 - 回档中

  • 10 - 重启中

  • 12 - 自建迁移中

  • 14 - 灾备实例创建同步中

  • 15 - 升级待切换

  • 16 - 升级切换中

  • 17 - 升级切换完成

  • 4 - 外网访问开通中

  • 7 - 外网访问关闭中

  • 3 - 开放Slave中

  • 5 - 批量操作执行中

  • 8 - 密码修改中

  • 9 - 实例名修改中

  • 13 - 删除库表中

  • 19 - 参数设置待执行

华为云: API 文档

  • 值为“BUILD”,表示实例正在创建。

  • 值为“ACTIVE”,表示实例正常。

  • 值为“FAILED”,表示实例异常。

  • 值为“FROZEN”,表示实例冻结。

  • 值为“REBOOTING”,表示实例正在重启。

  • 值为“MIGRATING”,表示实例正在迁移。

  • 值为“RESTORING”,表示实例正在恢复。

  • 值为“MODIFYING”,表示实例正在扩容。

  • 值为“SWITCHOVER”,表示实例正在主备切换。

  • 值为“STORAGE FULL”,表示实例磁盘空间满

  • 值为“BACKING UP”,表示实例正在进行备份。

  • 值为“MODIFYING INSTANCE TYPE”,表示实例正在转主备。

  • 值为“MODIFYING DATABASE PORT”,表示实例正在修改数据库端口。

统一状态
  • PENDING：表示创建中
  • RUNNING：表示运行中
  • ERROR: 运行异常
  • REBOOTING：表示重启中
  • DELETING：表示销毁中。
  • DESTROYED: 已销毁
  • ISOLATIONING: 隔离中
  • ISOLATIONED: 已隔中
  • RESTORING: 备份恢复中
  • TRANSING: 迁移中
  • SWITCHOVER: 表示实例正在主备切换
  • GUARD_CREATING: 灾备实例创建同步中
  • IMPORTING: 数据导入中
  • STORAGE_FULL: 表示实例磁盘空间满
  • CLONING: 实例克隆中
  • UPGRADING: 迁移版本中
  • BACKING_UP: 表示实例正在进行备份
  • NET_CHANGING: 内外网切换中
  • MODIFYING: 实例配置变更生效中

Documentation

Index

Constants

View Source 
const (
	AppName = "rds"
)

Variables

View Source 
var (
	STATUS_name = map[int32]string{
		0:  "UNKNOW",
		5:  "PENDING",
		6:  "CREATE_FAILED",
		11: "RUNNING",
		20: "MODIFYING",
		30: "REBOOTING",
		31: "RESTORING",
		32: "TRANSING",
		33: "IMPORTING",
		34: "CLONING",
		35: "UPGRADING",
		36: "BACKING_UP",
		37: "NET_CHANGING",
		40: "SWITCHOVER",
		41: "GUARD_CREATING",
		50: "ERROR",
		51: "STORAGE_FULL",
		70: "LOCKED",
		71: "ISOLATIONING",
		72: "ISOLATIONED",
		80: "SHUTDOWN",
		81: "DELETING",
		90: "DESTROYED",
	}
	STATUS_value = map[string]int32{
		"UNKNOW":         0,
		"PENDING":        5,
		"CREATE_FAILED":  6,
		"RUNNING":        11,
		"MODIFYING":      20,
		"REBOOTING":      30,
		"RESTORING":      31,
		"TRANSING":       32,
		"IMPORTING":      33,
		"CLONING":        34,
		"UPGRADING":      35,
		"BACKING_UP":     36,
		"NET_CHANGING":   37,
		"SWITCHOVER":     40,
		"GUARD_CREATING": 41,
		"ERROR":          50,
		"STORAGE_FULL":   51,
		"LOCKED":         70,
		"ISOLATIONING":   71,
		"ISOLATIONED":    72,
		"SHUTDOWN":       80,
		"DELETING":       81,
		"DESTROYED":      90,
	}
)

Enum value maps for STATUS.

View Source 
var File_apps_rds_pb_rds_proto protoreflect.FileDescriptor
View Source 
var File_apps_rds_pb_rpc_proto protoreflect.FileDescriptor
View Source 
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "infraboard.cmdb.rds.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SyncRDS",
			Handler:    _Service_SyncRDS_Handler,
		},
		{
			MethodName: "QueryRDS",
			Handler:    _Service_QueryRDS_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "apps/rds/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 Account 

type Account struct {

	// 账号名称
	// @gotags: json:"name"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	// 账号对该数据库拥有的权限
	// @gotags: json:"account_privilege"
	AccountPrivilege string `protobuf:"bytes,2,opt,name=account_privilege,json=accountPrivilege,proto3" json:"account_privilege"`
	// 账号对该数据库具有的权限。
	// @gotags: json:"account_privilege_detail"
	AccountPrivilegeDetail string `protobuf:"bytes,3,opt,name=account_privilege_detail,json=accountPrivilegeDetail,proto3" json:"account_privilege_detail"`
	// 账号描述
	// @gotags: json:"description"
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description"`
	// 创建时间
	// @gotags: json:"create_at"
	CreateAt int64 `protobuf:"varint,5,opt,name=create_at,json=createAt,proto3" json:"create_at"`
	// 修改时间
	// @gotags: json:"modify_at"
	ModifyAt int64 `protobuf:"varint,6,opt,name=modify_at,json=modifyAt,proto3" json:"modify_at"`
	// contains filtered or unexported fields
}

数据库 账号信息

func (*Account) Descriptor deprecated 

func (*Account) Descriptor() ([]byte, []int)

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetAccountPrivilege 

func (x *Account) GetAccountPrivilege() string

func (*Account) GetAccountPrivilegeDetail 

func (x *Account) GetAccountPrivilegeDetail() string

func (*Account) GetCreateAt 

func (x *Account) GetCreateAt() int64

func (*Account) GetDescription 

func (x *Account) GetDescription() string

func (*Account) GetModifyAt 

func (x *Account) GetModifyAt() int64

func (*Account) GetName 

func (x *Account) GetName() string

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) ProtoReflect 

func (x *Account) ProtoReflect() protoreflect.Message

func (*Account) Reset 

func (x *Account) Reset()

func (*Account) String 

func (x *Account) String() string

type ConnectionAddr 

type ConnectionAddr struct {

	// 连接地址类型, 内网链接/公网链接
	// @gotags: json:"type"
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type"`
	// 连接地址
	// @gotags: json:"host"
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host"`
	// 连接端口
	// @gotags: json:"port"
	Port int64 `protobuf:"varint,3,opt,name=port,proto3" json:"port"`
	// contains filtered or unexported fields
}

数据库 连接地址

func (*ConnectionAddr) Descriptor deprecated 

func (*ConnectionAddr) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionAddr.ProtoReflect.Descriptor instead.

func (*ConnectionAddr) GetHost 

func (x *ConnectionAddr) GetHost() string

func (*ConnectionAddr) GetPort 

func (x *ConnectionAddr) GetPort() int64

func (*ConnectionAddr) GetType 

func (x *ConnectionAddr) GetType() string

func (*ConnectionAddr) ProtoMessage 

func (*ConnectionAddr) ProtoMessage()

func (*ConnectionAddr) ProtoReflect 

func (x *ConnectionAddr) ProtoReflect() protoreflect.Message

func (*ConnectionAddr) Reset 

func (x *ConnectionAddr) Reset()

func (*ConnectionAddr) String 

func (x *ConnectionAddr) String() string

type Database 

type Database struct {

	// 数据库 库的名称
	// @gotags: json:"name"
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	// 数据库实例类型
	// @gotags: json:"engine"
	Engine string `protobuf:"bytes,2,opt,name=engine,proto3" json:"engine"`
	// 数据库状态
	// @gotags: json:"status"
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status"`
	// 字符集
	// @gotags: json:"character_set"
	CharacterSet string `protobuf:"bytes,4,opt,name=character_set,json=characterSet,proto3" json:"character_set"`
	// 数据库描述
	// @gotags: json:"description"
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description"`
	// 数据库账号
	// @gotags: json:"accounts"
	Accounts []*Account `protobuf:"bytes,6,rep,name=accounts,proto3" json:"accounts"`
	// contains filtered or unexported fields
}

func (*Database) Descriptor deprecated 

func (*Database) Descriptor() ([]byte, []int)

Deprecated: Use Database.ProtoReflect.Descriptor instead.

func (*Database) GetAccounts 

func (x *Database) GetAccounts() []*Account

func (*Database) GetCharacterSet 

func (x *Database) GetCharacterSet() string

func (*Database) GetDescription 

func (x *Database) GetDescription() string

func (*Database) GetEngine 

func (x *Database) GetEngine() string

func (*Database) GetName 

func (x *Database) GetName() string

func (*Database) GetStatus 

func (x *Database) GetStatus() string

func (*Database) ProtoMessage 

func (*Database) ProtoMessage()

func (*Database) ProtoReflect 

func (x *Database) ProtoReflect() protoreflect.Message

func (*Database) Reset 

func (x *Database) Reset()

func (*Database) String 

func (x *Database) String() string

type Describe 

type Describe struct {

	// 引擎 比如 MYSQL, SQLServer, PGSQL
	// @gotags: json:"engine_type"
	EngineType string `protobuf:"bytes,1,opt,name=engine_type,json=engineType,proto3" json:"engine_type"`
	// 引擎版本
	// @gotags: json:"engine_version"
	EngineVersion string `protobuf:"bytes,2,opt,name=engine_version,json=engineVersion,proto3" json:"engine_version"`
	// 实例规格: 对应ALI(DBInstanceClass)
	// @gotags: json:"instance_class"
	InstanceClass string `protobuf:"bytes,3,opt,name=instance_class,json=instanceClass,proto3" json:"instance_class"`
	// 实例规格族，取值：s：共享型；x：通用型；d：独享套餐；h：独占物理机。
	// @gotags: json:"class_type"
	ClassType string `protobuf:"bytes,4,opt,name=class_type,json=classType,proto3" json:"class_type"`
	// 实例是内网或外网 (Internet：外网/Intranet：内网)
	// @gotags: json:"export_type"
	ExportType string `protobuf:"bytes,5,opt,name=export_type,json=exportType,proto3" json:"export_type"`
	// 实例的网络类型 (Classic：经典网络/VPC：专有网络。)
	// @gotags: json:"network_type"
	NetworkType string `protobuf:"bytes,6,opt,name=network_type,json=networkType,proto3" json:"network_type"`
	// 实例类型 Primary：主实例, Readonly：只读实例, Guard：灾备实例, Temp：临时实例
	// @gotags: json:"type"
	Type string `protobuf:"bytes,7,opt,name=type,proto3" json:"type"`
	// 一个实例下可创建最大数据库数量
	// @gotags: json:"db_max_quantity"
	DbMaxQuantity int64 `protobuf:"varint,8,opt,name=db_max_quantity,json=dbMaxQuantity,proto3" json:"db_max_quantity"`
	// 可创建账号的最大数量
	// @gotags: json:"account_max_quantity"
	AccountMaxQuantity int64 `protobuf:"varint,9,opt,name=account_max_quantity,json=accountMaxQuantity,proto3" json:"account_max_quantity"`
	// 最大并发连接数
	// @gotags: json:"max_connections"
	MaxConnections int64 `protobuf:"varint,10,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections"`
	// 最大每秒IO请求次数
	// @gotags: json:"max_iops"
	MaxIops int64 `protobuf:"varint,11,opt,name=max_iops,json=maxIops,proto3" json:"max_iops"`
	// 系统字符集排序规则
	// @gotags: json:"collation"
	Collation string `protobuf:"bytes,12,opt,name=collation,proto3" json:"collation"`
	// 时区
	// @gotags: json:"time_zone"
	TimeZone string `protobuf:"bytes,13,opt,name=time_zone,json=timeZone,proto3" json:"time_zone"`
	// 实例储存类型 local_ssd/ephemeral_ssd：本地SSD盘, cloud_ssd：SSD云盘；cloud_essd：ESSD云盘
	// @gotags: json:"storage_type"
	StorageType string `protobuf:"bytes,14,opt,name=storage_type,json=storageType,proto3" json:"storage_type"`
	// 安全名单模式, 默认白名单
	// @gotags: json:"security_ip_mode"
	SecurityIpMode string `protobuf:"bytes,15,opt,name=security_ip_mode,json=securityIpMode,proto3" json:"security_ip_mode"`
	// IP白名单
	// @gotags: json:"security_ip_list"
	SecurityIpList []string `protobuf:"bytes,16,rep,name=security_ip_list,json=securityIpList,proto3" json:"security_ip_list"`
	// 实例的访问模式，取值：Standard：标准访问模式；Safe：数据库代理模式。
	// @gotags: json:"connection_mode"
	ConnectionMode string `protobuf:"bytes,17,opt,name=connection_mode,json=connectionMode,proto3" json:"connection_mode"`
	// IP类型
	// @gotags: json:"ip_type"
	IpType string `protobuf:"bytes,18,opt,name=ip_type,json=ipType,proto3" json:"ip_type"`
	// 部署模式(腾讯云独有)
	// @gotags: json:"deploy_mode"
	DeployMode string `protobuf:"bytes,21,opt,name=deploy_mode,json=deployMode,proto3" json:"deploy_mode"`
	// 端口
	// @gotags: json:"port"
	Port int64 `protobuf:"varint,22,opt,name=port,proto3" json:"port"`
	// 额外的无法通用的一些属性, 比如只有腾讯云独有的一些属性
	// @gotags: json:"extra"
	Extra map[string]string `` /* 142-byte string literal not displayed */
	// 实例链接地址
	// @gotags: json:"connection_addr"
	ConnectionAddr []*ConnectionAddr `protobuf:"bytes,28,rep,name=connection_addr,json=connectionAddr,proto3" json:"connection_addr"`
	// 数据库
	// @gotags: json:"databases"
	Databases []*Database `protobuf:"bytes,29,rep,name=databases,proto3" json:"databases"`
	// contains filtered or unexported fields
}

func (*Describe) Descriptor deprecated 

func (*Describe) Descriptor() ([]byte, []int)

Deprecated: Use Describe.ProtoReflect.Descriptor instead.

func (*Describe) ExtraToJson 

func (d *Describe) ExtraToJson() string

func (*Describe) GetAccountMaxQuantity 

func (x *Describe) GetAccountMaxQuantity() int64

func (*Describe) GetClassType 

func (x *Describe) GetClassType() string

func (*Describe) GetCollation 

func (x *Describe) GetCollation() string

func (*Describe) GetConnectionAddr 

func (x *Describe) GetConnectionAddr() []*ConnectionAddr

func (*Describe) GetConnectionMode 

func (x *Describe) GetConnectionMode() string

func (*Describe) GetDatabases 

func (x *Describe) GetDatabases() []*Database

func (*Describe) GetDbMaxQuantity 

func (x *Describe) GetDbMaxQuantity() int64

func (*Describe) GetDeployMode 

func (x *Describe) GetDeployMode() string

func (*Describe) GetEngineType 

func (x *Describe) GetEngineType() string

func (*Describe) GetEngineVersion 

func (x *Describe) GetEngineVersion() string

func (*Describe) GetExportType 

func (x *Describe) GetExportType() string

func (*Describe) GetExtra 

func (x *Describe) GetExtra() map[string]string

func (*Describe) GetInstanceClass 

func (x *Describe) GetInstanceClass() string

func (*Describe) GetIpType 

func (x *Describe) GetIpType() string

func (*Describe) GetMaxConnections 

func (x *Describe) GetMaxConnections() int64

func (*Describe) GetMaxIops 

func (x *Describe) GetMaxIops() int64

func (*Describe) GetNetworkType 

func (x *Describe) GetNetworkType() string

func (*Describe) GetPort 

func (x *Describe) GetPort() int64

func (*Describe) GetSecurityIpList 

func (x *Describe) GetSecurityIpList() []string

func (*Describe) GetSecurityIpMode 

func (x *Describe) GetSecurityIpMode() string

func (*Describe) GetStorageType 

func (x *Describe) GetStorageType() string

func (*Describe) GetTimeZone 

func (x *Describe) GetTimeZone() string

func (*Describe) GetType 

func (x *Describe) GetType() string

func (*Describe) ProtoMessage 

func (*Describe) ProtoMessage()

func (*Describe) ProtoReflect 

func (x *Describe) ProtoReflect() protoreflect.Message

func (*Describe) Reset 

func (x *Describe) Reset()

func (*Describe) SecurityIpListToString 

func (d *Describe) SecurityIpListToString() string

func (*Describe) String 

func (x *Describe) String() string

type QueryRDSRequest 

type QueryRDSRequest struct {

	// 分页参数
	// @gotags: json:"page"
	Page *request.PageRequest `protobuf:"bytes,1,opt,name=page,proto3" json:"page"`
	// contains filtered or unexported fields
}

func (*QueryRDSRequest) Descriptor deprecated 

func (*QueryRDSRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryRDSRequest.ProtoReflect.Descriptor instead.

func (*QueryRDSRequest) GetPage 

func (x *QueryRDSRequest) GetPage() *request.PageRequest

func (*QueryRDSRequest) ProtoMessage 

func (*QueryRDSRequest) ProtoMessage()

func (*QueryRDSRequest) ProtoReflect 

func (x *QueryRDSRequest) ProtoReflect() protoreflect.Message

func (*QueryRDSRequest) Reset 

func (x *QueryRDSRequest) Reset()

func (*QueryRDSRequest) String 

func (x *QueryRDSRequest) String() string

type Rds 

type Rds struct {

	// @gotags: json:"resource"
	Resource *resource.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource"`
	// Rds描述信息
	// @gotags: json:"describe"
	Describe *Describe `protobuf:"bytes,2,opt,name=describe,proto3" json:"describe"`
	// contains filtered or unexported fields
}

func NewDefaultRDS 

func NewDefaultRDS() *Rds

func (*Rds) Descriptor deprecated 

func (*Rds) Descriptor() ([]byte, []int)

Deprecated: Use Rds.ProtoReflect.Descriptor instead.

func (*Rds) GenHash 

func (r *Rds) GenHash() error

func (*Rds) GetDescribe 

func (x *Rds) GetDescribe() *Describe

func (*Rds) GetResource 

func (x *Rds) GetResource() *resource.Resource

func (*Rds) ProtoMessage 

func (*Rds) ProtoMessage()

func (*Rds) ProtoReflect 

func (x *Rds) ProtoReflect() protoreflect.Message

func (*Rds) Reset 

func (x *Rds) Reset()

func (*Rds) ShortDesc 

func (r *Rds) ShortDesc() string

func (*Rds) String 

func (x *Rds) String() string

type RdsSet 

type RdsSet struct {

	// 总数量
	// @gotags: json:"total"
	Total int64 `protobuf:"varint,1,opt,name=total,proto3" json:"total"`
	// 列表项
	// @gotags: json:"items"
	Items []*Rds `protobuf:"bytes,2,rep,name=items,proto3" json:"items"`
	// contains filtered or unexported fields
}

func NewSet 

func NewSet() *RdsSet

func (*RdsSet) Add 

func (s *RdsSet) Add(items ...any)

func (*RdsSet) AddSet 

func (s *RdsSet) AddSet(set *RdsSet)

func (*RdsSet) Descriptor deprecated 

func (*RdsSet) Descriptor() ([]byte, []int)

Deprecated: Use RdsSet.ProtoReflect.Descriptor instead.

func (*RdsSet) GetItems 

func (x *RdsSet) GetItems() []*Rds

func (*RdsSet) GetTotal 

func (x *RdsSet) GetTotal() int64

func (*RdsSet) Length 

func (s *RdsSet) Length() int64

func (*RdsSet) ProtoMessage 

func (*RdsSet) ProtoMessage()

func (*RdsSet) ProtoReflect 

func (x *RdsSet) ProtoReflect() protoreflect.Message

func (*RdsSet) Reset 

func (x *RdsSet) Reset()

func (*RdsSet) String 

func (x *RdsSet) String() string

func (*RdsSet) ToAny 

func (s *RdsSet) ToAny() (items []any)

type STATUS 

type STATUS int32
const (
	// 未知状态
	STATUS_UNKNOW STATUS = 0
	// 表示创建中
	STATUS_PENDING STATUS = 5
	// 表示创建失败
	STATUS_CREATE_FAILED STATUS = 6
	// 表示运行中
	STATUS_RUNNING STATUS = 11
	// 实例配置变更生效中
	STATUS_MODIFYING STATUS = 20
	// 表示重启中
	STATUS_REBOOTING STATUS = 30
	// 备份恢复中
	STATUS_RESTORING STATUS = 31
	// 迁移中
	STATUS_TRANSING STATUS = 32
	// 数据导入中
	STATUS_IMPORTING STATUS = 33
	// 实例克隆中
	STATUS_CLONING STATUS = 34
	// 迁移版本中
	STATUS_UPGRADING STATUS = 35
	// 表示实例正在进行备份
	STATUS_BACKING_UP STATUS = 36
	// 内外网切换中
	STATUS_NET_CHANGING STATUS = 37
	// 表示实例正在主备切换
	STATUS_SWITCHOVER STATUS = 40
	// 灾备实例创建同步中
	STATUS_GUARD_CREATING STATUS = 41
	// 状态异常
	STATUS_ERROR STATUS = 50
	// 表示实例磁盘空间满
	STATUS_STORAGE_FULL STATUS = 51
	// 表示实例已经锁定
	STATUS_LOCKED STATUS = 70
	// 隔离中
	STATUS_ISOLATIONING STATUS = 71
	// 已隔中
	STATUS_ISOLATIONED STATUS = 72
	// 表示停止待销毁
	STATUS_SHUTDOWN STATUS = 80
	// 表示销毁中
	STATUS_DELETING STATUS = 81
	// 已销毁
	STATUS_DESTROYED STATUS = 90
)

func ParseSTATUSFromString 

func ParseSTATUSFromString(str string) (STATUS, error)

ParseSTATUSFromString Parse STATUS from string

func (STATUS) Descriptor 

func (STATUS) Descriptor() protoreflect.EnumDescriptor

func (STATUS) Enum 

func (x STATUS) Enum() *STATUS

func (STATUS) EnumDescriptor deprecated 

func (STATUS) EnumDescriptor() ([]byte, []int)

Deprecated: Use STATUS.Descriptor instead.

func (STATUS) Equal 

func (t STATUS) Equal(target STATUS) bool

Equal type compare

func (STATUS) IsIn 

func (t STATUS) IsIn(targets ...STATUS) bool

IsIn todo

func (STATUS) MarshalJSON 

func (t STATUS) MarshalJSON() ([]byte, error)

MarshalJSON todo

func (STATUS) Number 

func (x STATUS) Number() protoreflect.EnumNumber

func (STATUS) String 

func (x STATUS) String() string

func (STATUS) Type 

func (STATUS) Type() protoreflect.EnumType

func (*STATUS) UnmarshalJSON 

func (t *STATUS) UnmarshalJSON(b []byte) error

UnmarshalJSON todo

type ServiceClient 

type ServiceClient interface {
	SyncRDS(ctx context.Context, in *Rds, opts ...grpc.CallOption) (*Rds, error)
	QueryRDS(ctx context.Context, in *QueryRDSRequest, opts ...grpc.CallOption) (*RdsSet, 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 {
	SyncRDS(context.Context, *Rds) (*Rds, error)
	QueryRDS(context.Context, *QueryRDSRequest) (*RdsSet, 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) QueryRDS 

func (UnimplementedServiceServer) QueryRDS(context.Context, *QueryRDSRequest) (*RdsSet, error)

func (UnimplementedServiceServer) SyncRDS 

func (UnimplementedServiceServer) SyncRDS(context.Context, *Rds) (*Rds, error)

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.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.