alarmpb

package
v0.6.4 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2018 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package alarmpb is a generated protocol buffer package.

It is generated from these files: 

alarmpb.proto

It has these top-level messages: 

RequestHeader
ResponseHeader
SimpleAlarmRequest
SimpleAlarmResponse
TaskAlarmRequest
TaskTimeout
TaskLongTimeRunning
TaskAlarmResponse
NodeRangeAlarmRequest
RangeNoHeartbeatAlarm
NodeNoHeartbeatAlarm
NodeDiskSizeAlarm
NodeLeaderCountAlarm
NodeRangeAlarmResponse
AliveRequest
AliveResponse
SimpleRequest
SimpleResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAlarmpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAlarmpb   = fmt.Errorf("proto: integer overflow")
)
View Source 
var NodeRangeAlarmType_name = map[int32]string{
	0: "RANGE_NO_HEARTBEAT",
	1: "NODE_NO_HEARTBEAT",
	2: "NODE_DISK_SIZE",
	3: "NODE_LEADER_COUNT",
}
View Source 
var NodeRangeAlarmType_value = map[string]int32{
	"RANGE_NO_HEARTBEAT": 0,
	"NODE_NO_HEARTBEAT":  1,
	"NODE_DISK_SIZE":     2,
	"NODE_LEADER_COUNT":  3,
}
View Source 
var TaskAlarmType_name = map[int32]string{
	0: "TIMEOUT",
	1: "LONG_TIME_RUNNING",
}
View Source 
var TaskAlarmType_value = map[string]int32{
	"TIMEOUT":           0,
	"LONG_TIME_RUNNING": 1,
}

Functions

func RegisterAlarmServer 

func RegisterAlarmServer(s *grpc.Server, srv AlarmServer)

Types

type AlarmClient 

type AlarmClient interface {
	TaskAlarm(ctx context.Context, in *TaskAlarmRequest, opts ...grpc.CallOption) (*TaskAlarmResponse, error)
	NodeRangeAlarm(ctx context.Context, in *NodeRangeAlarmRequest, opts ...grpc.CallOption) (*NodeRangeAlarmResponse, error)
	AliveAlarm(ctx context.Context, in *AliveRequest, opts ...grpc.CallOption) (*AliveResponse, error)
	SimpleAlarm(ctx context.Context, in *SimpleRequest, opts ...grpc.CallOption) (*SimpleResponse, error)
}

func NewAlarmClient 

func NewAlarmClient(cc *grpc.ClientConn) AlarmClient

type AlarmServer 

type AlarmServer interface {
	TaskAlarm(context.Context, *TaskAlarmRequest) (*TaskAlarmResponse, error)
	NodeRangeAlarm(context.Context, *NodeRangeAlarmRequest) (*NodeRangeAlarmResponse, error)
	AliveAlarm(context.Context, *AliveRequest) (*AliveResponse, error)
	SimpleAlarm(context.Context, *SimpleRequest) (*SimpleResponse, error)
}

type AliveRequest 

type AliveRequest struct {
	Head       *RequestHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
	SampleJson []string       `protobuf:"bytes,10,rep,name=sample_json,json=sampleJson" json:"sample_json,omitempty"`
}

func (*AliveRequest) Descriptor 

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

func (*AliveRequest) GetHead 

func (m *AliveRequest) GetHead() *RequestHeader

func (*AliveRequest) GetSampleJson added in v0.6.3 

func (m *AliveRequest) GetSampleJson() []string

func (*AliveRequest) Marshal 

func (m *AliveRequest) Marshal() (dAtA []byte, err error)

func (*AliveRequest) MarshalTo 

func (m *AliveRequest) MarshalTo(dAtA []byte) (int, error)

func (*AliveRequest) ProtoMessage 

func (*AliveRequest) ProtoMessage()

func (*AliveRequest) Reset 

func (m *AliveRequest) Reset()

func (*AliveRequest) Size 

func (m *AliveRequest) Size() (n int)

func (*AliveRequest) String 

func (m *AliveRequest) String() string

func (*AliveRequest) Unmarshal 

func (m *AliveRequest) Unmarshal(dAtA []byte) error

type AliveResponse 

type AliveResponse struct {
	Head *ResponseHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
}

func (*AliveResponse) Descriptor 

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

func (*AliveResponse) GetHead 

func (m *AliveResponse) GetHead() *ResponseHeader

func (*AliveResponse) Marshal 

func (m *AliveResponse) Marshal() (dAtA []byte, err error)

func (*AliveResponse) MarshalTo 

func (m *AliveResponse) MarshalTo(dAtA []byte) (int, error)

func (*AliveResponse) ProtoMessage 

func (*AliveResponse) ProtoMessage()

func (*AliveResponse) Reset 

func (m *AliveResponse) Reset()

func (*AliveResponse) Size 

func (m *AliveResponse) Size() (n int)

func (*AliveResponse) String 

func (m *AliveResponse) String() string

func (*AliveResponse) Unmarshal 

func (m *AliveResponse) Unmarshal(dAtA []byte) error

type NodeDiskSizeAlarm 

type NodeDiskSizeAlarm struct {
	Node     *metapb.Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	DiskSize int64        `protobuf:"varint,2,opt,name=disk_size,json=diskSize,proto3" json:"disk_size,omitempty"`
}

func (*NodeDiskSizeAlarm) Descriptor 

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

func (*NodeDiskSizeAlarm) GetDiskSize 

func (m *NodeDiskSizeAlarm) GetDiskSize() int64

func (*NodeDiskSizeAlarm) GetNode 

func (m *NodeDiskSizeAlarm) GetNode() *metapb.Node

func (*NodeDiskSizeAlarm) Marshal 

func (m *NodeDiskSizeAlarm) Marshal() (dAtA []byte, err error)

func (*NodeDiskSizeAlarm) MarshalTo 

func (m *NodeDiskSizeAlarm) MarshalTo(dAtA []byte) (int, error)

func (*NodeDiskSizeAlarm) ProtoMessage 

func (*NodeDiskSizeAlarm) ProtoMessage()

func (*NodeDiskSizeAlarm) Reset 

func (m *NodeDiskSizeAlarm) Reset()

func (*NodeDiskSizeAlarm) Size 

func (m *NodeDiskSizeAlarm) Size() (n int)

func (*NodeDiskSizeAlarm) String 

func (m *NodeDiskSizeAlarm) String() string

func (*NodeDiskSizeAlarm) Unmarshal 

func (m *NodeDiskSizeAlarm) Unmarshal(dAtA []byte) error

type NodeLeaderCountAlarm 

type NodeLeaderCountAlarm struct {
	Node        *metapb.Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	LeaderCount int64        `protobuf:"varint,2,opt,name=leader_count,json=leaderCount,proto3" json:"leader_count,omitempty"`
}

func (*NodeLeaderCountAlarm) Descriptor 

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

func (*NodeLeaderCountAlarm) GetLeaderCount 

func (m *NodeLeaderCountAlarm) GetLeaderCount() int64

func (*NodeLeaderCountAlarm) GetNode 

func (m *NodeLeaderCountAlarm) GetNode() *metapb.Node

func (*NodeLeaderCountAlarm) Marshal 

func (m *NodeLeaderCountAlarm) Marshal() (dAtA []byte, err error)

func (*NodeLeaderCountAlarm) MarshalTo 

func (m *NodeLeaderCountAlarm) MarshalTo(dAtA []byte) (int, error)

func (*NodeLeaderCountAlarm) ProtoMessage 

func (*NodeLeaderCountAlarm) ProtoMessage()

func (*NodeLeaderCountAlarm) Reset 

func (m *NodeLeaderCountAlarm) Reset()

func (*NodeLeaderCountAlarm) Size 

func (m *NodeLeaderCountAlarm) Size() (n int)

func (*NodeLeaderCountAlarm) String 

func (m *NodeLeaderCountAlarm) String() string

func (*NodeLeaderCountAlarm) Unmarshal 

func (m *NodeLeaderCountAlarm) Unmarshal(dAtA []byte) error

type NodeNoHeartbeatAlarm 

type NodeNoHeartbeatAlarm struct {
	Node              *metapb.Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
	LastHeartbeatTime string       `protobuf:"bytes,2,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
}

func (*NodeNoHeartbeatAlarm) Descriptor 

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

func (*NodeNoHeartbeatAlarm) GetLastHeartbeatTime 

func (m *NodeNoHeartbeatAlarm) GetLastHeartbeatTime() string

func (*NodeNoHeartbeatAlarm) GetNode 

func (m *NodeNoHeartbeatAlarm) GetNode() *metapb.Node

func (*NodeNoHeartbeatAlarm) Marshal 

func (m *NodeNoHeartbeatAlarm) Marshal() (dAtA []byte, err error)

func (*NodeNoHeartbeatAlarm) MarshalTo 

func (m *NodeNoHeartbeatAlarm) MarshalTo(dAtA []byte) (int, error)

func (*NodeNoHeartbeatAlarm) ProtoMessage 

func (*NodeNoHeartbeatAlarm) ProtoMessage()

func (*NodeNoHeartbeatAlarm) Reset 

func (m *NodeNoHeartbeatAlarm) Reset()

func (*NodeNoHeartbeatAlarm) Size 

func (m *NodeNoHeartbeatAlarm) Size() (n int)

func (*NodeNoHeartbeatAlarm) String 

func (m *NodeNoHeartbeatAlarm) String() string

func (*NodeNoHeartbeatAlarm) Unmarshal 

func (m *NodeNoHeartbeatAlarm) Unmarshal(dAtA []byte) error

type NodeRangeAlarmRequest 

type NodeRangeAlarmRequest struct {
	Head                 *RequestHeader         `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
	Type                 NodeRangeAlarmType     `protobuf:"varint,2,opt,name=type,proto3,enum=alarmpb.NodeRangeAlarmType" json:"type,omitempty"`
	RangeNoHbAlarm       *RangeNoHeartbeatAlarm `protobuf:"bytes,3,opt,name=range_no_hb_alarm,json=rangeNoHbAlarm" json:"range_no_hb_alarm,omitempty"`
	NodeNoHbAlarm        *NodeNoHeartbeatAlarm  `protobuf:"bytes,4,opt,name=node_no_hb_alarm,json=nodeNoHbAlarm" json:"node_no_hb_alarm,omitempty"`
	NodeDiskSizeAlarm    *NodeDiskSizeAlarm     `protobuf:"bytes,5,opt,name=node_disk_size_alarm,json=nodeDiskSizeAlarm" json:"node_disk_size_alarm,omitempty"`
	NodeLeaderCountAlarm *NodeLeaderCountAlarm  `protobuf:"bytes,6,opt,name=node_leader_count_alarm,json=nodeLeaderCountAlarm" json:"node_leader_count_alarm,omitempty"`
	Describe             string                 `protobuf:"bytes,7,opt,name=Describe,proto3" json:"Describe,omitempty"`
	SampleJson           []string               `protobuf:"bytes,10,rep,name=sample_json,json=sampleJson" json:"sample_json,omitempty"`
}

func (*NodeRangeAlarmRequest) Descriptor 

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

func (*NodeRangeAlarmRequest) GetDescribe 

func (m *NodeRangeAlarmRequest) GetDescribe() string

func (*NodeRangeAlarmRequest) GetHead 

func (m *NodeRangeAlarmRequest) GetHead() *RequestHeader

func (*NodeRangeAlarmRequest) GetNodeDiskSizeAlarm 

func (m *NodeRangeAlarmRequest) GetNodeDiskSizeAlarm() *NodeDiskSizeAlarm

func (*NodeRangeAlarmRequest) GetNodeLeaderCountAlarm 

func (m *NodeRangeAlarmRequest) GetNodeLeaderCountAlarm() *NodeLeaderCountAlarm

func (*NodeRangeAlarmRequest) GetNodeNoHbAlarm 

func (m *NodeRangeAlarmRequest) GetNodeNoHbAlarm() *NodeNoHeartbeatAlarm

func (*NodeRangeAlarmRequest) GetRangeNoHbAlarm 

func (m *NodeRangeAlarmRequest) GetRangeNoHbAlarm() *RangeNoHeartbeatAlarm

func (*NodeRangeAlarmRequest) GetSampleJson added in v0.6.3 

func (m *NodeRangeAlarmRequest) GetSampleJson() []string

func (*NodeRangeAlarmRequest) GetType 

func (m *NodeRangeAlarmRequest) GetType() NodeRangeAlarmType

func (*NodeRangeAlarmRequest) Marshal 

func (m *NodeRangeAlarmRequest) Marshal() (dAtA []byte, err error)

func (*NodeRangeAlarmRequest) MarshalTo 

func (m *NodeRangeAlarmRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodeRangeAlarmRequest) ProtoMessage 

func (*NodeRangeAlarmRequest) ProtoMessage()

func (*NodeRangeAlarmRequest) Reset 

func (m *NodeRangeAlarmRequest) Reset()

func (*NodeRangeAlarmRequest) Size 

func (m *NodeRangeAlarmRequest) Size() (n int)

func (*NodeRangeAlarmRequest) String 

func (m *NodeRangeAlarmRequest) String() string

func (*NodeRangeAlarmRequest) Unmarshal 

func (m *NodeRangeAlarmRequest) Unmarshal(dAtA []byte) error

type NodeRangeAlarmResponse 

type NodeRangeAlarmResponse struct {
	Head *ResponseHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
}

func (*NodeRangeAlarmResponse) Descriptor 

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

func (*NodeRangeAlarmResponse) GetHead 

func (m *NodeRangeAlarmResponse) GetHead() *ResponseHeader

func (*NodeRangeAlarmResponse) Marshal 

func (m *NodeRangeAlarmResponse) Marshal() (dAtA []byte, err error)

func (*NodeRangeAlarmResponse) MarshalTo 

func (m *NodeRangeAlarmResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodeRangeAlarmResponse) ProtoMessage 

func (*NodeRangeAlarmResponse) ProtoMessage()

func (*NodeRangeAlarmResponse) Reset 

func (m *NodeRangeAlarmResponse) Reset()

func (*NodeRangeAlarmResponse) Size 

func (m *NodeRangeAlarmResponse) Size() (n int)

func (*NodeRangeAlarmResponse) String 

func (m *NodeRangeAlarmResponse) String() string

func (*NodeRangeAlarmResponse) Unmarshal 

func (m *NodeRangeAlarmResponse) Unmarshal(dAtA []byte) error

type NodeRangeAlarmType 

type NodeRangeAlarmType int32
const (
	NodeRangeAlarmType_RANGE_NO_HEARTBEAT NodeRangeAlarmType = 0
	NodeRangeAlarmType_NODE_NO_HEARTBEAT  NodeRangeAlarmType = 1
	NodeRangeAlarmType_NODE_DISK_SIZE     NodeRangeAlarmType = 2
	NodeRangeAlarmType_NODE_LEADER_COUNT  NodeRangeAlarmType = 3
)

func (NodeRangeAlarmType) EnumDescriptor 

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

func (NodeRangeAlarmType) String 

func (x NodeRangeAlarmType) String() string

type RangeNoHeartbeatAlarm 

type RangeNoHeartbeatAlarm struct {
	Range             *metapb.Range `protobuf:"bytes,1,opt,name=range" json:"range,omitempty"`
	LastHeartbeatTime string        `protobuf:"bytes,2,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
}

func (*RangeNoHeartbeatAlarm) Descriptor 

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

func (*RangeNoHeartbeatAlarm) GetLastHeartbeatTime 

func (m *RangeNoHeartbeatAlarm) GetLastHeartbeatTime() string

func (*RangeNoHeartbeatAlarm) GetRange 

func (m *RangeNoHeartbeatAlarm) GetRange() *metapb.Range

func (*RangeNoHeartbeatAlarm) Marshal 

func (m *RangeNoHeartbeatAlarm) Marshal() (dAtA []byte, err error)

func (*RangeNoHeartbeatAlarm) MarshalTo 

func (m *RangeNoHeartbeatAlarm) MarshalTo(dAtA []byte) (int, error)

func (*RangeNoHeartbeatAlarm) ProtoMessage 

func (*RangeNoHeartbeatAlarm) ProtoMessage()

func (*RangeNoHeartbeatAlarm) Reset 

func (m *RangeNoHeartbeatAlarm) Reset()

func (*RangeNoHeartbeatAlarm) Size 

func (m *RangeNoHeartbeatAlarm) Size() (n int)

func (*RangeNoHeartbeatAlarm) String 

func (m *RangeNoHeartbeatAlarm) String() string

func (*RangeNoHeartbeatAlarm) Unmarshal 

func (m *RangeNoHeartbeatAlarm) Unmarshal(dAtA []byte) error

type RequestHeader 

type RequestHeader struct {
	ClusterId int64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() int64

func (*RequestHeader) Marshal 

func (m *RequestHeader) Marshal() (dAtA []byte, err error)

func (*RequestHeader) MarshalTo 

func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

func (m *RequestHeader) Size() (n int)

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

func (m *RequestHeader) Unmarshal(dAtA []byte) error

type ResponseHeader 

type ResponseHeader struct {
	Code  int32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetCode 

func (m *ResponseHeader) GetCode() int32

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() string

func (*ResponseHeader) Marshal 

func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

func (m *ResponseHeader) Size() (n int)

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

func (m *ResponseHeader) Unmarshal(dAtA []byte) error

type SimpleAlarmRequest 

type SimpleAlarmRequest struct {
	Head     *RequestHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
	Describe string         `protobuf:"bytes,2,opt,name=Describe,proto3" json:"Describe,omitempty"`
}

func (*SimpleAlarmRequest) Descriptor 

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

func (*SimpleAlarmRequest) GetDescribe 

func (m *SimpleAlarmRequest) GetDescribe() string

func (*SimpleAlarmRequest) GetHead 

func (m *SimpleAlarmRequest) GetHead() *RequestHeader

func (*SimpleAlarmRequest) Marshal 

func (m *SimpleAlarmRequest) Marshal() (dAtA []byte, err error)

func (*SimpleAlarmRequest) MarshalTo 

func (m *SimpleAlarmRequest) MarshalTo(dAtA []byte) (int, error)

func (*SimpleAlarmRequest) ProtoMessage 

func (*SimpleAlarmRequest) ProtoMessage()

func (*SimpleAlarmRequest) Reset 

func (m *SimpleAlarmRequest) Reset()

func (*SimpleAlarmRequest) Size 

func (m *SimpleAlarmRequest) Size() (n int)

func (*SimpleAlarmRequest) String 

func (m *SimpleAlarmRequest) String() string

func (*SimpleAlarmRequest) Unmarshal 

func (m *SimpleAlarmRequest) Unmarshal(dAtA []byte) error

type SimpleAlarmResponse 

type SimpleAlarmResponse struct {
	Head *ResponseHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
}

func (*SimpleAlarmResponse) Descriptor 

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

func (*SimpleAlarmResponse) GetHead 

func (m *SimpleAlarmResponse) GetHead() *ResponseHeader

func (*SimpleAlarmResponse) Marshal 

func (m *SimpleAlarmResponse) Marshal() (dAtA []byte, err error)

func (*SimpleAlarmResponse) MarshalTo 

func (m *SimpleAlarmResponse) MarshalTo(dAtA []byte) (int, error)

func (*SimpleAlarmResponse) ProtoMessage 

func (*SimpleAlarmResponse) ProtoMessage()

func (*SimpleAlarmResponse) Reset 

func (m *SimpleAlarmResponse) Reset()

func (*SimpleAlarmResponse) Size 

func (m *SimpleAlarmResponse) Size() (n int)

func (*SimpleAlarmResponse) String 

func (m *SimpleAlarmResponse) String() string

func (*SimpleAlarmResponse) Unmarshal 

func (m *SimpleAlarmResponse) Unmarshal(dAtA []byte) error

type SimpleRequest 

type SimpleRequest struct {
	Head       *RequestHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
	Title      string         `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Content    string         `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	SampleJson []string       `protobuf:"bytes,10,rep,name=sample_json,json=sampleJson" json:"sample_json,omitempty"`
}

func (*SimpleRequest) Descriptor 

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

func (*SimpleRequest) GetContent 

func (m *SimpleRequest) GetContent() string

func (*SimpleRequest) GetHead 

func (m *SimpleRequest) GetHead() *RequestHeader

func (*SimpleRequest) GetSampleJson added in v0.6.3 

func (m *SimpleRequest) GetSampleJson() []string

func (*SimpleRequest) GetTitle 

func (m *SimpleRequest) GetTitle() string

func (*SimpleRequest) Marshal 

func (m *SimpleRequest) Marshal() (dAtA []byte, err error)

func (*SimpleRequest) MarshalTo 

func (m *SimpleRequest) MarshalTo(dAtA []byte) (int, error)

func (*SimpleRequest) ProtoMessage 

func (*SimpleRequest) ProtoMessage()

func (*SimpleRequest) Reset 

func (m *SimpleRequest) Reset()

func (*SimpleRequest) Size 

func (m *SimpleRequest) Size() (n int)

func (*SimpleRequest) String 

func (m *SimpleRequest) String() string

func (*SimpleRequest) Unmarshal 

func (m *SimpleRequest) Unmarshal(dAtA []byte) error

type SimpleResponse 

type SimpleResponse struct {
	Head *ResponseHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
}

func (*SimpleResponse) Descriptor 

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

func (*SimpleResponse) GetHead 

func (m *SimpleResponse) GetHead() *ResponseHeader

func (*SimpleResponse) Marshal 

func (m *SimpleResponse) Marshal() (dAtA []byte, err error)

func (*SimpleResponse) MarshalTo 

func (m *SimpleResponse) MarshalTo(dAtA []byte) (int, error)

func (*SimpleResponse) ProtoMessage 

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset 

func (m *SimpleResponse) Reset()

func (*SimpleResponse) Size 

func (m *SimpleResponse) Size() (n int)

func (*SimpleResponse) String 

func (m *SimpleResponse) String() string

func (*SimpleResponse) Unmarshal 

func (m *SimpleResponse) Unmarshal(dAtA []byte) error

type TaskAlarmRequest 

type TaskAlarmRequest struct {
	Head                     *RequestHeader       `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
	Type                     TaskAlarmType        `protobuf:"varint,2,opt,name=type,proto3,enum=alarmpb.TaskAlarmType" json:"type,omitempty"`
	Task                     *taskpb.Task         `protobuf:"bytes,3,opt,name=task" json:"task,omitempty"`
	TaskTimeoutAlarm         *TaskTimeout         `protobuf:"bytes,4,opt,name=task_timeout_alarm,json=taskTimeoutAlarm" json:"task_timeout_alarm,omitempty"`
	TaskLongTimeRunningAlarm *TaskLongTimeRunning `` /* 132-byte string literal not displayed */
	Describe                 string               `protobuf:"bytes,6,opt,name=Describe,proto3" json:"Describe,omitempty"`
	SampleJson               []string             `protobuf:"bytes,10,rep,name=sample_json,json=sampleJson" json:"sample_json,omitempty"`
}

func (*TaskAlarmRequest) Descriptor 

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

func (*TaskAlarmRequest) GetDescribe 

func (m *TaskAlarmRequest) GetDescribe() string

func (*TaskAlarmRequest) GetHead 

func (m *TaskAlarmRequest) GetHead() *RequestHeader

func (*TaskAlarmRequest) GetSampleJson added in v0.6.3 

func (m *TaskAlarmRequest) GetSampleJson() []string

func (*TaskAlarmRequest) GetTask 

func (m *TaskAlarmRequest) GetTask() *taskpb.Task

func (*TaskAlarmRequest) GetTaskLongTimeRunningAlarm 

func (m *TaskAlarmRequest) GetTaskLongTimeRunningAlarm() *TaskLongTimeRunning

func (*TaskAlarmRequest) GetTaskTimeoutAlarm 

func (m *TaskAlarmRequest) GetTaskTimeoutAlarm() *TaskTimeout

func (*TaskAlarmRequest) GetType 

func (m *TaskAlarmRequest) GetType() TaskAlarmType

func (*TaskAlarmRequest) Marshal 

func (m *TaskAlarmRequest) Marshal() (dAtA []byte, err error)

func (*TaskAlarmRequest) MarshalTo 

func (m *TaskAlarmRequest) MarshalTo(dAtA []byte) (int, error)

func (*TaskAlarmRequest) ProtoMessage 

func (*TaskAlarmRequest) ProtoMessage()

func (*TaskAlarmRequest) Reset 

func (m *TaskAlarmRequest) Reset()

func (*TaskAlarmRequest) Size 

func (m *TaskAlarmRequest) Size() (n int)

func (*TaskAlarmRequest) String 

func (m *TaskAlarmRequest) String() string

func (*TaskAlarmRequest) Unmarshal 

func (m *TaskAlarmRequest) Unmarshal(dAtA []byte) error

type TaskAlarmResponse 

type TaskAlarmResponse struct {
	Head *ResponseHeader `protobuf:"bytes,1,opt,name=head" json:"head,omitempty"`
}

func (*TaskAlarmResponse) Descriptor 

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

func (*TaskAlarmResponse) GetHead 

func (m *TaskAlarmResponse) GetHead() *ResponseHeader

func (*TaskAlarmResponse) Marshal 

func (m *TaskAlarmResponse) Marshal() (dAtA []byte, err error)

func (*TaskAlarmResponse) MarshalTo 

func (m *TaskAlarmResponse) MarshalTo(dAtA []byte) (int, error)

func (*TaskAlarmResponse) ProtoMessage 

func (*TaskAlarmResponse) ProtoMessage()

func (*TaskAlarmResponse) Reset 

func (m *TaskAlarmResponse) Reset()

func (*TaskAlarmResponse) Size 

func (m *TaskAlarmResponse) Size() (n int)

func (*TaskAlarmResponse) String 

func (m *TaskAlarmResponse) String() string

func (*TaskAlarmResponse) Unmarshal 

func (m *TaskAlarmResponse) Unmarshal(dAtA []byte) error

type TaskAlarmType 

type TaskAlarmType int32
const (
	TaskAlarmType_TIMEOUT           TaskAlarmType = 0
	TaskAlarmType_LONG_TIME_RUNNING TaskAlarmType = 1
)

func (TaskAlarmType) EnumDescriptor 

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

func (TaskAlarmType) String 

func (x TaskAlarmType) String() string

type TaskLongTimeRunning 

type TaskLongTimeRunning struct {
	Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Takes int64  `protobuf:"varint,3,opt,name=takes,proto3" json:"takes,omitempty"`
}

func (*TaskLongTimeRunning) Descriptor 

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

func (*TaskLongTimeRunning) GetStart 

func (m *TaskLongTimeRunning) GetStart() string

func (*TaskLongTimeRunning) GetTakes 

func (m *TaskLongTimeRunning) GetTakes() int64

func (*TaskLongTimeRunning) Marshal 

func (m *TaskLongTimeRunning) Marshal() (dAtA []byte, err error)

func (*TaskLongTimeRunning) MarshalTo 

func (m *TaskLongTimeRunning) MarshalTo(dAtA []byte) (int, error)

func (*TaskLongTimeRunning) ProtoMessage 

func (*TaskLongTimeRunning) ProtoMessage()

func (*TaskLongTimeRunning) Reset 

func (m *TaskLongTimeRunning) Reset()

func (*TaskLongTimeRunning) Size 

func (m *TaskLongTimeRunning) Size() (n int)

func (*TaskLongTimeRunning) String 

func (m *TaskLongTimeRunning) String() string

func (*TaskLongTimeRunning) Unmarshal 

func (m *TaskLongTimeRunning) Unmarshal(dAtA []byte) error

type TaskTimeout 

type TaskTimeout struct {
	Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Takes int64  `protobuf:"varint,3,opt,name=takes,proto3" json:"takes,omitempty"`
}

func (*TaskTimeout) Descriptor 

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

func (*TaskTimeout) GetStart 

func (m *TaskTimeout) GetStart() string

func (*TaskTimeout) GetTakes 

func (m *TaskTimeout) GetTakes() int64

func (*TaskTimeout) Marshal 

func (m *TaskTimeout) Marshal() (dAtA []byte, err error)

func (*TaskTimeout) MarshalTo 

func (m *TaskTimeout) MarshalTo(dAtA []byte) (int, error)

func (*TaskTimeout) ProtoMessage 

func (*TaskTimeout) ProtoMessage()

func (*TaskTimeout) Reset 

func (m *TaskTimeout) Reset()

func (*TaskTimeout) Size 

func (m *TaskTimeout) Size() (n int)

func (*TaskTimeout) String 

func (m *TaskTimeout) String() string

func (*TaskTimeout) Unmarshal 

func (m *TaskTimeout) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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