sodor

package
v0.0.0-...-5387342 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2023 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskType_name = map[int32]string{
		0: "TaskType_Null",
		1: "TaskType_Shell",
	}
	TaskType_value = map[string]int32{
		"TaskType_Null":  0,
		"TaskType_Shell": 1,
	}
)

Enum value maps for TaskType.

View Source 
var (
	ScheduleMode_name = map[int32]string{
		0: "ScheduleMode_Null",
		1: "ScheduleMode_None",
		2: "ScheduleMode_Crontab",
	}
	ScheduleMode_value = map[string]int32{
		"ScheduleMode_Null":    0,
		"ScheduleMode_None":    1,
		"ScheduleMode_Crontab": 2,
	}
)

Enum value maps for ScheduleMode.

View Source 
var (
	HostType_name = map[int32]string{
		0: "HostType_Null",
		1: "HostType_IP",
	}
	HostType_value = map[string]int32{
		"HostType_Null": 0,
		"HostType_IP":   1,
	}
)

Enum value maps for HostType.

View Source 
var (
	ThomasType_name = map[int32]string{
		0: "Thomas_Null",
		1: "Thomas_Static",
		2: "Thomas_Dynamic",
	}
	ThomasType_value = map[string]int32{
		"Thomas_Null":    0,
		"Thomas_Static":  1,
		"Thomas_Dynamic": 2,
	}
)

Enum value maps for ThomasType.

View Source 
var (
	AlertPluginName_name = map[int32]string{
		0: "APN_DingDing",
	}
	AlertPluginName_value = map[string]int32{
		"APN_DingDing": 0,
	}
)

Enum value maps for AlertPluginName.

View Source 
var FatController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "FatController",
	HandlerType: (*FatControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandShake",
			Handler:    _FatController_HandShake_Handler,
		},
		{
			MethodName: "UpdateTaskInstance",
			Handler:    _FatController_UpdateTaskInstance_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sodor/fat_ctrl.proto",
}

FatController_ServiceDesc is the grpc.ServiceDesc for FatController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_sodor_fat_ctrl_proto protoreflect.FileDescriptor
View Source 
var File_sodor_sodor_proto protoreflect.FileDescriptor
View Source 
var File_sodor_thomas_proto protoreflect.FileDescriptor
View Source 
var Thomas_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Thomas",
	HandlerType: (*ThomasServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandShake",
			Handler:    _Thomas_HandShake_Handler,
		},
		{
			MethodName: "RunTask",
			Handler:    _Thomas_RunTask_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sodor/thomas.proto",
}

Thomas_ServiceDesc is the grpc.ServiceDesc for Thomas service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterFatControllerServer 

func RegisterFatControllerServer(s grpc.ServiceRegistrar, srv FatControllerServer)

func RegisterThomasServer 

func RegisterThomasServer(s grpc.ServiceRegistrar, srv ThomasServer)

Types

type AlertGroup 

type AlertGroup struct {
	Id              int32   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt        int32   `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt        int32   `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Name            string  `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	PluginInstances []int32 `protobuf:"varint,5,rep,packed,name=plugin_instances,json=pluginInstances,proto3" json:"plugin_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertGroup) Descriptor deprecated 

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

Deprecated: Use AlertGroup.ProtoReflect.Descriptor instead.

func (*AlertGroup) GetCreateAt 

func (x *AlertGroup) GetCreateAt() int32

func (*AlertGroup) GetId 

func (x *AlertGroup) GetId() int32

func (*AlertGroup) GetName 

func (x *AlertGroup) GetName() string

func (*AlertGroup) GetPluginInstances 

func (x *AlertGroup) GetPluginInstances() []int32

func (*AlertGroup) GetUpdateAt 

func (x *AlertGroup) GetUpdateAt() int32

func (*AlertGroup) ProtoMessage 

func (*AlertGroup) ProtoMessage()

func (*AlertGroup) ProtoReflect 

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

func (*AlertGroup) Reset 

func (x *AlertGroup) Reset()

func (*AlertGroup) String 

func (x *AlertGroup) String() string

type AlertGroupReply 

type AlertGroupReply struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertGroupReply) Descriptor deprecated 

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

Deprecated: Use AlertGroupReply.ProtoReflect.Descriptor instead.

func (*AlertGroupReply) GetId 

func (x *AlertGroupReply) GetId() int32

func (*AlertGroupReply) ProtoMessage 

func (*AlertGroupReply) ProtoMessage()

func (*AlertGroupReply) ProtoReflect 

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

func (*AlertGroupReply) Reset 

func (x *AlertGroupReply) Reset()

func (*AlertGroupReply) String 

func (x *AlertGroupReply) String() string

type AlertGroups 

type AlertGroups struct {
	AlertGroups []*AlertGroup `protobuf:"bytes,1,rep,name=alert_groups,json=alertGroups,proto3" json:"alert_groups,omitempty"`
	// contains filtered or unexported fields
}

alert

func (*AlertGroups) Descriptor deprecated 

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

Deprecated: Use AlertGroups.ProtoReflect.Descriptor instead.

func (*AlertGroups) GetAlertGroups 

func (x *AlertGroups) GetAlertGroups() []*AlertGroup

func (*AlertGroups) ProtoMessage 

func (*AlertGroups) ProtoMessage()

func (*AlertGroups) ProtoReflect 

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

func (*AlertGroups) Reset 

func (x *AlertGroups) Reset()

func (*AlertGroups) String 

func (x *AlertGroups) String() string

type AlertPluginDingDing 

type AlertPluginDingDing struct {
	Webhook   string   `protobuf:"bytes,1,opt,name=webhook,proto3" json:"webhook,omitempty"`
	Sign      string   `protobuf:"bytes,2,opt,name=sign,proto3" json:"sign,omitempty"`
	AtMobiles []string `protobuf:"bytes,3,rep,name=at_mobiles,json=atMobiles,proto3" json:"at_mobiles,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertPluginDingDing) Descriptor deprecated 

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

Deprecated: Use AlertPluginDingDing.ProtoReflect.Descriptor instead.

func (*AlertPluginDingDing) GetAtMobiles 

func (x *AlertPluginDingDing) GetAtMobiles() []string

func (*AlertPluginDingDing) GetSign 

func (x *AlertPluginDingDing) GetSign() string

func (*AlertPluginDingDing) GetWebhook 

func (x *AlertPluginDingDing) GetWebhook() string

func (*AlertPluginDingDing) ProtoMessage 

func (*AlertPluginDingDing) ProtoMessage()

func (*AlertPluginDingDing) ProtoReflect 

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

func (*AlertPluginDingDing) Reset 

func (x *AlertPluginDingDing) Reset()

func (*AlertPluginDingDing) String 

func (x *AlertPluginDingDing) String() string

type AlertPluginInstance 

type AlertPluginInstance struct {
	Id         int32                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt   int32                `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt   int32                `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Name       string               `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	PluginName string               `protobuf:"bytes,5,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
	Dingding   *AlertPluginDingDing `protobuf:"bytes,6,opt,name=dingding,proto3" json:"dingding,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertPluginInstance) Descriptor deprecated 

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

Deprecated: Use AlertPluginInstance.ProtoReflect.Descriptor instead.

func (*AlertPluginInstance) GetCreateAt 

func (x *AlertPluginInstance) GetCreateAt() int32

func (*AlertPluginInstance) GetDingding 

func (x *AlertPluginInstance) GetDingding() *AlertPluginDingDing

func (*AlertPluginInstance) GetId 

func (x *AlertPluginInstance) GetId() int32

func (*AlertPluginInstance) GetName 

func (x *AlertPluginInstance) GetName() string

func (*AlertPluginInstance) GetPluginName 

func (x *AlertPluginInstance) GetPluginName() string

func (*AlertPluginInstance) GetUpdateAt 

func (x *AlertPluginInstance) GetUpdateAt() int32

func (*AlertPluginInstance) ProtoMessage 

func (*AlertPluginInstance) ProtoMessage()

func (*AlertPluginInstance) ProtoReflect 

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

func (*AlertPluginInstance) Reset 

func (x *AlertPluginInstance) Reset()

func (*AlertPluginInstance) String 

func (x *AlertPluginInstance) String() string

type AlertPluginInstanceHistories 

type AlertPluginInstanceHistories struct {
	AlertPluginInstanceHistory []*AlertPluginInstanceHistory `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AlertPluginInstanceHistories) Descriptor deprecated 

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

Deprecated: Use AlertPluginInstanceHistories.ProtoReflect.Descriptor instead.

func (*AlertPluginInstanceHistories) GetAlertPluginInstanceHistory 

func (x *AlertPluginInstanceHistories) GetAlertPluginInstanceHistory() []*AlertPluginInstanceHistory

func (*AlertPluginInstanceHistories) ProtoMessage 

func (*AlertPluginInstanceHistories) ProtoMessage()

func (*AlertPluginInstanceHistories) ProtoReflect 

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

func (*AlertPluginInstanceHistories) Reset 

func (x *AlertPluginInstanceHistories) Reset()

func (*AlertPluginInstanceHistories) String 

func (x *AlertPluginInstanceHistories) String() string

type AlertPluginInstanceHistory 

type AlertPluginInstanceHistory struct {
	Id         int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt   int32  `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt   int32  `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	InstanceId int32  `protobuf:"varint,4,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	GroupId    int32  `protobuf:"varint,5,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	AlertMsg   string `protobuf:"bytes,6,opt,name=alert_msg,json=alertMsg,proto3" json:"alert_msg,omitempty"`
	StatusMsg  string `protobuf:"bytes,7,opt,name=status_msg,json=statusMsg,proto3" json:"status_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertPluginInstanceHistory) Descriptor deprecated 

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

Deprecated: Use AlertPluginInstanceHistory.ProtoReflect.Descriptor instead.

func (*AlertPluginInstanceHistory) GetAlertMsg 

func (x *AlertPluginInstanceHistory) GetAlertMsg() string

func (*AlertPluginInstanceHistory) GetCreateAt 

func (x *AlertPluginInstanceHistory) GetCreateAt() int32

func (*AlertPluginInstanceHistory) GetGroupId 

func (x *AlertPluginInstanceHistory) GetGroupId() int32

func (*AlertPluginInstanceHistory) GetId 

func (x *AlertPluginInstanceHistory) GetId() int32

func (*AlertPluginInstanceHistory) GetInstanceId 

func (x *AlertPluginInstanceHistory) GetInstanceId() int32

func (*AlertPluginInstanceHistory) GetStatusMsg 

func (x *AlertPluginInstanceHistory) GetStatusMsg() string

func (*AlertPluginInstanceHistory) GetUpdateAt 

func (x *AlertPluginInstanceHistory) GetUpdateAt() int32

func (*AlertPluginInstanceHistory) ProtoMessage 

func (*AlertPluginInstanceHistory) ProtoMessage()

func (*AlertPluginInstanceHistory) ProtoReflect 

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

func (*AlertPluginInstanceHistory) Reset 

func (x *AlertPluginInstanceHistory) Reset()

func (*AlertPluginInstanceHistory) String 

func (x *AlertPluginInstanceHistory) String() string

type AlertPluginInstances 

type AlertPluginInstances struct {
	AlertPluginInstances []*AlertPluginInstance `protobuf:"bytes,1,rep,name=alert_plugin_instances,json=alertPluginInstances,proto3" json:"alert_plugin_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertPluginInstances) Descriptor deprecated 

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

Deprecated: Use AlertPluginInstances.ProtoReflect.Descriptor instead.

func (*AlertPluginInstances) GetAlertPluginInstances 

func (x *AlertPluginInstances) GetAlertPluginInstances() []*AlertPluginInstance

func (*AlertPluginInstances) ProtoMessage 

func (*AlertPluginInstances) ProtoMessage()

func (*AlertPluginInstances) ProtoReflect 

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

func (*AlertPluginInstances) Reset 

func (x *AlertPluginInstances) Reset()

func (*AlertPluginInstances) String 

func (x *AlertPluginInstances) String() string

type AlertPluginName 

type AlertPluginName int32
const (
	AlertPluginName_APN_DingDing AlertPluginName = 0
)

func (AlertPluginName) Descriptor 

func (AlertPluginName) Descriptor() protoreflect.EnumDescriptor

func (AlertPluginName) Enum 

func (x AlertPluginName) Enum() *AlertPluginName

func (AlertPluginName) EnumDescriptor deprecated 

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

Deprecated: Use AlertPluginName.Descriptor instead.

func (AlertPluginName) Number 

func (x AlertPluginName) Number() protoreflect.EnumNumber

func (AlertPluginName) String 

func (x AlertPluginName) String() string

func (AlertPluginName) Type 

func (AlertPluginName) Type() protoreflect.EnumType

type AlertPluginReply 

type AlertPluginReply struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AlertPluginReply) Descriptor deprecated 

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

Deprecated: Use AlertPluginReply.ProtoReflect.Descriptor instead.

func (*AlertPluginReply) GetId 

func (x *AlertPluginReply) GetId() int32

func (*AlertPluginReply) ProtoMessage 

func (*AlertPluginReply) ProtoMessage()

func (*AlertPluginReply) ProtoReflect 

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

func (*AlertPluginReply) Reset 

func (x *AlertPluginReply) Reset()

func (*AlertPluginReply) String 

func (x *AlertPluginReply) String() string

type EmptyResponse 

type EmptyResponse struct {
	// contains filtered or unexported fields
}

func (*EmptyResponse) Descriptor deprecated 

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

Deprecated: Use EmptyResponse.ProtoReflect.Descriptor instead.

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) ProtoReflect 

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

func (*EmptyResponse) Reset 

func (x *EmptyResponse) Reset()

func (*EmptyResponse) String 

func (x *EmptyResponse) String() string

type FatControllerClient 

type FatControllerClient interface {
	// for Thomas_Dynamic
	// Thomas Send HandShae(ThomasInfo:id/host/port/pid/...) To FatController
	HandShake(ctx context.Context, in *ThomasInfo, opts ...grpc.CallOption) (*FatCtrlInfos, error)
	UpdateTaskInstance(ctx context.Context, in *TaskInstance, opts ...grpc.CallOption) (*EmptyResponse, error)
}

FatControllerClient is the client API for FatController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFatControllerClient 

func NewFatControllerClient(cc grpc.ClientConnInterface) FatControllerClient

type FatControllerServer 

type FatControllerServer interface {
	// for Thomas_Dynamic
	// Thomas Send HandShae(ThomasInfo:id/host/port/pid/...) To FatController
	HandShake(context.Context, *ThomasInfo) (*FatCtrlInfos, error)
	UpdateTaskInstance(context.Context, *TaskInstance) (*EmptyResponse, error)
	// contains filtered or unexported methods
}

FatControllerServer is the server API for FatController service. All implementations must embed UnimplementedFatControllerServer for forward compatibility

type FatCtrlInfo 

type FatCtrlInfo struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt int32  `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt int32  `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Name     string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Version  string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Proto    string `protobuf:"bytes,6,opt,name=proto,proto3" json:"proto,omitempty"`
	Host     string `protobuf:"bytes,7,opt,name=host,proto3" json:"host,omitempty"`
	Port     int32  `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

fat_ctrl

func (*FatCtrlInfo) Descriptor deprecated 

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

Deprecated: Use FatCtrlInfo.ProtoReflect.Descriptor instead.

func (*FatCtrlInfo) GetCreateAt 

func (x *FatCtrlInfo) GetCreateAt() int32

func (*FatCtrlInfo) GetHost 

func (x *FatCtrlInfo) GetHost() string

func (*FatCtrlInfo) GetId 

func (x *FatCtrlInfo) GetId() int32

func (*FatCtrlInfo) GetName 

func (x *FatCtrlInfo) GetName() string

func (*FatCtrlInfo) GetPort 

func (x *FatCtrlInfo) GetPort() int32

func (*FatCtrlInfo) GetProto 

func (x *FatCtrlInfo) GetProto() string

func (*FatCtrlInfo) GetUpdateAt 

func (x *FatCtrlInfo) GetUpdateAt() int32

func (*FatCtrlInfo) GetVersion 

func (x *FatCtrlInfo) GetVersion() string

func (*FatCtrlInfo) ProtoMessage 

func (*FatCtrlInfo) ProtoMessage()

func (*FatCtrlInfo) ProtoReflect 

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

func (*FatCtrlInfo) Reset 

func (x *FatCtrlInfo) Reset()

func (*FatCtrlInfo) String 

func (x *FatCtrlInfo) String() string

type FatCtrlInfos 

type FatCtrlInfos struct {
	FatCtrlInfos []*FatCtrlInfo `protobuf:"bytes,1,rep,name=fat_ctrl_infos,json=fatCtrlInfos,proto3" json:"fat_ctrl_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*FatCtrlInfos) Descriptor deprecated 

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

Deprecated: Use FatCtrlInfos.ProtoReflect.Descriptor instead.

func (*FatCtrlInfos) GetFatCtrlInfos 

func (x *FatCtrlInfos) GetFatCtrlInfos() []*FatCtrlInfo

func (*FatCtrlInfos) ProtoMessage 

func (*FatCtrlInfos) ProtoMessage()

func (*FatCtrlInfos) ProtoReflect 

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

func (*FatCtrlInfos) Reset 

func (x *FatCtrlInfos) Reset()

func (*FatCtrlInfos) String 

func (x *FatCtrlInfos) String() string

type HandShakeWithThomasRequest 

type HandShakeWithThomasRequest struct {
	Thomas   *ThomasInfo   `protobuf:"bytes,1,opt,name=thomas,proto3" json:"thomas,omitempty"`
	FatCtrls *FatCtrlInfos `protobuf:"bytes,2,opt,name=fat_ctrls,json=fatCtrls,proto3" json:"fat_ctrls,omitempty"`
	// contains filtered or unexported fields
}

func (*HandShakeWithThomasRequest) Descriptor deprecated 

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

Deprecated: Use HandShakeWithThomasRequest.ProtoReflect.Descriptor instead.

func (*HandShakeWithThomasRequest) GetFatCtrls 

func (x *HandShakeWithThomasRequest) GetFatCtrls() *FatCtrlInfos

func (*HandShakeWithThomasRequest) GetThomas 

func (x *HandShakeWithThomasRequest) GetThomas() *ThomasInfo

func (*HandShakeWithThomasRequest) ProtoMessage 

func (*HandShakeWithThomasRequest) ProtoMessage()

func (*HandShakeWithThomasRequest) ProtoReflect 

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

func (*HandShakeWithThomasRequest) Reset 

func (x *HandShakeWithThomasRequest) Reset()

func (*HandShakeWithThomasRequest) String 

func (x *HandShakeWithThomasRequest) String() string

type Host 

type Host struct {
	Type HostType `protobuf:"varint,1,opt,name=type,proto3,enum=HostType" json:"type,omitempty"`
	Node string   `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

func (*Host) Descriptor deprecated 

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

Deprecated: Use Host.ProtoReflect.Descriptor instead.

func (*Host) GetNode 

func (x *Host) GetNode() string

func (*Host) GetType 

func (x *Host) GetType() HostType

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

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

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) String 

func (x *Host) String() string

type HostType 

type HostType int32
const (
	HostType_HostType_Null HostType = 0
	HostType_HostType_IP   HostType = 1
)

func (HostType) Descriptor 

func (HostType) Descriptor() protoreflect.EnumDescriptor

func (HostType) Enum 

func (x HostType) Enum() *HostType

func (HostType) EnumDescriptor deprecated 

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

Deprecated: Use HostType.Descriptor instead.

func (HostType) Number 

func (x HostType) Number() protoreflect.EnumNumber

func (HostType) String 

func (x HostType) String() string

func (HostType) Type 

func (HostType) Type() protoreflect.EnumType

type Job 

type Job struct {
	Id           int32           `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt     int32           `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt     int32           `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Name         string          `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	ScheduleMode ScheduleMode    `protobuf:"varint,5,opt,name=schedule_mode,json=scheduleMode,proto3,enum=ScheduleMode" json:"schedule_mode,omitempty"`
	RoutineSpec  *RoutineSpec    `protobuf:"bytes,6,opt,name=routine_spec,json=routineSpec,proto3" json:"routine_spec,omitempty"`
	Tasks        []*Task         `protobuf:"bytes,7,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Relations    []*TaskRelation `protobuf:"bytes,8,rep,name=relations,proto3" json:"relations,omitempty"`
	AlertGroupId int32           `protobuf:"varint,9,opt,name=alert_group_id,json=alertGroupId,proto3" json:"alert_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAlertGroupId 

func (x *Job) GetAlertGroupId() int32

func (*Job) GetCreateAt 

func (x *Job) GetCreateAt() int32

func (*Job) GetId 

func (x *Job) GetId() int32

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetRelations 

func (x *Job) GetRelations() []*TaskRelation

func (*Job) GetRoutineSpec 

func (x *Job) GetRoutineSpec() *RoutineSpec

func (*Job) GetScheduleMode 

func (x *Job) GetScheduleMode() ScheduleMode

func (*Job) GetTasks 

func (x *Job) GetTasks() []*Task

func (*Job) GetUpdateAt 

func (x *Job) GetUpdateAt() int32

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobInstance 

type JobInstance struct {
	Id         int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt   int32  `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt   int32  `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	JobId      int32  `protobuf:"varint,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ScheduleTs int32  `protobuf:"varint,5,opt,name=schedule_ts,json=scheduleTs,proto3" json:"schedule_ts,omitempty"`
	StartTs    int32  `protobuf:"varint,6,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	StopTs     int32  `protobuf:"varint,7,opt,name=stop_ts,json=stopTs,proto3" json:"stop_ts,omitempty"`
	ExitCode   int32  `protobuf:"varint,8,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	ExitMsg    string `protobuf:"bytes,9,opt,name=exit_msg,json=exitMsg,proto3" json:"exit_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInstance) Descriptor deprecated 

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

Deprecated: Use JobInstance.ProtoReflect.Descriptor instead.

func (*JobInstance) GetCreateAt 

func (x *JobInstance) GetCreateAt() int32

func (*JobInstance) GetExitCode 

func (x *JobInstance) GetExitCode() int32

func (*JobInstance) GetExitMsg 

func (x *JobInstance) GetExitMsg() string

func (*JobInstance) GetId 

func (x *JobInstance) GetId() int32

func (*JobInstance) GetJobId 

func (x *JobInstance) GetJobId() int32

func (*JobInstance) GetScheduleTs 

func (x *JobInstance) GetScheduleTs() int32

func (*JobInstance) GetStartTs 

func (x *JobInstance) GetStartTs() int32

func (*JobInstance) GetStopTs 

func (x *JobInstance) GetStopTs() int32

func (*JobInstance) GetUpdateAt 

func (x *JobInstance) GetUpdateAt() int32

func (*JobInstance) ProtoMessage 

func (*JobInstance) ProtoMessage()

func (*JobInstance) ProtoReflect 

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

func (*JobInstance) Reset 

func (x *JobInstance) Reset()

func (*JobInstance) String 

func (x *JobInstance) String() string

type JobInstances 

type JobInstances struct {
	JobInstances []*JobInstance `protobuf:"bytes,1,rep,name=job_instances,json=jobInstances,proto3" json:"job_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInstances) Descriptor deprecated 

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

Deprecated: Use JobInstances.ProtoReflect.Descriptor instead.

func (*JobInstances) GetJobInstances 

func (x *JobInstances) GetJobInstances() []*JobInstance

func (*JobInstances) ProtoMessage 

func (*JobInstances) ProtoMessage()

func (*JobInstances) ProtoReflect 

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

func (*JobInstances) Reset 

func (x *JobInstances) Reset()

func (*JobInstances) String 

func (x *JobInstances) String() string

type JobReply 

type JobReply struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobReply) Descriptor deprecated 

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

Deprecated: Use JobReply.ProtoReflect.Descriptor instead.

func (*JobReply) GetId 

func (x *JobReply) GetId() int32

func (*JobReply) ProtoMessage 

func (*JobReply) ProtoMessage()

func (*JobReply) ProtoReflect 

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

func (*JobReply) Reset 

func (x *JobReply) Reset()

func (*JobReply) String 

func (x *JobReply) String() string

type Jobs 

type Jobs struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*Jobs) Descriptor deprecated 

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

Deprecated: Use Jobs.ProtoReflect.Descriptor instead.

func (*Jobs) GetJobs 

func (x *Jobs) GetJobs() []*Job

func (*Jobs) ProtoMessage 

func (*Jobs) ProtoMessage()

func (*Jobs) ProtoReflect 

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

func (*Jobs) Reset 

func (x *Jobs) Reset()

func (*Jobs) String 

func (x *Jobs) String() string

type RoutineSpec 

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

func (*RoutineSpec) Descriptor deprecated 

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

Deprecated: Use RoutineSpec.ProtoReflect.Descriptor instead.

func (*RoutineSpec) GetCtSpec 

func (x *RoutineSpec) GetCtSpec() string

func (*RoutineSpec) ProtoMessage 

func (*RoutineSpec) ProtoMessage()

func (*RoutineSpec) ProtoReflect 

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

func (*RoutineSpec) Reset 

func (x *RoutineSpec) Reset()

func (*RoutineSpec) String 

func (x *RoutineSpec) String() string

type RunTaskRequest 

type RunTaskRequest struct {
	TaskInstance *TaskInstance `protobuf:"bytes,1,opt,name=task_instance,json=taskInstance,proto3" json:"task_instance,omitempty"`
	Task         *Task         `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*RunTaskRequest) Descriptor deprecated 

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

Deprecated: Use RunTaskRequest.ProtoReflect.Descriptor instead.

func (*RunTaskRequest) GetTask 

func (x *RunTaskRequest) GetTask() *Task

func (*RunTaskRequest) GetTaskInstance 

func (x *RunTaskRequest) GetTaskInstance() *TaskInstance

func (*RunTaskRequest) ProtoMessage 

func (*RunTaskRequest) ProtoMessage()

func (*RunTaskRequest) ProtoReflect 

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

func (*RunTaskRequest) Reset 

func (x *RunTaskRequest) Reset()

func (*RunTaskRequest) String 

func (x *RunTaskRequest) String() string

type ScheduleMode 

type ScheduleMode int32
const (
	ScheduleMode_ScheduleMode_Null    ScheduleMode = 0
	ScheduleMode_ScheduleMode_None    ScheduleMode = 1
	ScheduleMode_ScheduleMode_Crontab ScheduleMode = 2
)

func (ScheduleMode) Descriptor 

func (ScheduleMode) Descriptor() protoreflect.EnumDescriptor

func (ScheduleMode) Enum 

func (x ScheduleMode) Enum() *ScheduleMode

func (ScheduleMode) EnumDescriptor deprecated 

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

Deprecated: Use ScheduleMode.Descriptor instead.

func (ScheduleMode) Number 

func (x ScheduleMode) Number() protoreflect.EnumNumber

func (ScheduleMode) String 

func (x ScheduleMode) String() string

func (ScheduleMode) Type 

func (ScheduleMode) Type() protoreflect.EnumType

type Task 

type Task struct {
	Id           int32    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt     int32    `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt     int32    `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	JobId        int32    `protobuf:"varint,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Name         string   `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	RunningHosts []*Host  `protobuf:"bytes,6,rep,name=running_hosts,json=runningHosts,proto3" json:"running_hosts,omitempty"`
	Type         TaskType `protobuf:"varint,7,opt,name=type,proto3,enum=TaskType" json:"type,omitempty"`
	Content      string   `protobuf:"bytes,8,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetContent 

func (x *Task) GetContent() string

func (*Task) GetCreateAt 

func (x *Task) GetCreateAt() int32

func (*Task) GetId 

func (x *Task) GetId() int32

func (*Task) GetJobId 

func (x *Task) GetJobId() int32

func (*Task) GetName 

func (x *Task) GetName() string

func (*Task) GetRunningHosts 

func (x *Task) GetRunningHosts() []*Host

func (*Task) GetType 

func (x *Task) GetType() TaskType

func (*Task) GetUpdateAt 

func (x *Task) GetUpdateAt() int32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskInstance 

type TaskInstance struct {
	Id            int32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt      int32            `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt      int32            `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	JobId         int32            `protobuf:"varint,4,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	TaskId        int32            `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	JobInstanceId int32            `protobuf:"varint,6,opt,name=job_instance_id,json=jobInstanceId,proto3" json:"job_instance_id,omitempty"`
	ParsedContent string           `protobuf:"bytes,7,opt,name=parsed_content,json=parsedContent,proto3" json:"parsed_content,omitempty"`
	StartTs       int32            `protobuf:"varint,8,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	StopTs        int32            `protobuf:"varint,9,opt,name=stop_ts,json=stopTs,proto3" json:"stop_ts,omitempty"`
	Host          string           `protobuf:"bytes,10,opt,name=host,proto3" json:"host,omitempty"`
	Pid           int32            `protobuf:"varint,11,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitCode      int32            `protobuf:"varint,12,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	ExitMsg       string           `protobuf:"bytes,13,opt,name=exit_msg,json=exitMsg,proto3" json:"exit_msg,omitempty"`
	OutputVars    *structpb.Struct `protobuf:"bytes,14,opt,name=output_vars,json=outputVars,proto3" json:"output_vars,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInstance) Descriptor deprecated 

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

Deprecated: Use TaskInstance.ProtoReflect.Descriptor instead.

func (*TaskInstance) GetCreateAt 

func (x *TaskInstance) GetCreateAt() int32

func (*TaskInstance) GetExitCode 

func (x *TaskInstance) GetExitCode() int32

func (*TaskInstance) GetExitMsg 

func (x *TaskInstance) GetExitMsg() string

func (*TaskInstance) GetHost 

func (x *TaskInstance) GetHost() string

func (*TaskInstance) GetId 

func (x *TaskInstance) GetId() int32

func (*TaskInstance) GetJobId 

func (x *TaskInstance) GetJobId() int32

func (*TaskInstance) GetJobInstanceId 

func (x *TaskInstance) GetJobInstanceId() int32

func (*TaskInstance) GetOutputVars 

func (x *TaskInstance) GetOutputVars() *structpb.Struct

func (*TaskInstance) GetParsedContent 

func (x *TaskInstance) GetParsedContent() string

func (*TaskInstance) GetPid 

func (x *TaskInstance) GetPid() int32

func (*TaskInstance) GetStartTs 

func (x *TaskInstance) GetStartTs() int32

func (*TaskInstance) GetStopTs 

func (x *TaskInstance) GetStopTs() int32

func (*TaskInstance) GetTaskId 

func (x *TaskInstance) GetTaskId() int32

func (*TaskInstance) GetUpdateAt 

func (x *TaskInstance) GetUpdateAt() int32

func (*TaskInstance) ProtoMessage 

func (*TaskInstance) ProtoMessage()

func (*TaskInstance) ProtoReflect 

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

func (*TaskInstance) Reset 

func (x *TaskInstance) Reset()

func (*TaskInstance) String 

func (x *TaskInstance) String() string

type TaskInstances 

type TaskInstances struct {
	TaskInstances []*TaskInstance `protobuf:"bytes,1,rep,name=task_instances,json=taskInstances,proto3" json:"task_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInstances) Descriptor deprecated 

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

Deprecated: Use TaskInstances.ProtoReflect.Descriptor instead.

func (*TaskInstances) GetTaskInstances 

func (x *TaskInstances) GetTaskInstances() []*TaskInstance

func (*TaskInstances) ProtoMessage 

func (*TaskInstances) ProtoMessage()

func (*TaskInstances) ProtoReflect 

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

func (*TaskInstances) Reset 

func (x *TaskInstances) Reset()

func (*TaskInstances) String 

func (x *TaskInstances) String() string

type TaskRelation 

type TaskRelation struct {
	FromTask string `protobuf:"bytes,1,opt,name=from_task,json=fromTask,proto3" json:"from_task,omitempty"`
	ToTask   string `protobuf:"bytes,2,opt,name=to_task,json=toTask,proto3" json:"to_task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskRelation) Descriptor deprecated 

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

Deprecated: Use TaskRelation.ProtoReflect.Descriptor instead.

func (*TaskRelation) GetFromTask 

func (x *TaskRelation) GetFromTask() string

func (*TaskRelation) GetToTask 

func (x *TaskRelation) GetToTask() string

func (*TaskRelation) ProtoMessage 

func (*TaskRelation) ProtoMessage()

func (*TaskRelation) ProtoReflect 

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

func (*TaskRelation) Reset 

func (x *TaskRelation) Reset()

func (*TaskRelation) String 

func (x *TaskRelation) String() string

type TaskType 

type TaskType int32
const (
	TaskType_TaskType_Null  TaskType = 0
	TaskType_TaskType_Shell TaskType = 1
)

func (TaskType) Descriptor 

func (TaskType) Descriptor() protoreflect.EnumDescriptor

func (TaskType) Enum 

func (x TaskType) Enum() *TaskType

func (TaskType) EnumDescriptor deprecated 

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

Deprecated: Use TaskType.Descriptor instead.

func (TaskType) Number 

func (x TaskType) Number() protoreflect.EnumNumber

func (TaskType) String 

func (x TaskType) String() string

func (TaskType) Type 

func (TaskType) Type() protoreflect.EnumType

type ThomasClient 

type ThomasClient interface {
	// for Thomas_Static
	// FatController Send HandShae(ThomasInfo:ID) To Thomas
	HandShake(ctx context.Context, in *HandShakeWithThomasRequest, opts ...grpc.CallOption) (*ThomasInfo, error)
	RunTask(ctx context.Context, in *RunTaskRequest, opts ...grpc.CallOption) (*EmptyResponse, error)
}

ThomasClient is the client API for Thomas service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewThomasClient 

func NewThomasClient(cc grpc.ClientConnInterface) ThomasClient

type ThomasInfo 

type ThomasInfo struct {
	Id            int32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt      int32            `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt      int32            `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Name          string           `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Version       string           `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Tags          []string         `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	Proto         string           `protobuf:"bytes,7,opt,name=proto,proto3" json:"proto,omitempty"`
	Host          string           `protobuf:"bytes,8,opt,name=host,proto3" json:"host,omitempty"`
	Port          int32            `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	Pid           int32            `protobuf:"varint,10,opt,name=pid,proto3" json:"pid,omitempty"`
	StartTime     int32            `protobuf:"varint,11,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	HeartBeatTime int32            `protobuf:"varint,12,opt,name=heart_beat_time,json=heartBeatTime,proto3" json:"heart_beat_time,omitempty"`
	ThomasType    ThomasType       `protobuf:"varint,13,opt,name=thomas_type,json=thomasType,proto3,enum=ThomasType" json:"thomas_type,omitempty"`
	Status        string           `protobuf:"bytes,14,opt,name=status,proto3" json:"status,omitempty"`
	LatestMetrics *structpb.Struct `protobuf:"bytes,15,opt,name=latest_metrics,json=latestMetrics,proto3" json:"latest_metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasInfo) Descriptor deprecated 

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

Deprecated: Use ThomasInfo.ProtoReflect.Descriptor instead.

func (*ThomasInfo) GetCreateAt 

func (x *ThomasInfo) GetCreateAt() int32

func (*ThomasInfo) GetHeartBeatTime 

func (x *ThomasInfo) GetHeartBeatTime() int32

func (*ThomasInfo) GetHost 

func (x *ThomasInfo) GetHost() string

func (*ThomasInfo) GetId 

func (x *ThomasInfo) GetId() int32

func (*ThomasInfo) GetLatestMetrics 

func (x *ThomasInfo) GetLatestMetrics() *structpb.Struct

func (*ThomasInfo) GetName 

func (x *ThomasInfo) GetName() string

func (*ThomasInfo) GetPid 

func (x *ThomasInfo) GetPid() int32

func (*ThomasInfo) GetPort 

func (x *ThomasInfo) GetPort() int32

func (*ThomasInfo) GetProto 

func (x *ThomasInfo) GetProto() string

func (*ThomasInfo) GetStartTime 

func (x *ThomasInfo) GetStartTime() int32

func (*ThomasInfo) GetStatus 

func (x *ThomasInfo) GetStatus() string

func (*ThomasInfo) GetTags 

func (x *ThomasInfo) GetTags() []string

func (*ThomasInfo) GetThomasType 

func (x *ThomasInfo) GetThomasType() ThomasType

func (*ThomasInfo) GetUpdateAt 

func (x *ThomasInfo) GetUpdateAt() int32

func (*ThomasInfo) GetVersion 

func (x *ThomasInfo) GetVersion() string

func (*ThomasInfo) ProtoMessage 

func (*ThomasInfo) ProtoMessage()

func (*ThomasInfo) ProtoReflect 

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

func (*ThomasInfo) Reset 

func (x *ThomasInfo) Reset()

func (*ThomasInfo) String 

func (x *ThomasInfo) String() string

type ThomasInfos 

type ThomasInfos struct {
	ThomasInfos []*ThomasInfo `protobuf:"bytes,1,rep,name=thomas_infos,json=thomasInfos,proto3" json:"thomas_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasInfos) Descriptor deprecated 

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

Deprecated: Use ThomasInfos.ProtoReflect.Descriptor instead.

func (*ThomasInfos) GetThomasInfos 

func (x *ThomasInfos) GetThomasInfos() []*ThomasInfo

func (*ThomasInfos) ProtoMessage 

func (*ThomasInfos) ProtoMessage()

func (*ThomasInfos) ProtoReflect 

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

func (*ThomasInfos) Reset 

func (x *ThomasInfos) Reset()

func (*ThomasInfos) String 

func (x *ThomasInfos) String() string

type ThomasInstance 

type ThomasInstance struct {
	Thomas  *ThomasInfo      `protobuf:"bytes,1,opt,name=thomas,proto3" json:"thomas,omitempty"`
	Metrics []*ThomasMetrics `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasInstance) Descriptor deprecated 

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

Deprecated: Use ThomasInstance.ProtoReflect.Descriptor instead.

func (*ThomasInstance) GetMetrics 

func (x *ThomasInstance) GetMetrics() []*ThomasMetrics

func (*ThomasInstance) GetThomas 

func (x *ThomasInstance) GetThomas() *ThomasInfo

func (*ThomasInstance) ProtoMessage 

func (*ThomasInstance) ProtoMessage()

func (*ThomasInstance) ProtoReflect 

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

func (*ThomasInstance) Reset 

func (x *ThomasInstance) Reset()

func (*ThomasInstance) String 

func (x *ThomasInstance) String() string

type ThomasInstances 

type ThomasInstances struct {
	ThomasInstances []*ThomasInstance `protobuf:"bytes,1,rep,name=thomas_instances,json=thomasInstances,proto3" json:"thomas_instances,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasInstances) Descriptor deprecated 

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

Deprecated: Use ThomasInstances.ProtoReflect.Descriptor instead.

func (*ThomasInstances) GetThomasInstances 

func (x *ThomasInstances) GetThomasInstances() []*ThomasInstance

func (*ThomasInstances) ProtoMessage 

func (*ThomasInstances) ProtoMessage()

func (*ThomasInstances) ProtoReflect 

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

func (*ThomasInstances) Reset 

func (x *ThomasInstances) Reset()

func (*ThomasInstances) String 

func (x *ThomasInstances) String() string

type ThomasMetrics 

type ThomasMetrics struct {
	Id       int32            `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateAt int32            `protobuf:"varint,2,opt,name=create_at,json=createAt,proto3" json:"create_at,omitempty"`
	UpdateAt int32            `protobuf:"varint,3,opt,name=update_at,json=updateAt,proto3" json:"update_at,omitempty"`
	Metrics  *structpb.Struct `protobuf:"bytes,4,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasMetrics) Descriptor deprecated 

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

Deprecated: Use ThomasMetrics.ProtoReflect.Descriptor instead.

func (*ThomasMetrics) GetCreateAt 

func (x *ThomasMetrics) GetCreateAt() int32

func (*ThomasMetrics) GetId 

func (x *ThomasMetrics) GetId() int32

func (*ThomasMetrics) GetMetrics 

func (x *ThomasMetrics) GetMetrics() *structpb.Struct

func (*ThomasMetrics) GetUpdateAt 

func (x *ThomasMetrics) GetUpdateAt() int32

func (*ThomasMetrics) ProtoMessage 

func (*ThomasMetrics) ProtoMessage()

func (*ThomasMetrics) ProtoReflect 

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

func (*ThomasMetrics) Reset 

func (x *ThomasMetrics) Reset()

func (*ThomasMetrics) String 

func (x *ThomasMetrics) String() string

type ThomasReply 

type ThomasReply struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ThomasReply) Descriptor deprecated 

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

Deprecated: Use ThomasReply.ProtoReflect.Descriptor instead.

func (*ThomasReply) GetId 

func (x *ThomasReply) GetId() int32

func (*ThomasReply) ProtoMessage 

func (*ThomasReply) ProtoMessage()

func (*ThomasReply) ProtoReflect 

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

func (*ThomasReply) Reset 

func (x *ThomasReply) Reset()

func (*ThomasReply) String 

func (x *ThomasReply) String() string

type ThomasServer 

type ThomasServer interface {
	// for Thomas_Static
	// FatController Send HandShae(ThomasInfo:ID) To Thomas
	HandShake(context.Context, *HandShakeWithThomasRequest) (*ThomasInfo, error)
	RunTask(context.Context, *RunTaskRequest) (*EmptyResponse, error)
	// contains filtered or unexported methods
}

ThomasServer is the server API for Thomas service. All implementations must embed UnimplementedThomasServer for forward compatibility

type ThomasType 

type ThomasType int32

thomas 

const (
	ThomasType_Thomas_Null    ThomasType = 0
	ThomasType_Thomas_Static  ThomasType = 1
	ThomasType_Thomas_Dynamic ThomasType = 2
)

func (ThomasType) Descriptor 

func (ThomasType) Descriptor() protoreflect.EnumDescriptor

func (ThomasType) Enum 

func (x ThomasType) Enum() *ThomasType

func (ThomasType) EnumDescriptor deprecated 

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

Deprecated: Use ThomasType.Descriptor instead.

func (ThomasType) Number 

func (x ThomasType) Number() protoreflect.EnumNumber

func (ThomasType) String 

func (x ThomasType) String() string

func (ThomasType) Type 

func (ThomasType) Type() protoreflect.EnumType

type UnimplementedFatControllerServer 

type UnimplementedFatControllerServer struct {
}

UnimplementedFatControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedFatControllerServer) HandShake 

func (UnimplementedFatControllerServer) HandShake(context.Context, *ThomasInfo) (*FatCtrlInfos, error)

func (UnimplementedFatControllerServer) UpdateTaskInstance 

func (UnimplementedFatControllerServer) UpdateTaskInstance(context.Context, *TaskInstance) (*EmptyResponse, error)

type UnimplementedThomasServer 

type UnimplementedThomasServer struct {
}

UnimplementedThomasServer must be embedded to have forward compatible implementations.

func (UnimplementedThomasServer) HandShake 

func (UnimplementedThomasServer) HandShake(context.Context, *HandShakeWithThomasRequest) (*ThomasInfo, error)

func (UnimplementedThomasServer) RunTask 

func (UnimplementedThomasServer) RunTask(context.Context, *RunTaskRequest) (*EmptyResponse, error)

type UnsafeFatControllerServer 

type UnsafeFatControllerServer interface {
	// contains filtered or unexported methods
}

UnsafeFatControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FatControllerServer will result in compilation errors.

type UnsafeThomasServer 

type UnsafeThomasServer interface {
	// contains filtered or unexported methods
}

UnsafeThomasServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ThomasServer will result in compilation errors.

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.