protocol

package
v0.0.0-...-f13fc7a Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LogMessage_LogLevel_name = map[int32]string{
		0: "Trace",
		1: "Info",
		2: "Warning",
		3: "Error",
	}
	LogMessage_LogLevel_value = map[string]int32{
		"Trace":   0,
		"Info":    1,
		"Warning": 2,
		"Error":   3,
	}
)

Enum value maps for LogMessage_LogLevel.

View Source 
var (
	ControlMessage_PluginActionType_name = map[int32]string{
		0: "Enable",
		1: "Disable",
		2: "Install",
		3: "UnInstall",
		4: "Upgrade",
		5: "CheckState",
		6: "CheckCompatibility",
	}
	ControlMessage_PluginActionType_value = map[string]int32{
		"Enable":             0,
		"Disable":            1,
		"Install":            2,
		"UnInstall":          3,
		"Upgrade":            4,
		"CheckState":         5,
		"CheckCompatibility": 6,
	}
)

Enum value maps for ControlMessage_PluginActionType.

View Source 
var (
	WorkspaceMessage_IOOperationType_name = map[int32]string{
		0:  "Create",
		1:  "Rename",
		2:  "Remove",
		3:  "IsExist",
		4:  "Copy",
		5:  "List",
		6:  "IsDir",
		7:  "CreateDir",
		10: "Read",
		11: "ReadLines",
		12: "WriteBytes",
		13: "AppendBytes",
		14: "WriteStrings",
		15: "AppendStrings",
		21: "Zip",
		22: "UnZip",
		23: "Gz",
		24: "UnGz",
		25: "Hash",
	}
	WorkspaceMessage_IOOperationType_value = map[string]int32{
		"Create":        0,
		"Rename":        1,
		"Remove":        2,
		"IsExist":       3,
		"Copy":          4,
		"List":          5,
		"IsDir":         6,
		"CreateDir":     7,
		"Read":          10,
		"ReadLines":     11,
		"WriteBytes":    12,
		"AppendBytes":   13,
		"WriteStrings":  14,
		"AppendStrings": 15,
		"Zip":           21,
		"UnZip":         22,
		"Gz":            23,
		"UnGz":          24,
		"Hash":          25,
	}
)

Enum value maps for WorkspaceMessage_IOOperationType.

View Source 
var (
	HttpResourceMessage_HttpResourceType_name = map[int32]string{
		0: "API",
		1: "Outdoor",
	}
	HttpResourceMessage_HttpResourceType_value = map[string]int32{
		"API":     0,
		"Outdoor": 1,
	}
)

Enum value maps for HttpResourceMessage_HttpResourceType.

View Source 
var (
	EventMessage_SubscribeOperationType_name = map[int32]string{
		0: "Subscribe",
		1: "SubscribeWithFilter",
		2: "Unsubscribe",
	}
	EventMessage_SubscribeOperationType_value = map[string]int32{
		"Subscribe":           0,
		"SubscribeWithFilter": 1,
		"Unsubscribe":         2,
	}
)

Enum value maps for EventMessage_SubscribeOperationType.

View Source 
var File_common_proto protoreflect.FileDescriptor
View Source 
var File_control_proto protoreflect.FileDescriptor
View Source 
var File_message_proto protoreflect.FileDescriptor
View Source 
var File_plugin_proto protoreflect.FileDescriptor
View Source 
var File_resources_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AbilityMessage 

type AbilityMessage struct {
	Ability string        `protobuf:"bytes,1,opt,name=Ability,proto3" json:"Ability,omitempty"`
	Content []byte        `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	Error   *ErrorMessage `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*AbilityMessage) Descriptor deprecated 

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

Deprecated: Use AbilityMessage.ProtoReflect.Descriptor instead.

func (*AbilityMessage) GetAbility 

func (x *AbilityMessage) GetAbility() string

func (*AbilityMessage) GetContent 

func (x *AbilityMessage) GetContent() []byte

func (*AbilityMessage) GetError 

func (x *AbilityMessage) GetError() *ErrorMessage

func (*AbilityMessage) ProtoMessage 

func (*AbilityMessage) ProtoMessage()

func (*AbilityMessage) ProtoReflect 

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

func (*AbilityMessage) Reset 

func (x *AbilityMessage) Reset()

func (*AbilityMessage) String 

func (x *AbilityMessage) String() string

type ColumnDesc 

type ColumnDesc struct {
	Index int64  `protobuf:"varint,1,opt,name=Index,proto3" json:"Index,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Type  string `protobuf:"bytes,3,opt,name=Type,proto3" json:"Type,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDesc) Descriptor deprecated 

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

Deprecated: Use ColumnDesc.ProtoReflect.Descriptor instead.

func (*ColumnDesc) GetIndex 

func (x *ColumnDesc) GetIndex() int64

func (*ColumnDesc) GetName 

func (x *ColumnDesc) GetName() string

func (*ColumnDesc) GetType 

func (x *ColumnDesc) GetType() string

func (*ColumnDesc) ProtoMessage 

func (*ColumnDesc) ProtoMessage()

func (*ColumnDesc) ProtoReflect 

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

func (*ColumnDesc) Reset 

func (x *ColumnDesc) Reset()

func (*ColumnDesc) String 

func (x *ColumnDesc) String() string

type ConfigurationMessage 

type ConfigurationMessage struct {
	ConfigChangeRequest  *ConfigurationMessage_ConfigurationChangeMessage `protobuf:"bytes,1,opt,name=ConfigChangeRequest,proto3" json:"ConfigChangeRequest,omitempty"`
	ConfigChangeResponse *ErrorMessage                                    `protobuf:"bytes,2,opt,name=ConfigChangeResponse,proto3" json:"ConfigChangeResponse,omitempty"`
	// contains filtered or unexported fields
}

插件需要相应的消息请求及其对应的应答 插件提供的接口实现 插件提供的配置处理实现

func (*ConfigurationMessage) Descriptor deprecated 

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

Deprecated: Use ConfigurationMessage.ProtoReflect.Descriptor instead.

func (*ConfigurationMessage) GetConfigChangeRequest 

func (x *ConfigurationMessage) GetConfigChangeRequest() *ConfigurationMessage_ConfigurationChangeMessage

func (*ConfigurationMessage) GetConfigChangeResponse 

func (x *ConfigurationMessage) GetConfigChangeResponse() *ErrorMessage

func (*ConfigurationMessage) ProtoMessage 

func (*ConfigurationMessage) ProtoMessage()

func (*ConfigurationMessage) ProtoReflect 

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

func (*ConfigurationMessage) Reset 

func (x *ConfigurationMessage) Reset()

func (*ConfigurationMessage) String 

func (x *ConfigurationMessage) String() string

type ConfigurationMessage_ConfigurationChangeMessage 

type ConfigurationMessage_ConfigurationChangeMessage struct {
	ConfigKey   string   `protobuf:"bytes,1,opt,name=ConfigKey,proto3" json:"ConfigKey,omitempty"`
	NewValue    []string `protobuf:"bytes,2,rep,name=NewValue,proto3" json:"NewValue,omitempty"`
	OriginValue []string `protobuf:"bytes,3,rep,name=OriginValue,proto3" json:"OriginValue,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationMessage_ConfigurationChangeMessage) Descriptor deprecated 

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

Deprecated: Use ConfigurationMessage_ConfigurationChangeMessage.ProtoReflect.Descriptor instead.

func (*ConfigurationMessage_ConfigurationChangeMessage) GetConfigKey 

func (x *ConfigurationMessage_ConfigurationChangeMessage) GetConfigKey() string

func (*ConfigurationMessage_ConfigurationChangeMessage) GetNewValue 

func (x *ConfigurationMessage_ConfigurationChangeMessage) GetNewValue() []string

func (*ConfigurationMessage_ConfigurationChangeMessage) GetOriginValue 

func (x *ConfigurationMessage_ConfigurationChangeMessage) GetOriginValue() []string

func (*ConfigurationMessage_ConfigurationChangeMessage) ProtoMessage 

func (*ConfigurationMessage_ConfigurationChangeMessage) ProtoMessage()

func (*ConfigurationMessage_ConfigurationChangeMessage) ProtoReflect 

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

func (*ConfigurationMessage_ConfigurationChangeMessage) Reset 

func (x *ConfigurationMessage_ConfigurationChangeMessage) Reset()

func (*ConfigurationMessage_ConfigurationChangeMessage) String 

func (x *ConfigurationMessage_ConfigurationChangeMessage) String() string

type ControlMessage 

type ControlMessage struct {

	// 发起的心跳消息
	Heartbeat uint64 `protobuf:"varint,10,opt,name=Heartbeat,proto3" json:"Heartbeat,omitempty"`
	// 从Host传递过来的报告
	HostReport *ControlMessage_HostReportMessage     `protobuf:"bytes,11,opt,name=HostReport,proto3" json:"HostReport,omitempty"`
	BootReport *ControlMessage_HostBootReportMessage `protobuf:"bytes,12,opt,name=BootReport,proto3" json:"BootReport,omitempty"`
	// 干掉host
	Kill *ControlMessage_KillPluginHostMessage `protobuf:"bytes,13,opt,name=Kill,proto3" json:"Kill,omitempty"`
	// 干掉插件
	KillPlugin        *ControlMessage_KillPluginMessage              `protobuf:"bytes,14,opt,name=killPlugin,proto3" json:"killPlugin,omitempty"`
	CheckPlugin       *ControlMessage_SupportCheckRequestMessage     `protobuf:"bytes,15,opt,name=CheckPlugin,proto3" json:"CheckPlugin,omitempty"`
	CheckPluginResult *ControlMessage_SupportCheckResponseMessage    `protobuf:"bytes,16,opt,name=CheckPluginResult,proto3" json:"CheckPluginResult,omitempty"`
	LifeCycleRequest  *ControlMessage_PluginLifeCycleRequestMessage  `protobuf:"bytes,17,opt,name=LifeCycleRequest,proto3" json:"LifeCycleRequest,omitempty"`
	LifeCycleResponse *ControlMessage_PluginLifeCycleResponseMessage `protobuf:"bytes,18,opt,name=LifeCycleResponse,proto3" json:"LifeCycleResponse,omitempty"`
	StartHost         *ControlMessage_StartHostMessage               `protobuf:"bytes,19,opt,name=StartHost,proto3" json:"StartHost,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetBootReport 

func (x *ControlMessage) GetBootReport() *ControlMessage_HostBootReportMessage

func (*ControlMessage) GetCheckPlugin 

func (x *ControlMessage) GetCheckPlugin() *ControlMessage_SupportCheckRequestMessage

func (*ControlMessage) GetCheckPluginResult 

func (x *ControlMessage) GetCheckPluginResult() *ControlMessage_SupportCheckResponseMessage

func (*ControlMessage) GetHeartbeat 

func (x *ControlMessage) GetHeartbeat() uint64

func (*ControlMessage) GetHostReport 

func (x *ControlMessage) GetHostReport() *ControlMessage_HostReportMessage

func (*ControlMessage) GetKill 

func (x *ControlMessage) GetKill() *ControlMessage_KillPluginHostMessage

func (*ControlMessage) GetKillPlugin 

func (x *ControlMessage) GetKillPlugin() *ControlMessage_KillPluginMessage

func (*ControlMessage) GetLifeCycleRequest 

func (x *ControlMessage) GetLifeCycleRequest() *ControlMessage_PluginLifeCycleRequestMessage

func (*ControlMessage) GetLifeCycleResponse 

func (x *ControlMessage) GetLifeCycleResponse() *ControlMessage_PluginLifeCycleResponseMessage

func (*ControlMessage) GetStartHost 

func (x *ControlMessage) GetStartHost() *ControlMessage_StartHostMessage

func (*ControlMessage) ProtoMessage 

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect 

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

func (*ControlMessage) Reset 

func (x *ControlMessage) Reset()

func (*ControlMessage) String 

func (x *ControlMessage) String() string

type ControlMessage_HostBootReportMessage 

type ControlMessage_HostBootReportMessage struct {
	Boot *HostBootDescriptor `protobuf:"bytes,1,opt,name=Boot,proto3" json:"Boot,omitempty"`
	// 从HostBoot传递过来的错误报告
	ErrorReport []*ErrorMessage `protobuf:"bytes,2,rep,name=ErrorReport,proto3" json:"ErrorReport,omitempty"`
	Log         []*LogMessage   `protobuf:"bytes,3,rep,name=Log,proto3" json:"Log,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_HostBootReportMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_HostBootReportMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_HostBootReportMessage) GetBoot 

func (x *ControlMessage_HostBootReportMessage) GetBoot() *HostBootDescriptor

func (*ControlMessage_HostBootReportMessage) GetErrorReport 

func (x *ControlMessage_HostBootReportMessage) GetErrorReport() []*ErrorMessage

func (*ControlMessage_HostBootReportMessage) GetLog 

func (x *ControlMessage_HostBootReportMessage) GetLog() []*LogMessage

func (*ControlMessage_HostBootReportMessage) ProtoMessage 

func (*ControlMessage_HostBootReportMessage) ProtoMessage()

func (*ControlMessage_HostBootReportMessage) ProtoReflect 

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

func (*ControlMessage_HostBootReportMessage) Reset 

func (x *ControlMessage_HostBootReportMessage) Reset()

func (*ControlMessage_HostBootReportMessage) String 

func (x *ControlMessage_HostBootReportMessage) String() string

type ControlMessage_HostReportMessage 

type ControlMessage_HostReportMessage struct {
	Host *HostDescriptor `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	// 从Host传递过来的错误报告
	ErrorReport []*ErrorMessage `protobuf:"bytes,10,rep,name=ErrorReport,proto3" json:"ErrorReport,omitempty"`
	// 从Host传递的日志消息
	Log []*LogMessage `protobuf:"bytes,11,rep,name=Log,proto3" json:"Log,omitempty"`
	// Host上支持/已经挂载的插件实例
	SupportedList map[string]*PluginInstanceDescriptor `` /* 168-byte string literal not displayed */
	// Host上执行的插件实例列表
	InstanceList map[string]*PluginInstanceDescriptor `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ControlMessage_HostReportMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_HostReportMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_HostReportMessage) GetErrorReport 

func (x *ControlMessage_HostReportMessage) GetErrorReport() []*ErrorMessage

func (*ControlMessage_HostReportMessage) GetHost 

func (x *ControlMessage_HostReportMessage) GetHost() *HostDescriptor

func (*ControlMessage_HostReportMessage) GetInstanceList 

func (x *ControlMessage_HostReportMessage) GetInstanceList() map[string]*PluginInstanceDescriptor

func (*ControlMessage_HostReportMessage) GetLog 

func (x *ControlMessage_HostReportMessage) GetLog() []*LogMessage

func (*ControlMessage_HostReportMessage) GetSupportedList 

func (x *ControlMessage_HostReportMessage) GetSupportedList() map[string]*PluginInstanceDescriptor

func (*ControlMessage_HostReportMessage) ProtoMessage 

func (*ControlMessage_HostReportMessage) ProtoMessage()

func (*ControlMessage_HostReportMessage) ProtoReflect 

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

func (*ControlMessage_HostReportMessage) Reset 

func (x *ControlMessage_HostReportMessage) Reset()

func (*ControlMessage_HostReportMessage) String 

func (x *ControlMessage_HostReportMessage) String() string

type ControlMessage_KillPluginHostMessage 

type ControlMessage_KillPluginHostMessage struct {
	Kill bool `protobuf:"varint,1,opt,name=Kill,proto3" json:"Kill,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_KillPluginHostMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_KillPluginHostMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_KillPluginHostMessage) GetKill 

func (x *ControlMessage_KillPluginHostMessage) GetKill() bool

func (*ControlMessage_KillPluginHostMessage) ProtoMessage 

func (*ControlMessage_KillPluginHostMessage) ProtoMessage()

func (*ControlMessage_KillPluginHostMessage) ProtoReflect 

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

func (*ControlMessage_KillPluginHostMessage) Reset 

func (x *ControlMessage_KillPluginHostMessage) Reset()

func (*ControlMessage_KillPluginHostMessage) String 

func (x *ControlMessage_KillPluginHostMessage) String() string

type ControlMessage_KillPluginMessage 

type ControlMessage_KillPluginMessage struct {
	InstanceID string `protobuf:"bytes,1,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_KillPluginMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_KillPluginMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_KillPluginMessage) GetInstanceID 

func (x *ControlMessage_KillPluginMessage) GetInstanceID() string

func (*ControlMessage_KillPluginMessage) ProtoMessage 

func (*ControlMessage_KillPluginMessage) ProtoMessage()

func (*ControlMessage_KillPluginMessage) ProtoReflect 

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

func (*ControlMessage_KillPluginMessage) Reset 

func (x *ControlMessage_KillPluginMessage) Reset()

func (*ControlMessage_KillPluginMessage) String 

func (x *ControlMessage_KillPluginMessage) String() string

type ControlMessage_PluginActionType 

type ControlMessage_PluginActionType int32
const (
	ControlMessage_Enable             ControlMessage_PluginActionType = 0
	ControlMessage_Disable            ControlMessage_PluginActionType = 1
	ControlMessage_Install            ControlMessage_PluginActionType = 2
	ControlMessage_UnInstall          ControlMessage_PluginActionType = 3
	ControlMessage_Upgrade            ControlMessage_PluginActionType = 4
	ControlMessage_CheckState         ControlMessage_PluginActionType = 5
	ControlMessage_CheckCompatibility ControlMessage_PluginActionType = 6
)

func (ControlMessage_PluginActionType) Descriptor 

func (ControlMessage_PluginActionType) Descriptor() protoreflect.EnumDescriptor

func (ControlMessage_PluginActionType) Enum 

func (x ControlMessage_PluginActionType) Enum() *ControlMessage_PluginActionType

func (ControlMessage_PluginActionType) EnumDescriptor deprecated 

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

Deprecated: Use ControlMessage_PluginActionType.Descriptor instead.

func (ControlMessage_PluginActionType) Number 

func (x ControlMessage_PluginActionType) Number() protoreflect.EnumNumber

func (ControlMessage_PluginActionType) String 

func (x ControlMessage_PluginActionType) String() string

func (ControlMessage_PluginActionType) Type 

func (ControlMessage_PluginActionType) Type() protoreflect.EnumType

type ControlMessage_PluginLifeCycleRequestMessage 

type ControlMessage_PluginLifeCycleRequestMessage struct {
	Host       *HostDescriptor                 `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Instance   *PluginInstanceDescriptor       `protobuf:"bytes,2,opt,name=Instance,proto3" json:"Instance,omitempty"`
	Action     ControlMessage_PluginActionType `protobuf:"varint,3,opt,name=Action,proto3,enum=protocol.ControlMessage_PluginActionType" json:"Action,omitempty"`
	Reason     string                          `protobuf:"bytes,4,opt,name=Reason,proto3" json:"Reason,omitempty"`
	OldVersion *PluginDescriptor               `protobuf:"bytes,10,opt,name=OldVersion,proto3" json:"OldVersion,omitempty"`
	// contains filtered or unexported fields
}

插件提供的生命周期方法实现

func (*ControlMessage_PluginLifeCycleRequestMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_PluginLifeCycleRequestMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_PluginLifeCycleRequestMessage) GetAction 

func (x *ControlMessage_PluginLifeCycleRequestMessage) GetAction() ControlMessage_PluginActionType

func (*ControlMessage_PluginLifeCycleRequestMessage) GetHost 

func (x *ControlMessage_PluginLifeCycleRequestMessage) GetHost() *HostDescriptor

func (*ControlMessage_PluginLifeCycleRequestMessage) GetInstance 

func (x *ControlMessage_PluginLifeCycleRequestMessage) GetInstance() *PluginInstanceDescriptor

func (*ControlMessage_PluginLifeCycleRequestMessage) GetOldVersion 

func (x *ControlMessage_PluginLifeCycleRequestMessage) GetOldVersion() *PluginDescriptor

func (*ControlMessage_PluginLifeCycleRequestMessage) GetReason 

func (x *ControlMessage_PluginLifeCycleRequestMessage) GetReason() string

func (*ControlMessage_PluginLifeCycleRequestMessage) ProtoMessage 

func (*ControlMessage_PluginLifeCycleRequestMessage) ProtoMessage()

func (*ControlMessage_PluginLifeCycleRequestMessage) ProtoReflect 

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

func (*ControlMessage_PluginLifeCycleRequestMessage) Reset 

func (x *ControlMessage_PluginLifeCycleRequestMessage) Reset()

func (*ControlMessage_PluginLifeCycleRequestMessage) String 

func (x *ControlMessage_PluginLifeCycleRequestMessage) String() string

type ControlMessage_PluginLifeCycleResponseMessage 

type ControlMessage_PluginLifeCycleResponseMessage struct {
	Host     *HostDescriptor           `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Instance *PluginInstanceDescriptor `protobuf:"bytes,2,opt,name=Instance,proto3" json:"Instance,omitempty"`
	Result   bool                      `protobuf:"varint,4,opt,name=Result,proto3" json:"Result,omitempty"`
	Error    *ErrorMessage             `protobuf:"bytes,5,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_PluginLifeCycleResponseMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_PluginLifeCycleResponseMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_PluginLifeCycleResponseMessage) GetError 

func (x *ControlMessage_PluginLifeCycleResponseMessage) GetError() *ErrorMessage

func (*ControlMessage_PluginLifeCycleResponseMessage) GetHost 

func (x *ControlMessage_PluginLifeCycleResponseMessage) GetHost() *HostDescriptor

func (*ControlMessage_PluginLifeCycleResponseMessage) GetInstance 

func (x *ControlMessage_PluginLifeCycleResponseMessage) GetInstance() *PluginInstanceDescriptor

func (*ControlMessage_PluginLifeCycleResponseMessage) GetResult 

func (x *ControlMessage_PluginLifeCycleResponseMessage) GetResult() bool

func (*ControlMessage_PluginLifeCycleResponseMessage) ProtoMessage 

func (*ControlMessage_PluginLifeCycleResponseMessage) ProtoMessage()

func (*ControlMessage_PluginLifeCycleResponseMessage) ProtoReflect 

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

func (*ControlMessage_PluginLifeCycleResponseMessage) Reset 

func (x *ControlMessage_PluginLifeCycleResponseMessage) Reset()

func (*ControlMessage_PluginLifeCycleResponseMessage) String 

func (x *ControlMessage_PluginLifeCycleResponseMessage) String() string

type ControlMessage_StartHostMessage 

type ControlMessage_StartHostMessage struct {
	Host   *HostDescriptor `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Result bool            `protobuf:"varint,2,opt,name=Result,proto3" json:"Result,omitempty"`
	Error  *ErrorMessage   `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_StartHostMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_StartHostMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_StartHostMessage) GetError 

func (x *ControlMessage_StartHostMessage) GetError() *ErrorMessage

func (*ControlMessage_StartHostMessage) GetHost 

func (x *ControlMessage_StartHostMessage) GetHost() *HostDescriptor

func (*ControlMessage_StartHostMessage) GetResult 

func (x *ControlMessage_StartHostMessage) GetResult() bool

func (*ControlMessage_StartHostMessage) ProtoMessage 

func (*ControlMessage_StartHostMessage) ProtoMessage()

func (*ControlMessage_StartHostMessage) ProtoReflect 

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

func (*ControlMessage_StartHostMessage) Reset 

func (x *ControlMessage_StartHostMessage) Reset()

func (*ControlMessage_StartHostMessage) String 

func (x *ControlMessage_StartHostMessage) String() string

type ControlMessage_SupportCheckRequestMessage 

type ControlMessage_SupportCheckRequestMessage struct {

	// 请求体
	ApplicationID      string   `protobuf:"bytes,1,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	ApplicationVersion *Version `protobuf:"bytes,2,opt,name=ApplicationVersion,proto3" json:"ApplicationVersion,omitempty"`
	SystemVersion      *Version `protobuf:"bytes,3,opt,name=SystemVersion,proto3" json:"SystemVersion,omitempty"`
	InstanceID         string   `protobuf:"bytes,4,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	// 目标HostID
	Host *HostDescriptor `protobuf:"bytes,10,opt,name=Host,proto3" json:"Host,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_SupportCheckRequestMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_SupportCheckRequestMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_SupportCheckRequestMessage) GetApplicationID 

func (x *ControlMessage_SupportCheckRequestMessage) GetApplicationID() string

func (*ControlMessage_SupportCheckRequestMessage) GetApplicationVersion 

func (x *ControlMessage_SupportCheckRequestMessage) GetApplicationVersion() *Version

func (*ControlMessage_SupportCheckRequestMessage) GetHost 

func (x *ControlMessage_SupportCheckRequestMessage) GetHost() *HostDescriptor

func (*ControlMessage_SupportCheckRequestMessage) GetInstanceID 

func (x *ControlMessage_SupportCheckRequestMessage) GetInstanceID() string

func (*ControlMessage_SupportCheckRequestMessage) GetSystemVersion 

func (x *ControlMessage_SupportCheckRequestMessage) GetSystemVersion() *Version

func (*ControlMessage_SupportCheckRequestMessage) ProtoMessage 

func (*ControlMessage_SupportCheckRequestMessage) ProtoMessage()

func (*ControlMessage_SupportCheckRequestMessage) ProtoReflect 

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

func (*ControlMessage_SupportCheckRequestMessage) Reset 

func (x *ControlMessage_SupportCheckRequestMessage) Reset()

func (*ControlMessage_SupportCheckRequestMessage) String 

func (x *ControlMessage_SupportCheckRequestMessage) String() string

type ControlMessage_SupportCheckResponseMessage 

type ControlMessage_SupportCheckResponseMessage struct {
	Host        *HostDescriptor       `protobuf:"bytes,1,opt,name=Host,proto3" json:"Host,omitempty"`
	Application *PluginFullDescriptor `protobuf:"bytes,2,opt,name=Application,proto3" json:"Application,omitempty"`
	InstanceID  string                `protobuf:"bytes,3,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	Supported   bool                  `protobuf:"varint,20,opt,name=Supported,proto3" json:"Supported,omitempty"`
	// contains filtered or unexported fields
}

func (*ControlMessage_SupportCheckResponseMessage) Descriptor deprecated 

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

Deprecated: Use ControlMessage_SupportCheckResponseMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage_SupportCheckResponseMessage) GetApplication 

func (x *ControlMessage_SupportCheckResponseMessage) GetApplication() *PluginFullDescriptor

func (*ControlMessage_SupportCheckResponseMessage) GetHost 

func (x *ControlMessage_SupportCheckResponseMessage) GetHost() *HostDescriptor

func (*ControlMessage_SupportCheckResponseMessage) GetInstanceID 

func (x *ControlMessage_SupportCheckResponseMessage) GetInstanceID() string

func (*ControlMessage_SupportCheckResponseMessage) GetSupported 

func (x *ControlMessage_SupportCheckResponseMessage) GetSupported() bool

func (*ControlMessage_SupportCheckResponseMessage) ProtoMessage 

func (*ControlMessage_SupportCheckResponseMessage) ProtoMessage()

func (*ControlMessage_SupportCheckResponseMessage) ProtoReflect 

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

func (*ControlMessage_SupportCheckResponseMessage) Reset 

func (x *ControlMessage_SupportCheckResponseMessage) Reset()

func (*ControlMessage_SupportCheckResponseMessage) String 

func (x *ControlMessage_SupportCheckResponseMessage) String() string

type DatabaseMessage 

type DatabaseMessage struct {
	DBRequest  *DatabaseMessage_DatabaseRequestMessage  `protobuf:"bytes,1,opt,name=DBRequest,proto3" json:"DBRequest,omitempty"`
	DBResponse *DatabaseMessage_DatabaseResponseMessage `protobuf:"bytes,2,opt,name=DBResponse,proto3" json:"DBResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseMessage) Descriptor deprecated 

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

Deprecated: Use DatabaseMessage.ProtoReflect.Descriptor instead.

func (*DatabaseMessage) GetDBRequest 

func (x *DatabaseMessage) GetDBRequest() *DatabaseMessage_DatabaseRequestMessage

func (*DatabaseMessage) GetDBResponse 

func (x *DatabaseMessage) GetDBResponse() *DatabaseMessage_DatabaseResponseMessage

func (*DatabaseMessage) ProtoMessage 

func (*DatabaseMessage) ProtoMessage()

func (*DatabaseMessage) ProtoReflect 

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

func (*DatabaseMessage) Reset 

func (x *DatabaseMessage) Reset()

func (*DatabaseMessage) String 

func (x *DatabaseMessage) String() string

type DatabaseMessage_DatabaseRequestMessage 

type DatabaseMessage_DatabaseRequestMessage struct {
	DB          string `protobuf:"bytes,1,opt,name=DB,proto3" json:"DB,omitempty"`
	SqlFileName string `protobuf:"bytes,2,opt,name=SqlFileName,proto3" json:"SqlFileName,omitempty"`
	Statement   string `protobuf:"bytes,3,opt,name=Statement,proto3" json:"Statement,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseMessage_DatabaseRequestMessage) Descriptor deprecated 

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

Deprecated: Use DatabaseMessage_DatabaseRequestMessage.ProtoReflect.Descriptor instead.

func (*DatabaseMessage_DatabaseRequestMessage) GetDB 

func (x *DatabaseMessage_DatabaseRequestMessage) GetDB() string

func (*DatabaseMessage_DatabaseRequestMessage) GetSqlFileName 

func (x *DatabaseMessage_DatabaseRequestMessage) GetSqlFileName() string

func (*DatabaseMessage_DatabaseRequestMessage) GetStatement 

func (x *DatabaseMessage_DatabaseRequestMessage) GetStatement() string

func (*DatabaseMessage_DatabaseRequestMessage) ProtoMessage 

func (*DatabaseMessage_DatabaseRequestMessage) ProtoMessage()

func (*DatabaseMessage_DatabaseRequestMessage) ProtoReflect 

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

func (*DatabaseMessage_DatabaseRequestMessage) Reset 

func (x *DatabaseMessage_DatabaseRequestMessage) Reset()

func (*DatabaseMessage_DatabaseRequestMessage) String 

func (x *DatabaseMessage_DatabaseRequestMessage) String() string

type DatabaseMessage_DatabaseResponseMessage 

type DatabaseMessage_DatabaseResponseMessage struct {
	Error        *ErrorMessage `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	DBError      *ErrorMessage `protobuf:"bytes,2,opt,name=DBError,proto3" json:"DBError,omitempty"`
	Data         *TableMessage `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	Count        int64         `protobuf:"varint,7,opt,name=Count,proto3" json:"Count,omitempty"`
	LastInsertId int64         `protobuf:"varint,8,opt,name=LastInsertId,proto3" json:"LastInsertId,omitempty"`
	RowsAffected int64         `protobuf:"varint,9,opt,name=RowsAffected,proto3" json:"RowsAffected,omitempty"`
	// contains filtered or unexported fields
}

func (*DatabaseMessage_DatabaseResponseMessage) Descriptor deprecated 

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

Deprecated: Use DatabaseMessage_DatabaseResponseMessage.ProtoReflect.Descriptor instead.

func (*DatabaseMessage_DatabaseResponseMessage) GetCount 

func (x *DatabaseMessage_DatabaseResponseMessage) GetCount() int64

func (*DatabaseMessage_DatabaseResponseMessage) GetDBError 

func (x *DatabaseMessage_DatabaseResponseMessage) GetDBError() *ErrorMessage

func (*DatabaseMessage_DatabaseResponseMessage) GetData 

func (x *DatabaseMessage_DatabaseResponseMessage) GetData() *TableMessage

func (*DatabaseMessage_DatabaseResponseMessage) GetError 

func (x *DatabaseMessage_DatabaseResponseMessage) GetError() *ErrorMessage

func (*DatabaseMessage_DatabaseResponseMessage) GetLastInsertId 

func (x *DatabaseMessage_DatabaseResponseMessage) GetLastInsertId() int64

func (*DatabaseMessage_DatabaseResponseMessage) GetRowsAffected 

func (x *DatabaseMessage_DatabaseResponseMessage) GetRowsAffected() int64

func (*DatabaseMessage_DatabaseResponseMessage) ProtoMessage 

func (*DatabaseMessage_DatabaseResponseMessage) ProtoMessage()

func (*DatabaseMessage_DatabaseResponseMessage) ProtoReflect 

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

func (*DatabaseMessage_DatabaseResponseMessage) Reset 

func (x *DatabaseMessage_DatabaseResponseMessage) Reset()

func (*DatabaseMessage_DatabaseResponseMessage) String 

func (x *DatabaseMessage_DatabaseResponseMessage) String() string

type ErrorMessage 

type ErrorMessage struct {
	Code  int64  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Msg   string `protobuf:"bytes,3,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ErrorMessage) Descriptor deprecated 

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

Deprecated: Use ErrorMessage.ProtoReflect.Descriptor instead.

func (*ErrorMessage) GetCode 

func (x *ErrorMessage) GetCode() int64

func (*ErrorMessage) GetError 

func (x *ErrorMessage) GetError() string

func (*ErrorMessage) GetMsg 

func (x *ErrorMessage) GetMsg() string

func (*ErrorMessage) ProtoMessage 

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) ProtoReflect 

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

func (*ErrorMessage) Reset 

func (x *ErrorMessage) Reset()

func (*ErrorMessage) String 

func (x *ErrorMessage) String() string

type EventMessage 

type EventMessage struct {
	SubscribeOperation EventMessage_SubscribeOperationType `` /* 140-byte string literal not displayed */
	Condition          []string                            `protobuf:"bytes,2,rep,name=Condition,proto3" json:"Condition,omitempty"`
	SubscribeFilter    map[string]*Filter                  `` /* 171-byte string literal not displayed */
	Error              *ErrorMessage                       `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*EventMessage) Descriptor deprecated 

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

Deprecated: Use EventMessage.ProtoReflect.Descriptor instead.

func (*EventMessage) GetCondition 

func (x *EventMessage) GetCondition() []string

func (*EventMessage) GetError 

func (x *EventMessage) GetError() *ErrorMessage

func (*EventMessage) GetSubscribeFilter 

func (x *EventMessage) GetSubscribeFilter() map[string]*Filter

func (*EventMessage) GetSubscribeOperation 

func (x *EventMessage) GetSubscribeOperation() EventMessage_SubscribeOperationType

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) ProtoReflect 

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

func (*EventMessage) Reset 

func (x *EventMessage) Reset()

func (*EventMessage) String 

func (x *EventMessage) String() string

type EventMessage_SubscribeOperationType 

type EventMessage_SubscribeOperationType int32
const (
	EventMessage_Subscribe           EventMessage_SubscribeOperationType = 0
	EventMessage_SubscribeWithFilter EventMessage_SubscribeOperationType = 1
	EventMessage_Unsubscribe         EventMessage_SubscribeOperationType = 2
)

func (EventMessage_SubscribeOperationType) Descriptor 

func (EventMessage_SubscribeOperationType) Descriptor() protoreflect.EnumDescriptor

func (EventMessage_SubscribeOperationType) Enum 

func (x EventMessage_SubscribeOperationType) Enum() *EventMessage_SubscribeOperationType

func (EventMessage_SubscribeOperationType) EnumDescriptor deprecated 

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

Deprecated: Use EventMessage_SubscribeOperationType.Descriptor instead.

func (EventMessage_SubscribeOperationType) Number 

func (x EventMessage_SubscribeOperationType) Number() protoreflect.EnumNumber

func (EventMessage_SubscribeOperationType) String 

func (x EventMessage_SubscribeOperationType) String() string

func (EventMessage_SubscribeOperationType) Type 

func (EventMessage_SubscribeOperationType) Type() protoreflect.EnumType

type Filter 

type Filter struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetVal 

func (x *Filter) GetVal() []string

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type HeaderVal 

type HeaderVal struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*HeaderVal) Descriptor deprecated 

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

Deprecated: Use HeaderVal.ProtoReflect.Descriptor instead.

func (*HeaderVal) GetVal 

func (x *HeaderVal) GetVal() []string

func (*HeaderVal) ProtoMessage 

func (*HeaderVal) ProtoMessage()

func (*HeaderVal) ProtoReflect 

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

func (*HeaderVal) Reset 

func (x *HeaderVal) Reset()

func (*HeaderVal) String 

func (x *HeaderVal) String() string

type HostBootDescriptor 

type HostBootDescriptor struct {
	BootID      string   `protobuf:"bytes,1,opt,name=BootID,proto3" json:"BootID,omitempty"`
	Name        string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	BootVersion *Version `protobuf:"bytes,3,opt,name=BootVersion,proto3" json:"BootVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*HostBootDescriptor) Descriptor deprecated 

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

Deprecated: Use HostBootDescriptor.ProtoReflect.Descriptor instead.

func (*HostBootDescriptor) GetBootID 

func (x *HostBootDescriptor) GetBootID() string

func (*HostBootDescriptor) GetBootVersion 

func (x *HostBootDescriptor) GetBootVersion() *Version

func (*HostBootDescriptor) GetName 

func (x *HostBootDescriptor) GetName() string

func (*HostBootDescriptor) ProtoMessage 

func (*HostBootDescriptor) ProtoMessage()

func (*HostBootDescriptor) ProtoReflect 

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

func (*HostBootDescriptor) Reset 

func (x *HostBootDescriptor) Reset()

func (*HostBootDescriptor) String 

func (x *HostBootDescriptor) String() string

type HostDescriptor 

type HostDescriptor struct {
	HostID           string   `protobuf:"bytes,1,opt,name=HostID,proto3" json:"HostID,omitempty"`
	Name             string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Language         string   `protobuf:"bytes,3,opt,name=Language,proto3" json:"Language,omitempty"`
	HostVersion      *Version `protobuf:"bytes,4,opt,name=HostVersion,proto3" json:"HostVersion,omitempty"`
	MinSystemVersion *Version `protobuf:"bytes,5,opt,name=MinSystemVersion,proto3" json:"MinSystemVersion,omitempty"`
	LanguageVersion  *Version `protobuf:"bytes,6,opt,name=LanguageVersion,proto3" json:"LanguageVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*HostDescriptor) Descriptor deprecated 

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

Deprecated: Use HostDescriptor.ProtoReflect.Descriptor instead.

func (*HostDescriptor) GetHostID 

func (x *HostDescriptor) GetHostID() string

func (*HostDescriptor) GetHostVersion 

func (x *HostDescriptor) GetHostVersion() *Version

func (*HostDescriptor) GetLanguage 

func (x *HostDescriptor) GetLanguage() string

func (*HostDescriptor) GetLanguageVersion 

func (x *HostDescriptor) GetLanguageVersion() *Version

func (*HostDescriptor) GetMinSystemVersion 

func (x *HostDescriptor) GetMinSystemVersion() *Version

func (*HostDescriptor) GetName 

func (x *HostDescriptor) GetName() string

func (*HostDescriptor) ProtoMessage 

func (*HostDescriptor) ProtoMessage()

func (*HostDescriptor) ProtoReflect 

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

func (*HostDescriptor) Reset 

func (x *HostDescriptor) Reset()

func (*HostDescriptor) String 

func (x *HostDescriptor) String() string

type HttpContextMessage 

type HttpContextMessage struct {
	Request  *HttpRequestMessage  `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"`
	Response *HttpResponseMessage `protobuf:"bytes,2,opt,name=Response,proto3" json:"Response,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpContextMessage) Descriptor deprecated 

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

Deprecated: Use HttpContextMessage.ProtoReflect.Descriptor instead.

func (*HttpContextMessage) GetRequest 

func (x *HttpContextMessage) GetRequest() *HttpRequestMessage

func (*HttpContextMessage) GetResponse 

func (x *HttpContextMessage) GetResponse() *HttpResponseMessage

func (*HttpContextMessage) ProtoMessage 

func (*HttpContextMessage) ProtoMessage()

func (*HttpContextMessage) ProtoReflect 

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

func (*HttpContextMessage) Reset 

func (x *HttpContextMessage) Reset()

func (*HttpContextMessage) String 

func (x *HttpContextMessage) String() string

type HttpRequestMessage 

type HttpRequestMessage struct {
	Method      string                `protobuf:"bytes,1,opt,name=Method,proto3" json:"Method,omitempty"`
	Url         string                `protobuf:"bytes,2,opt,name=Url,proto3" json:"Url,omitempty"`
	Headers     map[string]*HeaderVal `` /* 155-byte string literal not displayed */
	Body        []byte                `protobuf:"bytes,4,opt,name=Body,proto3" json:"Body,omitempty"`
	Root        bool                  `protobuf:"varint,5,opt,name=Root,proto3" json:"Root,omitempty"`
	Internal    bool                  `protobuf:"varint,6,opt,name=Internal,proto3" json:"Internal,omitempty"`
	AbilityFunc string                `protobuf:"bytes,7,opt,name=AbilityFunc,proto3" json:"AbilityFunc,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpRequestMessage) Descriptor deprecated 

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

Deprecated: Use HttpRequestMessage.ProtoReflect.Descriptor instead.

func (*HttpRequestMessage) GetAbilityFunc 

func (x *HttpRequestMessage) GetAbilityFunc() string

func (*HttpRequestMessage) GetBody 

func (x *HttpRequestMessage) GetBody() []byte

func (*HttpRequestMessage) GetHeaders 

func (x *HttpRequestMessage) GetHeaders() map[string]*HeaderVal

func (*HttpRequestMessage) GetInternal 

func (x *HttpRequestMessage) GetInternal() bool

func (*HttpRequestMessage) GetMethod 

func (x *HttpRequestMessage) GetMethod() string

func (*HttpRequestMessage) GetRoot 

func (x *HttpRequestMessage) GetRoot() bool

func (*HttpRequestMessage) GetUrl 

func (x *HttpRequestMessage) GetUrl() string

func (*HttpRequestMessage) ProtoMessage 

func (*HttpRequestMessage) ProtoMessage()

func (*HttpRequestMessage) ProtoReflect 

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

func (*HttpRequestMessage) Reset 

func (x *HttpRequestMessage) Reset()

func (*HttpRequestMessage) String 

func (x *HttpRequestMessage) String() string

type HttpResourceMessage 

type HttpResourceMessage struct {
	ResourceType         HttpResourceMessage_HttpResourceType `` /* 129-byte string literal not displayed */
	ResourceHttpRequest  *HttpRequestMessage                  `protobuf:"bytes,10,opt,name=ResourceHttpRequest,proto3" json:"ResourceHttpRequest,omitempty"`
	ResourceHttpResponse *HttpResponseMessage                 `protobuf:"bytes,11,opt,name=ResourceHttpResponse,proto3" json:"ResourceHttpResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpResourceMessage) Descriptor deprecated 

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

Deprecated: Use HttpResourceMessage.ProtoReflect.Descriptor instead.

func (*HttpResourceMessage) GetResourceHttpRequest 

func (x *HttpResourceMessage) GetResourceHttpRequest() *HttpRequestMessage

func (*HttpResourceMessage) GetResourceHttpResponse 

func (x *HttpResourceMessage) GetResourceHttpResponse() *HttpResponseMessage

func (*HttpResourceMessage) GetResourceType 

func (x *HttpResourceMessage) GetResourceType() HttpResourceMessage_HttpResourceType

func (*HttpResourceMessage) ProtoMessage 

func (*HttpResourceMessage) ProtoMessage()

func (*HttpResourceMessage) ProtoReflect 

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

func (*HttpResourceMessage) Reset 

func (x *HttpResourceMessage) Reset()

func (*HttpResourceMessage) String 

func (x *HttpResourceMessage) String() string

type HttpResourceMessage_HttpResourceType 

type HttpResourceMessage_HttpResourceType int32
const (
	HttpResourceMessage_API     HttpResourceMessage_HttpResourceType = 0
	HttpResourceMessage_Outdoor HttpResourceMessage_HttpResourceType = 1
)

func (HttpResourceMessage_HttpResourceType) Descriptor 

func (HttpResourceMessage_HttpResourceType) Descriptor() protoreflect.EnumDescriptor

func (HttpResourceMessage_HttpResourceType) Enum 

func (x HttpResourceMessage_HttpResourceType) Enum() *HttpResourceMessage_HttpResourceType

func (HttpResourceMessage_HttpResourceType) EnumDescriptor deprecated 

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

Deprecated: Use HttpResourceMessage_HttpResourceType.Descriptor instead.

func (HttpResourceMessage_HttpResourceType) Number 

func (x HttpResourceMessage_HttpResourceType) Number() protoreflect.EnumNumber

func (HttpResourceMessage_HttpResourceType) String 

func (x HttpResourceMessage_HttpResourceType) String() string

func (HttpResourceMessage_HttpResourceType) Type 

func (HttpResourceMessage_HttpResourceType) Type() protoreflect.EnumType

type HttpResponseMessage 

type HttpResponseMessage struct {
	StatusCode int64                 `protobuf:"varint,1,opt,name=StatusCode,proto3" json:"StatusCode,omitempty"`
	Headers    map[string]*HeaderVal `` /* 155-byte string literal not displayed */
	Body       []byte                `protobuf:"bytes,3,opt,name=Body,proto3" json:"Body,omitempty"`
	Error      *ErrorMessage         `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpResponseMessage) Descriptor deprecated 

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

Deprecated: Use HttpResponseMessage.ProtoReflect.Descriptor instead.

func (*HttpResponseMessage) GetBody 

func (x *HttpResponseMessage) GetBody() []byte

func (*HttpResponseMessage) GetError 

func (x *HttpResponseMessage) GetError() *ErrorMessage

func (*HttpResponseMessage) GetHeaders 

func (x *HttpResponseMessage) GetHeaders() map[string]*HeaderVal

func (*HttpResponseMessage) GetStatusCode 

func (x *HttpResponseMessage) GetStatusCode() int64

func (*HttpResponseMessage) ProtoMessage 

func (*HttpResponseMessage) ProtoMessage()

func (*HttpResponseMessage) ProtoReflect 

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

func (*HttpResponseMessage) Reset 

func (x *HttpResponseMessage) Reset()

func (*HttpResponseMessage) String 

func (x *HttpResponseMessage) String() string

type LogMessage 

type LogMessage struct {
	Level   LogMessage_LogLevel `protobuf:"varint,1,opt,name=Level,proto3,enum=protocol.LogMessage_LogLevel" json:"Level,omitempty"`
	Content string              `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated 

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetContent 

func (x *LogMessage) GetContent() string

func (*LogMessage) GetLevel 

func (x *LogMessage) GetLevel() LogMessage_LogLevel

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect 

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

func (*LogMessage) Reset 

func (x *LogMessage) Reset()

func (*LogMessage) String 

func (x *LogMessage) String() string

type LogMessage_LogLevel 

type LogMessage_LogLevel int32
const (
	LogMessage_Trace   LogMessage_LogLevel = 0
	LogMessage_Info    LogMessage_LogLevel = 1
	LogMessage_Warning LogMessage_LogLevel = 2
	LogMessage_Error   LogMessage_LogLevel = 3
)

func (LogMessage_LogLevel) Descriptor 

func (LogMessage_LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogMessage_LogLevel) Enum 

func (x LogMessage_LogLevel) Enum() *LogMessage_LogLevel

func (LogMessage_LogLevel) EnumDescriptor deprecated 

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

Deprecated: Use LogMessage_LogLevel.Descriptor instead.

func (LogMessage_LogLevel) Number 

func (x LogMessage_LogLevel) Number() protoreflect.EnumNumber

func (LogMessage_LogLevel) String 

func (x LogMessage_LogLevel) String() string

func (LogMessage_LogLevel) Type 

func (LogMessage_LogLevel) Type() protoreflect.EnumType

type NodeRecord 

type NodeRecord struct {
	Node         *RouterNode `protobuf:"bytes,1,opt,name=Node,proto3" json:"Node,omitempty"`
	TimestampIn  uint64      `protobuf:"varint,2,opt,name=TimestampIn,proto3" json:"TimestampIn,omitempty"`
	TimestampOut uint64      `protobuf:"varint,3,opt,name=TimestampOut,proto3" json:"TimestampOut,omitempty"`
	HipCount     int32       `protobuf:"varint,4,opt,name=HipCount,proto3" json:"HipCount,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeRecord) Descriptor deprecated 

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

Deprecated: Use NodeRecord.ProtoReflect.Descriptor instead.

func (*NodeRecord) GetHipCount 

func (x *NodeRecord) GetHipCount() int32

func (*NodeRecord) GetNode 

func (x *NodeRecord) GetNode() *RouterNode

func (*NodeRecord) GetTimestampIn 

func (x *NodeRecord) GetTimestampIn() uint64

func (*NodeRecord) GetTimestampOut 

func (x *NodeRecord) GetTimestampOut() uint64

func (*NodeRecord) ProtoMessage 

func (*NodeRecord) ProtoMessage()

func (*NodeRecord) ProtoReflect 

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

func (*NodeRecord) Reset 

func (x *NodeRecord) Reset()

func (*NodeRecord) String 

func (x *NodeRecord) String() string

type NotificationMessage 

type NotificationMessage struct {
	Type      string        `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Timestamp int64         `protobuf:"varint,2,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Data      []byte        `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	Error     *ErrorMessage `protobuf:"bytes,4,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

事件

func (*NotificationMessage) Descriptor deprecated 

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

Deprecated: Use NotificationMessage.ProtoReflect.Descriptor instead.

func (*NotificationMessage) GetData 

func (x *NotificationMessage) GetData() []byte

func (*NotificationMessage) GetError 

func (x *NotificationMessage) GetError() *ErrorMessage

func (*NotificationMessage) GetTimestamp 

func (x *NotificationMessage) GetTimestamp() int64

func (*NotificationMessage) GetType 

func (x *NotificationMessage) GetType() string

func (*NotificationMessage) ProtoMessage 

func (*NotificationMessage) ProtoMessage()

func (*NotificationMessage) ProtoReflect 

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

func (*NotificationMessage) Reset 

func (x *NotificationMessage) Reset()

func (*NotificationMessage) String 

func (x *NotificationMessage) String() string

type PlatformMessage 

type PlatformMessage struct {

	// header
	Header *RouterMessage `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	// body
	Control *ControlMessage `protobuf:"bytes,2,opt,name=Control,proto3" json:"Control,omitempty"`
	Plugin  *PluginMessage  `protobuf:"bytes,3,opt,name=Plugin,proto3" json:"Plugin,omitempty"`
	//  CmdbMessage Cmdb = 15;
	Resource *ResourceMessage `protobuf:"bytes,20,opt,name=Resource,proto3" json:"Resource,omitempty"`
	// contains filtered or unexported fields
}

顶层消息

func (*PlatformMessage) Descriptor deprecated 

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

Deprecated: Use PlatformMessage.ProtoReflect.Descriptor instead.

func (*PlatformMessage) GetControl 

func (x *PlatformMessage) GetControl() *ControlMessage

func (*PlatformMessage) GetHeader 

func (x *PlatformMessage) GetHeader() *RouterMessage

func (*PlatformMessage) GetPlugin 

func (x *PlatformMessage) GetPlugin() *PluginMessage

func (*PlatformMessage) GetResource 

func (x *PlatformMessage) GetResource() *ResourceMessage

func (*PlatformMessage) ProtoMessage 

func (*PlatformMessage) ProtoMessage()

func (*PlatformMessage) ProtoReflect 

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

func (*PlatformMessage) Reset 

func (x *PlatformMessage) Reset()

func (*PlatformMessage) String 

func (x *PlatformMessage) String() string

type PluginDescriptor 

type PluginDescriptor struct {
	ApplicationID      string   `protobuf:"bytes,1,opt,name=ApplicationID,proto3" json:"ApplicationID,omitempty"`
	Name               string   `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	Language           string   `protobuf:"bytes,3,opt,name=Language,proto3" json:"Language,omitempty"`
	LanguageVersion    *Version `protobuf:"bytes,4,opt,name=LanguageVersion,proto3" json:"LanguageVersion,omitempty"`
	ApplicationVersion *Version `protobuf:"bytes,5,opt,name=ApplicationVersion,proto3" json:"ApplicationVersion,omitempty"`
	HostVersion        *Version `protobuf:"bytes,6,opt,name=HostVersion,proto3" json:"HostVersion,omitempty"`
	MinSystemVersion   *Version `protobuf:"bytes,7,opt,name=MinSystemVersion,proto3" json:"MinSystemVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginDescriptor) Descriptor deprecated 

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

Deprecated: Use PluginDescriptor.ProtoReflect.Descriptor instead.

func (*PluginDescriptor) GetApplicationID 

func (x *PluginDescriptor) GetApplicationID() string

func (*PluginDescriptor) GetApplicationVersion 

func (x *PluginDescriptor) GetApplicationVersion() *Version

func (*PluginDescriptor) GetHostVersion 

func (x *PluginDescriptor) GetHostVersion() *Version

func (*PluginDescriptor) GetLanguage 

func (x *PluginDescriptor) GetLanguage() string

func (*PluginDescriptor) GetLanguageVersion 

func (x *PluginDescriptor) GetLanguageVersion() *Version

func (*PluginDescriptor) GetMinSystemVersion 

func (x *PluginDescriptor) GetMinSystemVersion() *Version

func (*PluginDescriptor) GetName 

func (x *PluginDescriptor) GetName() string

func (*PluginDescriptor) ProtoMessage 

func (*PluginDescriptor) ProtoMessage()

func (*PluginDescriptor) ProtoReflect 

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

func (*PluginDescriptor) Reset 

func (x *PluginDescriptor) Reset()

func (*PluginDescriptor) String 

func (x *PluginDescriptor) String() string

type PluginFullDescriptor 

type PluginFullDescriptor struct {
	Application   *PluginDescriptor `protobuf:"bytes,1,opt,name=Application,proto3" json:"Application,omitempty"`
	Configuration string            `protobuf:"bytes,2,opt,name=Configuration,proto3" json:"Configuration,omitempty"`
	Certificate   []byte            `protobuf:"bytes,3,opt,name=Certificate,proto3" json:"Certificate,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginFullDescriptor) Descriptor deprecated 

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

Deprecated: Use PluginFullDescriptor.ProtoReflect.Descriptor instead.

func (*PluginFullDescriptor) GetApplication 

func (x *PluginFullDescriptor) GetApplication() *PluginDescriptor

func (*PluginFullDescriptor) GetCertificate 

func (x *PluginFullDescriptor) GetCertificate() []byte

func (*PluginFullDescriptor) GetConfiguration 

func (x *PluginFullDescriptor) GetConfiguration() string

func (*PluginFullDescriptor) ProtoMessage 

func (*PluginFullDescriptor) ProtoMessage()

func (*PluginFullDescriptor) ProtoReflect 

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

func (*PluginFullDescriptor) Reset 

func (x *PluginFullDescriptor) Reset()

func (*PluginFullDescriptor) String 

func (x *PluginFullDescriptor) String() string

type PluginInstanceDescriptor 

type PluginInstanceDescriptor struct {
	Application *PluginDescriptor `protobuf:"bytes,1,opt,name=Application,proto3" json:"Application,omitempty"`
	InstanceID  string            `protobuf:"bytes,2,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	HostID      string            `protobuf:"bytes,3,opt,name=HostID,proto3" json:"HostID,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginInstanceDescriptor) Descriptor deprecated 

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

Deprecated: Use PluginInstanceDescriptor.ProtoReflect.Descriptor instead.

func (*PluginInstanceDescriptor) GetApplication 

func (x *PluginInstanceDescriptor) GetApplication() *PluginDescriptor

func (*PluginInstanceDescriptor) GetHostID 

func (x *PluginInstanceDescriptor) GetHostID() string

func (*PluginInstanceDescriptor) GetInstanceID 

func (x *PluginInstanceDescriptor) GetInstanceID() string

func (*PluginInstanceDescriptor) ProtoMessage 

func (*PluginInstanceDescriptor) ProtoMessage()

func (*PluginInstanceDescriptor) ProtoReflect 

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

func (*PluginInstanceDescriptor) Reset 

func (x *PluginInstanceDescriptor) Reset()

func (*PluginInstanceDescriptor) String 

func (x *PluginInstanceDescriptor) String() string

type PluginMessage 

type PluginMessage struct {

	// 添加消息路由数据
	Target *PluginInstanceDescriptor `protobuf:"bytes,1,opt,name=Target,proto3" json:"Target,omitempty"`
	Host   *HostDescriptor           `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	// 插件实现的各种http方法，包括对内（前端）和对外（独立的http服务）
	Http *HttpContextMessage `protobuf:"bytes,3,opt,name=Http,proto3" json:"Http,omitempty"`
	// 插件配置变动通知
	Config *ConfigurationMessage `protobuf:"bytes,4,opt,name=Config,proto3" json:"Config,omitempty"`
	// 插件接收的通知消息
	Notification *NotificationMessage `protobuf:"bytes,5,opt,name=Notification,proto3" json:"Notification,omitempty"`
	// 标准能力
	Ability *StandardAbilityMessage `protobuf:"bytes,6,opt,name=Ability,proto3" json:"Ability,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginMessage) Descriptor deprecated 

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

Deprecated: Use PluginMessage.ProtoReflect.Descriptor instead.

func (*PluginMessage) GetAbility 

func (x *PluginMessage) GetAbility() *StandardAbilityMessage

func (*PluginMessage) GetConfig 

func (x *PluginMessage) GetConfig() *ConfigurationMessage

func (*PluginMessage) GetHost 

func (x *PluginMessage) GetHost() *HostDescriptor

func (*PluginMessage) GetHttp 

func (x *PluginMessage) GetHttp() *HttpContextMessage

func (*PluginMessage) GetNotification 

func (x *PluginMessage) GetNotification() *NotificationMessage

func (*PluginMessage) GetTarget 

func (x *PluginMessage) GetTarget() *PluginInstanceDescriptor

func (*PluginMessage) ProtoMessage 

func (*PluginMessage) ProtoMessage()

func (*PluginMessage) ProtoReflect 

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

func (*PluginMessage) Reset 

func (x *PluginMessage) Reset()

func (*PluginMessage) String 

func (x *PluginMessage) String() string

type ResourceMessage 

type ResourceMessage struct {

	// 添加消息头，路由数据
	Sender *PluginInstanceDescriptor `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Host   *HostDescriptor           `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	// no response, ack
	Log       *LogMessage          `protobuf:"bytes,20,opt,name=Log,proto3" json:"Log,omitempty"`
	Database  *DatabaseMessage     `protobuf:"bytes,21,opt,name=Database,proto3" json:"Database,omitempty"`
	Http      *HttpResourceMessage `protobuf:"bytes,22,opt,name=Http,proto3" json:"Http,omitempty"`
	Workspace *WorkspaceMessage    `protobuf:"bytes,23,opt,name=Workspace,proto3" json:"Workspace,omitempty"`
	Event     *EventMessage        `protobuf:"bytes,24,opt,name=Event,proto3" json:"Event,omitempty"`
	Ability   *AbilityMessage      `protobuf:"bytes,25,opt,name=Ability,proto3" json:"Ability,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceMessage) Descriptor deprecated 

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

Deprecated: Use ResourceMessage.ProtoReflect.Descriptor instead.

func (*ResourceMessage) GetAbility 

func (x *ResourceMessage) GetAbility() *AbilityMessage

func (*ResourceMessage) GetDatabase 

func (x *ResourceMessage) GetDatabase() *DatabaseMessage

func (*ResourceMessage) GetEvent 

func (x *ResourceMessage) GetEvent() *EventMessage

func (*ResourceMessage) GetHost 

func (x *ResourceMessage) GetHost() *HostDescriptor

func (*ResourceMessage) GetHttp 

func (x *ResourceMessage) GetHttp() *HttpResourceMessage

func (*ResourceMessage) GetLog 

func (x *ResourceMessage) GetLog() *LogMessage

func (*ResourceMessage) GetSender 

func (x *ResourceMessage) GetSender() *PluginInstanceDescriptor

func (*ResourceMessage) GetWorkspace 

func (x *ResourceMessage) GetWorkspace() *WorkspaceMessage

func (*ResourceMessage) ProtoMessage 

func (*ResourceMessage) ProtoMessage()

func (*ResourceMessage) ProtoReflect 

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

func (*ResourceMessage) Reset 

func (x *ResourceMessage) Reset()

func (*ResourceMessage) String 

func (x *ResourceMessage) String() string

type RouterMessage 

type RouterMessage struct {

	// 消息来源
	Source *RouterNode `protobuf:"bytes,1,opt,name=Source,proto3" json:"Source,omitempty"`
	// 消息目标。适用与点对点的通讯协议
	Distinct *RouterNode `protobuf:"bytes,2,opt,name=Distinct,proto3" json:"Distinct,omitempty"`
	// 消息序列号
	SeqNo uint64 `protobuf:"varint,3,opt,name=SeqNo,proto3" json:"SeqNo,omitempty"`
	// 消息关联序列号列表
	RefSeqNos []uint64 `protobuf:"varint,4,rep,packed,name=RefSeqNos,proto3" json:"RefSeqNos,omitempty"`
	// 消息传递节点清单
	Records []*NodeRecord `protobuf:"bytes,5,rep,name=Records,proto3" json:"Records,omitempty"`
	// contains filtered or unexported fields
}

用于消息路由

func (*RouterMessage) Descriptor deprecated 

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

Deprecated: Use RouterMessage.ProtoReflect.Descriptor instead.

func (*RouterMessage) GetDistinct 

func (x *RouterMessage) GetDistinct() *RouterNode

func (*RouterMessage) GetRecords 

func (x *RouterMessage) GetRecords() []*NodeRecord

func (*RouterMessage) GetRefSeqNos 

func (x *RouterMessage) GetRefSeqNos() []uint64

func (*RouterMessage) GetSeqNo 

func (x *RouterMessage) GetSeqNo() uint64

func (*RouterMessage) GetSource 

func (x *RouterMessage) GetSource() *RouterNode

func (*RouterMessage) ProtoMessage 

func (*RouterMessage) ProtoMessage()

func (*RouterMessage) ProtoReflect 

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

func (*RouterMessage) Reset 

func (x *RouterMessage) Reset()

func (*RouterMessage) String 

func (x *RouterMessage) String() string

type RouterNode 

type RouterNode struct {
	ID   string            `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

//////////////////////////////////////////////////////////

func (*RouterNode) Descriptor deprecated 

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

Deprecated: Use RouterNode.ProtoReflect.Descriptor instead.

func (*RouterNode) GetID 

func (x *RouterNode) GetID() string

func (*RouterNode) GetTags 

func (x *RouterNode) GetTags() map[string]string

func (*RouterNode) ProtoMessage 

func (*RouterNode) ProtoMessage()

func (*RouterNode) ProtoReflect 

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

func (*RouterNode) Reset 

func (x *RouterNode) Reset()

func (*RouterNode) String 

func (x *RouterNode) String() string

type RowMessage 

type RowMessage struct {
	Cell [][]byte `protobuf:"bytes,1,rep,name=Cell,proto3" json:"Cell,omitempty"`
	// contains filtered or unexported fields
}

func (*RowMessage) Descriptor deprecated 

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

Deprecated: Use RowMessage.ProtoReflect.Descriptor instead.

func (*RowMessage) GetCell 

func (x *RowMessage) GetCell() [][]byte

func (*RowMessage) ProtoMessage 

func (*RowMessage) ProtoMessage()

func (*RowMessage) ProtoReflect 

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

func (*RowMessage) Reset 

func (x *RowMessage) Reset()

func (*RowMessage) String 

func (x *RowMessage) String() string

type StandardAbilityMessage 

type StandardAbilityMessage struct {
	AbilityRequest  *StandardAbilityMessage_AbilityRequestMessage  `protobuf:"bytes,1,opt,name=AbilityRequest,proto3" json:"AbilityRequest,omitempty"`
	AbilityResponse *StandardAbilityMessage_AbilityResponseMessage `protobuf:"bytes,2,opt,name=AbilityResponse,proto3" json:"AbilityResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*StandardAbilityMessage) Descriptor deprecated 

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

Deprecated: Use StandardAbilityMessage.ProtoReflect.Descriptor instead.

func (*StandardAbilityMessage) GetAbilityRequest 

func (x *StandardAbilityMessage) GetAbilityRequest() *StandardAbilityMessage_AbilityRequestMessage

func (*StandardAbilityMessage) GetAbilityResponse 

func (x *StandardAbilityMessage) GetAbilityResponse() *StandardAbilityMessage_AbilityResponseMessage

func (*StandardAbilityMessage) ProtoMessage 

func (*StandardAbilityMessage) ProtoMessage()

func (*StandardAbilityMessage) ProtoReflect 

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

func (*StandardAbilityMessage) Reset 

func (x *StandardAbilityMessage) Reset()

func (*StandardAbilityMessage) String 

func (x *StandardAbilityMessage) String() string

type StandardAbilityMessage_AbilityRequestMessage 

type StandardAbilityMessage_AbilityRequestMessage struct {
	Id      string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Type    string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"` // 能力类型，能力的唯一标识
	FuncKey string `protobuf:"bytes,3,opt,name=FuncKey,proto3" json:"FuncKey,omitempty"`
	Args    []byte `protobuf:"bytes,4,opt,name=Args,proto3" json:"Args,omitempty"`
	// contains filtered or unexported fields
}

func (*StandardAbilityMessage_AbilityRequestMessage) Descriptor deprecated 

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

Deprecated: Use StandardAbilityMessage_AbilityRequestMessage.ProtoReflect.Descriptor instead.

func (*StandardAbilityMessage_AbilityRequestMessage) GetArgs 

func (x *StandardAbilityMessage_AbilityRequestMessage) GetArgs() []byte

func (*StandardAbilityMessage_AbilityRequestMessage) GetFuncKey 

func (x *StandardAbilityMessage_AbilityRequestMessage) GetFuncKey() string

func (*StandardAbilityMessage_AbilityRequestMessage) GetId 

func (x *StandardAbilityMessage_AbilityRequestMessage) GetId() string

func (*StandardAbilityMessage_AbilityRequestMessage) GetType 

func (x *StandardAbilityMessage_AbilityRequestMessage) GetType() string

func (*StandardAbilityMessage_AbilityRequestMessage) ProtoMessage 

func (*StandardAbilityMessage_AbilityRequestMessage) ProtoMessage()

func (*StandardAbilityMessage_AbilityRequestMessage) ProtoReflect 

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

func (*StandardAbilityMessage_AbilityRequestMessage) Reset 

func (x *StandardAbilityMessage_AbilityRequestMessage) Reset()

func (*StandardAbilityMessage_AbilityRequestMessage) String 

func (x *StandardAbilityMessage_AbilityRequestMessage) String() string

type StandardAbilityMessage_AbilityResponseMessage 

type StandardAbilityMessage_AbilityResponseMessage struct {
	Data  []byte        `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	Error *ErrorMessage `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

func (*StandardAbilityMessage_AbilityResponseMessage) Descriptor deprecated 

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

Deprecated: Use StandardAbilityMessage_AbilityResponseMessage.ProtoReflect.Descriptor instead.

func (*StandardAbilityMessage_AbilityResponseMessage) GetData 

func (x *StandardAbilityMessage_AbilityResponseMessage) GetData() []byte

func (*StandardAbilityMessage_AbilityResponseMessage) GetError 

func (x *StandardAbilityMessage_AbilityResponseMessage) GetError() *ErrorMessage

func (*StandardAbilityMessage_AbilityResponseMessage) ProtoMessage 

func (*StandardAbilityMessage_AbilityResponseMessage) ProtoMessage()

func (*StandardAbilityMessage_AbilityResponseMessage) ProtoReflect 

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

func (*StandardAbilityMessage_AbilityResponseMessage) Reset 

func (x *StandardAbilityMessage_AbilityResponseMessage) Reset()

func (*StandardAbilityMessage_AbilityResponseMessage) String 

func (x *StandardAbilityMessage_AbilityResponseMessage) String() string

type TableMessage 

type TableMessage struct {
	RowData []*RowMessage `protobuf:"bytes,1,rep,name=RowData,proto3" json:"RowData,omitempty"`
	Column  []*ColumnDesc `protobuf:"bytes,2,rep,name=Column,proto3" json:"Column,omitempty"`
	// contains filtered or unexported fields
}

func (*TableMessage) Descriptor deprecated 

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

Deprecated: Use TableMessage.ProtoReflect.Descriptor instead.

func (*TableMessage) GetColumn 

func (x *TableMessage) GetColumn() []*ColumnDesc

func (*TableMessage) GetRowData 

func (x *TableMessage) GetRowData() []*RowMessage

func (*TableMessage) ProtoMessage 

func (*TableMessage) ProtoMessage()

func (*TableMessage) ProtoReflect 

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

func (*TableMessage) Reset 

func (x *TableMessage) Reset()

func (*TableMessage) String 

func (x *TableMessage) String() string

type Version 

type Version struct {
	Major    int32 `protobuf:"varint,1,opt,name=Major,proto3" json:"Major,omitempty"`
	Minor    int32 `protobuf:"varint,2,opt,name=Minor,proto3" json:"Minor,omitempty"`
	Revision int32 `protobuf:"varint,3,opt,name=Revision,proto3" json:"Revision,omitempty"`
	// contains filtered or unexported fields
}

定义一些通用的数据结构

func (*Version) Descriptor deprecated 

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

Deprecated: Use Version.ProtoReflect.Descriptor instead.

func (*Version) GetMajor 

func (x *Version) GetMajor() int32

func (*Version) GetMinor 

func (x *Version) GetMinor() int32

func (*Version) GetRevision 

func (x *Version) GetRevision() int32

func (*Version) ProtoMessage 

func (*Version) ProtoMessage()

func (*Version) ProtoReflect 

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

func (*Version) Reset 

func (x *Version) Reset()

func (*Version) String 

func (x *Version) String() string

type WorkspaceMessage 

type WorkspaceMessage struct {
	IORequest  *WorkspaceMessage_IORequestMessage  `protobuf:"bytes,1,opt,name=IORequest,proto3" json:"IORequest,omitempty"`
	IOResponse *WorkspaceMessage_IOResponseMessage `protobuf:"bytes,2,opt,name=IOResponse,proto3" json:"IOResponse,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkspaceMessage) Descriptor deprecated 

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

Deprecated: Use WorkspaceMessage.ProtoReflect.Descriptor instead.

func (*WorkspaceMessage) GetIORequest 

func (x *WorkspaceMessage) GetIORequest() *WorkspaceMessage_IORequestMessage

func (*WorkspaceMessage) GetIOResponse 

func (x *WorkspaceMessage) GetIOResponse() *WorkspaceMessage_IOResponseMessage

func (*WorkspaceMessage) ProtoMessage 

func (*WorkspaceMessage) ProtoMessage()

func (*WorkspaceMessage) ProtoReflect 

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

func (*WorkspaceMessage) Reset 

func (x *WorkspaceMessage) Reset()

func (*WorkspaceMessage) String 

func (x *WorkspaceMessage) String() string

type WorkspaceMessage_IOOperationType 

type WorkspaceMessage_IOOperationType int32
const (
	WorkspaceMessage_Create        WorkspaceMessage_IOOperationType = 0
	WorkspaceMessage_Rename        WorkspaceMessage_IOOperationType = 1
	WorkspaceMessage_Remove        WorkspaceMessage_IOOperationType = 2
	WorkspaceMessage_IsExist       WorkspaceMessage_IOOperationType = 3
	WorkspaceMessage_Copy          WorkspaceMessage_IOOperationType = 4
	WorkspaceMessage_List          WorkspaceMessage_IOOperationType = 5
	WorkspaceMessage_IsDir         WorkspaceMessage_IOOperationType = 6
	WorkspaceMessage_CreateDir     WorkspaceMessage_IOOperationType = 7
	WorkspaceMessage_Read          WorkspaceMessage_IOOperationType = 10
	WorkspaceMessage_ReadLines     WorkspaceMessage_IOOperationType = 11
	WorkspaceMessage_WriteBytes    WorkspaceMessage_IOOperationType = 12
	WorkspaceMessage_AppendBytes   WorkspaceMessage_IOOperationType = 13
	WorkspaceMessage_WriteStrings  WorkspaceMessage_IOOperationType = 14
	WorkspaceMessage_AppendStrings WorkspaceMessage_IOOperationType = 15
	WorkspaceMessage_Zip           WorkspaceMessage_IOOperationType = 21
	WorkspaceMessage_UnZip         WorkspaceMessage_IOOperationType = 22
	WorkspaceMessage_Gz            WorkspaceMessage_IOOperationType = 23
	WorkspaceMessage_UnGz          WorkspaceMessage_IOOperationType = 24
	WorkspaceMessage_Hash          WorkspaceMessage_IOOperationType = 25
)

func (WorkspaceMessage_IOOperationType) Descriptor 

func (WorkspaceMessage_IOOperationType) Descriptor() protoreflect.EnumDescriptor

func (WorkspaceMessage_IOOperationType) Enum 

func (x WorkspaceMessage_IOOperationType) Enum() *WorkspaceMessage_IOOperationType

func (WorkspaceMessage_IOOperationType) EnumDescriptor deprecated 

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

Deprecated: Use WorkspaceMessage_IOOperationType.Descriptor instead.

func (WorkspaceMessage_IOOperationType) Number 

func (x WorkspaceMessage_IOOperationType) Number() protoreflect.EnumNumber

func (WorkspaceMessage_IOOperationType) String 

func (x WorkspaceMessage_IOOperationType) String() string

func (WorkspaceMessage_IOOperationType) Type 

func (WorkspaceMessage_IOOperationType) Type() protoreflect.EnumType

type WorkspaceMessage_IORequestMessage 

type WorkspaceMessage_IORequestMessage struct {
	Operation WorkspaceMessage_IOOperationType `protobuf:"varint,1,opt,name=Operation,proto3,enum=protocol.WorkspaceMessage_IOOperationType" json:"Operation,omitempty"`
	FileName  string                           `protobuf:"bytes,2,opt,name=FileName,proto3" json:"FileName,omitempty"`
	// Rename
	NewFileName string `protobuf:"bytes,3,opt,name=NewFileName,proto3" json:"NewFileName,omitempty"`
	// Copy
	CopyFileOldPath string `protobuf:"bytes,4,opt,name=CopyFileOldPath,proto3" json:"CopyFileOldPath,omitempty"`
	CopyFileNewPath string `protobuf:"bytes,5,opt,name=CopyFileNewPath,proto3" json:"CopyFileNewPath,omitempty"`
	// WriteByte
	// AppendByte
	ByteSlice []byte `protobuf:"bytes,6,opt,name=ByteSlice,proto3" json:"ByteSlice,omitempty"`
	// MakeDir
	// Walk
	DirName string `protobuf:"bytes,7,opt,name=DirName,proto3" json:"DirName,omitempty"`
	// WriteString
	// AppendString
	Content []string `protobuf:"bytes,8,rep,name=Content,proto3" json:"Content,omitempty"`
	// CreateZip
	ZipName        string   `protobuf:"bytes,9,opt,name=ZipName,proto3" json:"ZipName,omitempty"`
	ZipTargetFiles []string `protobuf:"bytes,10,rep,name=ZipTargetFiles,proto3" json:"ZipTargetFiles,omitempty"`
	// UnpackZip
	ZipTargetDir string `protobuf:"bytes,11,opt,name=ZipTargetDir,proto3" json:"ZipTargetDir,omitempty"`
	// UnpackGz
	GzTargetFile string `protobuf:"bytes,12,opt,name=GzTargetFile,proto3" json:"GzTargetFile,omitempty"`
	// ReadLines
	ReadLineBegin int32 `protobuf:"varint,13,opt,name=ReadLineBegin,proto3" json:"ReadLineBegin,omitempty"`
	ReadLineEnd   int32 `protobuf:"varint,14,opt,name=ReadLineEnd,proto3" json:"ReadLineEnd,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkspaceMessage_IORequestMessage) Descriptor deprecated 

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

Deprecated: Use WorkspaceMessage_IORequestMessage.ProtoReflect.Descriptor instead.

func (*WorkspaceMessage_IORequestMessage) GetByteSlice 

func (x *WorkspaceMessage_IORequestMessage) GetByteSlice() []byte

func (*WorkspaceMessage_IORequestMessage) GetContent 

func (x *WorkspaceMessage_IORequestMessage) GetContent() []string

func (*WorkspaceMessage_IORequestMessage) GetCopyFileNewPath 

func (x *WorkspaceMessage_IORequestMessage) GetCopyFileNewPath() string

func (*WorkspaceMessage_IORequestMessage) GetCopyFileOldPath 

func (x *WorkspaceMessage_IORequestMessage) GetCopyFileOldPath() string

func (*WorkspaceMessage_IORequestMessage) GetDirName 

func (x *WorkspaceMessage_IORequestMessage) GetDirName() string

func (*WorkspaceMessage_IORequestMessage) GetFileName 

func (x *WorkspaceMessage_IORequestMessage) GetFileName() string

func (*WorkspaceMessage_IORequestMessage) GetGzTargetFile 

func (x *WorkspaceMessage_IORequestMessage) GetGzTargetFile() string

func (*WorkspaceMessage_IORequestMessage) GetNewFileName 

func (x *WorkspaceMessage_IORequestMessage) GetNewFileName() string

func (*WorkspaceMessage_IORequestMessage) GetOperation 

func (x *WorkspaceMessage_IORequestMessage) GetOperation() WorkspaceMessage_IOOperationType

func (*WorkspaceMessage_IORequestMessage) GetReadLineBegin 

func (x *WorkspaceMessage_IORequestMessage) GetReadLineBegin() int32

func (*WorkspaceMessage_IORequestMessage) GetReadLineEnd 

func (x *WorkspaceMessage_IORequestMessage) GetReadLineEnd() int32

func (*WorkspaceMessage_IORequestMessage) GetZipName 

func (x *WorkspaceMessage_IORequestMessage) GetZipName() string

func (*WorkspaceMessage_IORequestMessage) GetZipTargetDir 

func (x *WorkspaceMessage_IORequestMessage) GetZipTargetDir() string

func (*WorkspaceMessage_IORequestMessage) GetZipTargetFiles 

func (x *WorkspaceMessage_IORequestMessage) GetZipTargetFiles() []string

func (*WorkspaceMessage_IORequestMessage) ProtoMessage 

func (*WorkspaceMessage_IORequestMessage) ProtoMessage()

func (*WorkspaceMessage_IORequestMessage) ProtoReflect 

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

func (*WorkspaceMessage_IORequestMessage) Reset 

func (x *WorkspaceMessage_IORequestMessage) Reset()

func (*WorkspaceMessage_IORequestMessage) String 

func (x *WorkspaceMessage_IORequestMessage) String() string

type WorkspaceMessage_IOResponseMessage 

type WorkspaceMessage_IOResponseMessage struct {
	Operation WorkspaceMessage_IOOperationType `protobuf:"varint,1,opt,name=Operation,proto3,enum=protocol.WorkspaceMessage_IOOperationType" json:"Operation,omitempty"`
	Error     *ErrorMessage                    `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	// IsExist
	// IsDir
	Result bool `protobuf:"varint,3,opt,name=Result,proto3" json:"Result,omitempty"`
	// ReadLines
	Lines []string `protobuf:"bytes,4,rep,name=Lines,proto3" json:"Lines,omitempty"`
	// ReadFile
	// Hash
	Data []byte `protobuf:"bytes,5,opt,name=Data,proto3" json:"Data,omitempty"`
	// List
	FileTree []string `protobuf:"bytes,6,rep,name=FileTree,proto3" json:"FileTree,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkspaceMessage_IOResponseMessage) Descriptor deprecated 

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

Deprecated: Use WorkspaceMessage_IOResponseMessage.ProtoReflect.Descriptor instead.

func (*WorkspaceMessage_IOResponseMessage) GetData 

func (x *WorkspaceMessage_IOResponseMessage) GetData() []byte

func (*WorkspaceMessage_IOResponseMessage) GetError 

func (x *WorkspaceMessage_IOResponseMessage) GetError() *ErrorMessage

func (*WorkspaceMessage_IOResponseMessage) GetFileTree 

func (x *WorkspaceMessage_IOResponseMessage) GetFileTree() []string

func (*WorkspaceMessage_IOResponseMessage) GetLines 

func (x *WorkspaceMessage_IOResponseMessage) GetLines() []string

func (*WorkspaceMessage_IOResponseMessage) GetOperation 

func (x *WorkspaceMessage_IOResponseMessage) GetOperation() WorkspaceMessage_IOOperationType

func (*WorkspaceMessage_IOResponseMessage) GetResult 

func (x *WorkspaceMessage_IOResponseMessage) GetResult() bool

func (*WorkspaceMessage_IOResponseMessage) ProtoMessage 

func (*WorkspaceMessage_IOResponseMessage) ProtoMessage()

func (*WorkspaceMessage_IOResponseMessage) ProtoReflect 

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

func (*WorkspaceMessage_IOResponseMessage) Reset 

func (x *WorkspaceMessage_IOResponseMessage) Reset()

func (*WorkspaceMessage_IOResponseMessage) String 

func (x *WorkspaceMessage_IOResponseMessage) String() string

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.