notify

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App 

type App struct {
	//
	//应用名
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" form:"name"`
	//
	//实例id
	InstanceId           string   `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

应用信息(name,instanceId)

func (*App) Descriptor 

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

func (*App) GetInstanceId 

func (m *App) GetInstanceId() string

func (*App) GetName 

func (m *App) GetName() string

func (*App) ProtoMessage 

func (*App) ProtoMessage()

func (*App) Reset 

func (m *App) Reset()

func (*App) String 

func (m *App) String() string

func (*App) Validate 

func (this *App) Validate() error

func (*App) XXX_DiscardUnknown 

func (m *App) XXX_DiscardUnknown()

func (*App) XXX_Marshal 

func (m *App) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*App) XXX_Merge 

func (m *App) XXX_Merge(src proto.Message)

func (*App) XXX_Size 

func (m *App) XXX_Size() int

func (*App) XXX_Unmarshal 

func (m *App) XXX_Unmarshal(b []byte) error

type DeployInfo 

type DeployInfo struct {
	//
	//应用部署方式
	From                 string   `protobuf:"bytes,1,opt,name=from,proto3" json:"from" form:"from"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

部署信息

func (*DeployInfo) Descriptor 

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

func (*DeployInfo) GetFrom 

func (m *DeployInfo) GetFrom() string

func (*DeployInfo) ProtoMessage 

func (*DeployInfo) ProtoMessage()

func (*DeployInfo) Reset 

func (m *DeployInfo) Reset()

func (*DeployInfo) String 

func (m *DeployInfo) String() string

func (*DeployInfo) Validate 

func (this *DeployInfo) Validate() error

func (*DeployInfo) XXX_DiscardUnknown 

func (m *DeployInfo) XXX_DiscardUnknown()

func (*DeployInfo) XXX_Marshal 

func (m *DeployInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeployInfo) XXX_Merge 

func (m *DeployInfo) XXX_Merge(src proto.Message)

func (*DeployInfo) XXX_Size 

func (m *DeployInfo) XXX_Size() int

func (*DeployInfo) XXX_Unmarshal 

func (m *DeployInfo) XXX_Unmarshal(b []byte) error

type Device 

type Device struct {
	//
	//ip
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip" form:"ip"`
	//
	//实例id
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//事件目标id
	TargetId string `protobuf:"bytes,3,opt,name=targetId,proto3" json:"targetId" form:"targetId"`
	//
	//事件目标名称
	TargetName           string   `protobuf:"bytes,4,opt,name=targetName,proto3" json:"targetName" form:"targetName"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

主机信息(ip,instanceId)

func (*Device) Descriptor 

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

func (*Device) GetInstanceId 

func (m *Device) GetInstanceId() string

func (*Device) GetIp 

func (m *Device) GetIp() string

func (*Device) GetTargetId 

func (m *Device) GetTargetId() string

func (*Device) GetTargetName 

func (m *Device) GetTargetName() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) String 

func (m *Device) String() string

func (*Device) Validate 

func (this *Device) Validate() error

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Device) XXX_Merge 

func (m *Device) XXX_Merge(src proto.Message)

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

func (m *Device) XXX_Unmarshal(b []byte) error

type ListOperationLogRequest 

type ListOperationLogRequest struct {
	//
	//page
	Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page" form:"page"`
	//
	//pageSize
	PageSize int32 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize" form:"pageSize"`
	//
	//系统名称
	System string `protobuf:"bytes,3,opt,name=system,proto3" json:"system" form:"system"`
	//
	//目标名称(工具名/流程名/对象名/实例名)
	TargetName string `protobuf:"bytes,4,opt,name=target_name,json=targetName,proto3" json:"target_name" form:"target_name"`
	//
	//目标分组
	TargetCategory string `protobuf:"bytes,5,opt,name=target_category,json=targetCategory,proto3" json:"target_category" form:"target_category"`
	//
	//目标名称
	TargetId string `protobuf:"bytes,6,opt,name=target_id,json=targetId,proto3" json:"target_id" form:"target_id"`
	//
	//事件id
	EventId string `protobuf:"bytes,7,opt,name=event_id,json=eventId,proto3" json:"event_id" form:"event_id"`
	//
	//父事件id
	ParentEventId string `protobuf:"bytes,8,opt,name=parent_event_id,json=parentEventId,proto3" json:"parent_event_id" form:"parent_event_id"`
	//
	//事件状态
	Status string `protobuf:"bytes,9,opt,name=status,proto3" json:"status" form:"status"`
	//
	//操作人
	Operator string `protobuf:"bytes,10,opt,name=operator,proto3" json:"operator" form:"operator"`
	//
	//事件名称
	Event string `protobuf:"bytes,11,opt,name=event,proto3" json:"event" form:"event"`
	//
	//排除事件名称
	ExcludeEvent string `protobuf:"bytes,12,opt,name=exclude_event,json=excludeEvent,proto3" json:"exclude_event" form:"exclude_event"`
	//
	//排除的系统名称
	ExcludeSystem string `protobuf:"bytes,13,opt,name=exclude_system,json=excludeSystem,proto3" json:"exclude_system" form:"exclude_system"`
	//
	//关联的设备ip
	DeviceIp string `protobuf:"bytes,14,opt,name=device_ip,json=deviceIp,proto3" json:"device_ip" form:"device_ip"`
	//
	//关联的设备id
	DeviceId string `protobuf:"bytes,15,opt,name=device_id,json=deviceId,proto3" json:"device_id" form:"device_id"`
	//
	//应用id
	AppId string `protobuf:"bytes,16,opt,name=app_id,json=appId,proto3" json:"app_id" form:"app_id"`
	//
	//应用名称
	AppName string `protobuf:"bytes,17,opt,name=app_name,json=appName,proto3" json:"app_name" form:"app_name"`
	//
	//事件备注
	Memo string `protobuf:"bytes,18,opt,name=memo,proto3" json:"memo" form:"memo"`
	//
	//是否查询子事件（true查询子事件，false不查询子时间，默认false)
	WithChildren bool `protobuf:"varint,19,opt,name=with_children,json=withChildren,proto3" json:"with_children" form:"with_children"`
	//
	//通知相关人（包含operator和notifier)
	User string `protobuf:"bytes,20,opt,name=user,proto3" json:"user" form:"user"`
	//
	//开始时间
	StartTime string `protobuf:"bytes,21,opt,name=start_time,json=startTime,proto3" json:"start_time" form:"start_time"`
	//
	//截止时间
	EndTime string `protobuf:"bytes,22,opt,name=end_time,json=endTime,proto3" json:"end_time" form:"end_time"`
	//
	//是否不需要查询总数
	WithoutTotal string `protobuf:"bytes,23,opt,name=without_total,json=withoutTotal,proto3" json:"without_total" form:"without_total"`
	//
	//topic
	Topic string `protobuf:"bytes,24,opt,name=topic,proto3" json:"topic" form:"topic"`
	//
	//query
	Query string `protobuf:"bytes,25,opt,name=query,proto3" json:"query" form:"query"`
	//
	//business
	Business string `protobuf:"bytes,26,opt,name=business,proto3" json:"business" form:"business"`
	//
	//ctime_order
	CtimeOrder string `protobuf:"bytes,27,opt,name=ctime_order,json=ctimeOrder,proto3" json:"ctime_order" form:"ctime_order"`
	//
	//应用id列表
	AppIdList            string   `protobuf:"bytes,28,opt,name=app_id_list,json=appIdList,proto3" json:"app_id_list" form:"app_id_list"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

list op log request

func (*ListOperationLogRequest) Descriptor 

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

func (*ListOperationLogRequest) GetAppId 

func (m *ListOperationLogRequest) GetAppId() string

func (*ListOperationLogRequest) GetAppIdList 

func (m *ListOperationLogRequest) GetAppIdList() string

func (*ListOperationLogRequest) GetAppName 

func (m *ListOperationLogRequest) GetAppName() string

func (*ListOperationLogRequest) GetBusiness 

func (m *ListOperationLogRequest) GetBusiness() string

func (*ListOperationLogRequest) GetCtimeOrder 

func (m *ListOperationLogRequest) GetCtimeOrder() string

func (*ListOperationLogRequest) GetDeviceId 

func (m *ListOperationLogRequest) GetDeviceId() string

func (*ListOperationLogRequest) GetDeviceIp 

func (m *ListOperationLogRequest) GetDeviceIp() string

func (*ListOperationLogRequest) GetEndTime 

func (m *ListOperationLogRequest) GetEndTime() string

func (*ListOperationLogRequest) GetEvent 

func (m *ListOperationLogRequest) GetEvent() string

func (*ListOperationLogRequest) GetEventId 

func (m *ListOperationLogRequest) GetEventId() string

func (*ListOperationLogRequest) GetExcludeEvent 

func (m *ListOperationLogRequest) GetExcludeEvent() string

func (*ListOperationLogRequest) GetExcludeSystem 

func (m *ListOperationLogRequest) GetExcludeSystem() string

func (*ListOperationLogRequest) GetMemo 

func (m *ListOperationLogRequest) GetMemo() string

func (*ListOperationLogRequest) GetOperator 

func (m *ListOperationLogRequest) GetOperator() string

func (*ListOperationLogRequest) GetPage 

func (m *ListOperationLogRequest) GetPage() int32

func (*ListOperationLogRequest) GetPageSize 

func (m *ListOperationLogRequest) GetPageSize() int32

func (*ListOperationLogRequest) GetParentEventId 

func (m *ListOperationLogRequest) GetParentEventId() string

func (*ListOperationLogRequest) GetQuery 

func (m *ListOperationLogRequest) GetQuery() string

func (*ListOperationLogRequest) GetStartTime 

func (m *ListOperationLogRequest) GetStartTime() string

func (*ListOperationLogRequest) GetStatus 

func (m *ListOperationLogRequest) GetStatus() string

func (*ListOperationLogRequest) GetSystem 

func (m *ListOperationLogRequest) GetSystem() string

func (*ListOperationLogRequest) GetTargetCategory 

func (m *ListOperationLogRequest) GetTargetCategory() string

func (*ListOperationLogRequest) GetTargetId 

func (m *ListOperationLogRequest) GetTargetId() string

func (*ListOperationLogRequest) GetTargetName 

func (m *ListOperationLogRequest) GetTargetName() string

func (*ListOperationLogRequest) GetTopic 

func (m *ListOperationLogRequest) GetTopic() string

func (*ListOperationLogRequest) GetUser 

func (m *ListOperationLogRequest) GetUser() string

func (*ListOperationLogRequest) GetWithChildren 

func (m *ListOperationLogRequest) GetWithChildren() bool

func (*ListOperationLogRequest) GetWithoutTotal 

func (m *ListOperationLogRequest) GetWithoutTotal() string

func (*ListOperationLogRequest) ProtoMessage 

func (*ListOperationLogRequest) ProtoMessage()

func (*ListOperationLogRequest) Reset 

func (m *ListOperationLogRequest) Reset()

func (*ListOperationLogRequest) String 

func (m *ListOperationLogRequest) String() string

func (*ListOperationLogRequest) Validate 

func (this *ListOperationLogRequest) Validate() error

func (*ListOperationLogRequest) XXX_DiscardUnknown 

func (m *ListOperationLogRequest) XXX_DiscardUnknown()

func (*ListOperationLogRequest) XXX_Marshal 

func (m *ListOperationLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListOperationLogRequest) XXX_Merge 

func (m *ListOperationLogRequest) XXX_Merge(src proto.Message)

func (*ListOperationLogRequest) XXX_Size 

func (m *ListOperationLogRequest) XXX_Size() int

func (*ListOperationLogRequest) XXX_Unmarshal 

func (m *ListOperationLogRequest) XXX_Unmarshal(b []byte) error

type OperationLog 

type OperationLog struct {
	//
	//系统名称
	System string `protobuf:"bytes,1,opt,name=system,proto3" json:"system" form:"system"`
	//
	//topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic" form:"topic"`
	//
	//事件id
	EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id" form:"event_id"`
	//
	//父事件id
	ParentEventId string `protobuf:"bytes,4,opt,name=parent_event_id,json=parentEventId,proto3" json:"parent_event_id" form:"parent_event_id"`
	//
	//父事件
	ParentEvent *OperationLog `protobuf:"bytes,5,opt,name=parent_event,json=parentEvent,proto3" json:"parent_event" form:"parent_event"`
	//
	//事件名称
	Event string `protobuf:"bytes,6,opt,name=event,proto3" json:"event" form:"event"`
	//
	//事件状态
	Status string `protobuf:"bytes,7,opt,name=status,proto3" json:"status" form:"status"`
	//
	//设备列表
	DeviceList []*Device `protobuf:"bytes,8,rep,name=device_list,json=deviceList,proto3" json:"device_list" form:"device_list"`
	//
	//操作人
	Operator string `protobuf:"bytes,9,opt,name=operator,proto3" json:"operator" form:"operator"`
	//
	//目标名称(工具名/流程名/对象名/实例名)
	TargetName string `protobuf:"bytes,10,opt,name=target_name,json=targetName,proto3" json:"target_name" form:"target_name"`
	//
	//目标名称
	TargetId string `protobuf:"bytes,11,opt,name=target_id,json=targetId,proto3" json:"target_id" form:"target_id"`
	//
	//目标分类
	TargetCategory string `protobuf:"bytes,12,opt,name=target_category,json=targetCategory,proto3" json:"target_category" form:"target_category"`
	//
	//app
	AppList []*App `protobuf:"bytes,13,rep,name=app_list,json=appList,proto3" json:"app_list" form:"app_list"`
	//
	//ext_info
	ExtInfo *types.Struct `protobuf:"bytes,14,opt,name=ext_info,json=extInfo,proto3" json:"ext_info" form:"ext_info"`
	//
	//notifiers
	Notifiers []string `protobuf:"bytes,15,rep,name=notifiers,proto3" json:"notifiers" form:"notifiers"`
	//
	//trigger
	Trigger string `protobuf:"bytes,16,opt,name=trigger,proto3" json:"trigger" form:"trigger"`
	//
	//memo
	Memo string `protobuf:"bytes,17,opt,name=memo,proto3" json:"memo" form:"memo"`
	//
	//关联应用id
	AppId string `protobuf:"bytes,18,opt,name=app_id,json=appId,proto3" json:"app_id" form:"app_id"`
	//
	//关联集群id
	ClusterId string `protobuf:"bytes,19,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id" form:"cluster_id"`
	//
	//关联包id
	PackageId string `protobuf:"bytes,20,opt,name=package_id,json=packageId,proto3" json:"package_id" form:"package_id"`
	//
	//关联包名称
	PackageName string `protobuf:"bytes,21,opt,name=package_name,json=packageName,proto3" json:"package_name" form:"package_name"`
	//
	//version_id
	VersionId string `protobuf:"bytes,22,opt,name=version_id,json=versionId,proto3" json:"version_id" form:"version_id"`
	//
	//version_name
	VersionName string `protobuf:"bytes,23,opt,name=version_name,json=versionName,proto3" json:"version_name" form:"version_name"`
	//
	//deploy_info
	DeployInfo *DeployInfo `protobuf:"bytes,24,opt,name=deploy_info,json=deployInfo,proto3" json:"deploy_info" form:"deploy_info"`
	//
	//content
	Content string `protobuf:"bytes,25,opt,name=content,proto3" json:"content" form:"content"`
	//
	//data_name
	DataName string `protobuf:"bytes,26,opt,name=data_name,json=dataName,proto3" json:"data_name" form:"data_name"`
	//
	//ip
	Ip string `protobuf:"bytes,27,opt,name=ip,proto3" json:"ip" form:"ip"`
	//
	//ip_list
	IpList []string `protobuf:"bytes,28,rep,name=ip_list,json=ipList,proto3" json:"ip_list" form:"ip_list"`
	//
	//subject
	Subject string `protobuf:"bytes,29,opt,name=subject,proto3" json:"subject" form:"subject"`
	//
	//修改时间
	Mtime int64 `protobuf:"varint,30,opt,name=mtime,proto3" json:"mtime" form:"mtime"`
	//
	//创建时间
	Ctime                int64    `protobuf:"varint,31,opt,name=ctime,proto3" json:"ctime" form:"ctime"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

返回数据中具体一条日志

func (*OperationLog) Descriptor 

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

func (*OperationLog) GetAppId 

func (m *OperationLog) GetAppId() string

func (*OperationLog) GetAppList 

func (m *OperationLog) GetAppList() []*App

func (*OperationLog) GetClusterId 

func (m *OperationLog) GetClusterId() string

func (*OperationLog) GetContent 

func (m *OperationLog) GetContent() string

func (*OperationLog) GetCtime 

func (m *OperationLog) GetCtime() int64

func (*OperationLog) GetDataName 

func (m *OperationLog) GetDataName() string

func (*OperationLog) GetDeployInfo 

func (m *OperationLog) GetDeployInfo() *DeployInfo

func (*OperationLog) GetDeviceList 

func (m *OperationLog) GetDeviceList() []*Device

func (*OperationLog) GetEvent 

func (m *OperationLog) GetEvent() string

func (*OperationLog) GetEventId 

func (m *OperationLog) GetEventId() string

func (*OperationLog) GetExtInfo 

func (m *OperationLog) GetExtInfo() *types.Struct

func (*OperationLog) GetIp 

func (m *OperationLog) GetIp() string

func (*OperationLog) GetIpList 

func (m *OperationLog) GetIpList() []string

func (*OperationLog) GetMemo 

func (m *OperationLog) GetMemo() string

func (*OperationLog) GetMtime 

func (m *OperationLog) GetMtime() int64

func (*OperationLog) GetNotifiers 

func (m *OperationLog) GetNotifiers() []string

func (*OperationLog) GetOperator 

func (m *OperationLog) GetOperator() string

func (*OperationLog) GetPackageId 

func (m *OperationLog) GetPackageId() string

func (*OperationLog) GetPackageName 

func (m *OperationLog) GetPackageName() string

func (*OperationLog) GetParentEvent 

func (m *OperationLog) GetParentEvent() *OperationLog

func (*OperationLog) GetParentEventId 

func (m *OperationLog) GetParentEventId() string

func (*OperationLog) GetStatus 

func (m *OperationLog) GetStatus() string

func (*OperationLog) GetSubject 

func (m *OperationLog) GetSubject() string

func (*OperationLog) GetSystem 

func (m *OperationLog) GetSystem() string

func (*OperationLog) GetTargetCategory 

func (m *OperationLog) GetTargetCategory() string

func (*OperationLog) GetTargetId 

func (m *OperationLog) GetTargetId() string

func (*OperationLog) GetTargetName 

func (m *OperationLog) GetTargetName() string

func (*OperationLog) GetTopic 

func (m *OperationLog) GetTopic() string

func (*OperationLog) GetTrigger 

func (m *OperationLog) GetTrigger() string

func (*OperationLog) GetVersionId 

func (m *OperationLog) GetVersionId() string

func (*OperationLog) GetVersionName 

func (m *OperationLog) GetVersionName() string

func (*OperationLog) ProtoMessage 

func (*OperationLog) ProtoMessage()

func (*OperationLog) Reset 

func (m *OperationLog) Reset()

func (*OperationLog) String 

func (m *OperationLog) String() string

func (*OperationLog) Validate 

func (this *OperationLog) Validate() error

func (*OperationLog) XXX_DiscardUnknown 

func (m *OperationLog) XXX_DiscardUnknown()

func (*OperationLog) XXX_Marshal 

func (m *OperationLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperationLog) XXX_Merge 

func (m *OperationLog) XXX_Merge(src proto.Message)

func (*OperationLog) XXX_Size 

func (m *OperationLog) XXX_Size() int

func (*OperationLog) XXX_Unmarshal 

func (m *OperationLog) XXX_Unmarshal(b []byte) error

type OperationLogWithMeta 

type OperationLogWithMeta struct {
	//
	//系统名称
	System string `protobuf:"bytes,1,opt,name=system,proto3" json:"system" form:"system"`
	//
	//topic
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic" form:"topic"`
	//
	//OperationLog
	Data                 *OperationLog `protobuf:"bytes,3,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

带有系统名称和topic的operation log

func (*OperationLogWithMeta) Descriptor 

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

func (*OperationLogWithMeta) GetData 

func (m *OperationLogWithMeta) GetData() *OperationLog

func (*OperationLogWithMeta) GetSystem 

func (m *OperationLogWithMeta) GetSystem() string

func (*OperationLogWithMeta) GetTopic 

func (m *OperationLogWithMeta) GetTopic() string

func (*OperationLogWithMeta) ProtoMessage 

func (*OperationLogWithMeta) ProtoMessage()

func (*OperationLogWithMeta) Reset 

func (m *OperationLogWithMeta) Reset()

func (*OperationLogWithMeta) String 

func (m *OperationLogWithMeta) String() string

func (*OperationLogWithMeta) Validate 

func (this *OperationLogWithMeta) Validate() error

func (*OperationLogWithMeta) XXX_DiscardUnknown 

func (m *OperationLogWithMeta) XXX_DiscardUnknown()

func (*OperationLogWithMeta) XXX_Marshal 

func (m *OperationLogWithMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperationLogWithMeta) XXX_Merge 

func (m *OperationLogWithMeta) XXX_Merge(src proto.Message)

func (*OperationLogWithMeta) XXX_Size 

func (m *OperationLogWithMeta) XXX_Size() int

func (*OperationLogWithMeta) XXX_Unmarshal 

func (m *OperationLogWithMeta) XXX_Unmarshal(b []byte) error

type PubSubscriber 

type PubSubscriber struct {
	//
	//订阅ID
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//订阅负责人。如 linus
	Admin string `protobuf:"bytes,3,opt,name=admin,proto3" json:"admin" form:"admin"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,4,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,5,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,6,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//模型修改时间
	Mtime string `protobuf:"bytes,7,opt,name=mtime,proto3" json:"mtime" form:"mtime"`
	//
	//模型版本
	XVersion int32 `protobuf:"varint,8,opt,name=_version,json=Version,proto3" json:"_version" form:"_version"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,9,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

订阅者

func (*PubSubscriber) Descriptor 

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

func (*PubSubscriber) GetAdmin 

func (m *PubSubscriber) GetAdmin() string

func (*PubSubscriber) GetCallback 

func (m *PubSubscriber) GetCallback() string

func (*PubSubscriber) GetEnsName 

func (m *PubSubscriber) GetEnsName() string

func (*PubSubscriber) GetInstanceId 

func (m *PubSubscriber) GetInstanceId() string

func (*PubSubscriber) GetMtime 

func (m *PubSubscriber) GetMtime() string

func (*PubSubscriber) GetName 

func (m *PubSubscriber) GetName() string

func (*PubSubscriber) GetRetry 

func (m *PubSubscriber) GetRetry() int32

func (*PubSubscriber) GetTopicVersion 

func (m *PubSubscriber) GetTopicVersion() int32

func (*PubSubscriber) GetXVersion 

func (m *PubSubscriber) GetXVersion() int32

func (*PubSubscriber) ProtoMessage 

func (*PubSubscriber) ProtoMessage()

func (*PubSubscriber) Reset 

func (m *PubSubscriber) Reset()

func (*PubSubscriber) String 

func (m *PubSubscriber) String() string

func (*PubSubscriber) Validate 

func (this *PubSubscriber) Validate() error

func (*PubSubscriber) XXX_DiscardUnknown 

func (m *PubSubscriber) XXX_DiscardUnknown()

func (*PubSubscriber) XXX_Marshal 

func (m *PubSubscriber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubSubscriber) XXX_Merge 

func (m *PubSubscriber) XXX_Merge(src proto.Message)

func (*PubSubscriber) XXX_Size 

func (m *PubSubscriber) XXX_Size() int

func (*PubSubscriber) XXX_Unmarshal 

func (m *PubSubscriber) XXX_Unmarshal(b []byte) error

type SubscribeInfo 

type SubscribeInfo struct {
	//
	//订阅channel
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel" form:"channel"`
	//
	//订阅的事件列表
	Event                []string `protobuf:"bytes,2,rep,name=event,proto3" json:"event" form:"event"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

订阅信息

func (*SubscribeInfo) Descriptor 

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

func (*SubscribeInfo) GetChannel 

func (m *SubscribeInfo) GetChannel() string

func (*SubscribeInfo) GetEvent 

func (m *SubscribeInfo) GetEvent() []string

func (*SubscribeInfo) ProtoMessage 

func (*SubscribeInfo) ProtoMessage()

func (*SubscribeInfo) Reset 

func (m *SubscribeInfo) Reset()

func (*SubscribeInfo) String 

func (m *SubscribeInfo) String() string

func (*SubscribeInfo) Validate 

func (this *SubscribeInfo) Validate() error

func (*SubscribeInfo) XXX_DiscardUnknown 

func (m *SubscribeInfo) XXX_DiscardUnknown()

func (*SubscribeInfo) XXX_Marshal 

func (m *SubscribeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeInfo) XXX_Merge 

func (m *SubscribeInfo) XXX_Merge(src proto.Message)

func (*SubscribeInfo) XXX_Size 

func (m *SubscribeInfo) XXX_Size() int

func (*SubscribeInfo) XXX_Unmarshal 

func (m *SubscribeInfo) XXX_Unmarshal(b []byte) error

type Subscriber 

type Subscriber struct {
	//
	//订阅名称，为数据库主键
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" form:"name"`
	//
	//订阅负责人。如 linus
	Admin string `protobuf:"bytes,2,opt,name=admin,proto3" json:"admin" form:"admin"`
	//
	//回调url
	Callback string `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。字段非空时，callback的域名在执行时会替换成 ensName 对应的 ip 端口，这种情况目前未传 HOST Header
	EnsName string `protobuf:"bytes,4,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//订阅者的进程数，默认1
	ProcNum int32 `protobuf:"varint,5,opt,name=procNum,proto3" json:"procNum" form:"procNum"`
	//
	//消息类型，1为单条消息，2为批量接收
	MsgType int32 `protobuf:"varint,6,opt,name=msgType,proto3" json:"msgType" form:"msgType"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,7,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//订阅信息
	SubscribeInfo        []*SubscribeInfo `protobuf:"bytes,8,rep,name=subscribeInfo,proto3" json:"subscribeInfo" form:"subscribeInfo"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

订阅者

func (*Subscriber) Descriptor 

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

func (*Subscriber) GetAdmin 

func (m *Subscriber) GetAdmin() string

func (*Subscriber) GetCallback 

func (m *Subscriber) GetCallback() string

func (*Subscriber) GetEnsName 

func (m *Subscriber) GetEnsName() string

func (*Subscriber) GetMsgType 

func (m *Subscriber) GetMsgType() int32

func (*Subscriber) GetName 

func (m *Subscriber) GetName() string

func (*Subscriber) GetProcNum 

func (m *Subscriber) GetProcNum() int32

func (*Subscriber) GetRetry 

func (m *Subscriber) GetRetry() int32

func (*Subscriber) GetSubscribeInfo 

func (m *Subscriber) GetSubscribeInfo() []*SubscribeInfo

func (*Subscriber) ProtoMessage 

func (*Subscriber) ProtoMessage()

func (*Subscriber) Reset 

func (m *Subscriber) Reset()

func (*Subscriber) String 

func (m *Subscriber) String() string

func (*Subscriber) Validate 

func (this *Subscriber) Validate() error

func (*Subscriber) XXX_DiscardUnknown 

func (m *Subscriber) XXX_DiscardUnknown()

func (*Subscriber) XXX_Marshal 

func (m *Subscriber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscriber) XXX_Merge 

func (m *Subscriber) XXX_Merge(src proto.Message)

func (*Subscriber) XXX_Size 

func (m *Subscriber) XXX_Size() int

func (*Subscriber) XXX_Unmarshal 

func (m *Subscriber) XXX_Unmarshal(b []byte) error

type Topic 

type Topic struct {
	//
	//实例ID
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//实例名称
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//事件系统
	System string `protobuf:"bytes,3,opt,name=system,proto3" json:"system" form:"system"`
	//
	//事件分类
	Topic string `protobuf:"bytes,4,opt,name=topic,proto3" json:"topic" form:"topic"`
	//
	//说明
	Memo string `protobuf:"bytes,5,opt,name=memo,proto3" json:"memo" form:"memo"`
	//
	//事件二级分类
	Category string `protobuf:"bytes,6,opt,name=category,proto3" json:"category" form:"category"`
	//
	//数据格式样例
	Example              string   `protobuf:"bytes,7,opt,name=example,proto3" json:"example" form:"example"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

事件

func (*Topic) Descriptor 

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

func (*Topic) GetCategory 

func (m *Topic) GetCategory() string

func (*Topic) GetExample 

func (m *Topic) GetExample() string

func (*Topic) GetInstanceId 

func (m *Topic) GetInstanceId() string

func (*Topic) GetMemo 

func (m *Topic) GetMemo() string

func (*Topic) GetName 

func (m *Topic) GetName() string

func (*Topic) GetSystem 

func (m *Topic) GetSystem() string

func (*Topic) GetTopic 

func (m *Topic) GetTopic() string

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) String 

func (m *Topic) String() string

func (*Topic) Validate 

func (this *Topic) Validate() error

func (*Topic) XXX_DiscardUnknown 

func (m *Topic) XXX_DiscardUnknown()

func (*Topic) XXX_Marshal 

func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Topic) XXX_Merge 

func (m *Topic) XXX_Merge(src proto.Message)

func (*Topic) XXX_Size 

func (m *Topic) XXX_Size() int

func (*Topic) XXX_Unmarshal 

func (m *Topic) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

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.