message

package
v0.2.6 Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2017 License: GPL-3.0 Imports: 7 Imported by: 5

Documentation

Overview

Package message is a generated protocol buffer package.

It is generated from these files: 

message/api.proto
message/serfQueryParams.proto
message/job.proto

It has these top-level messages: 

ApiJobResponse
ApiExecutionResponse
ApiJobStatusResponse
ApiStringResponse
ApiNodeResponse
Pageing
SearchCondition
ApiJobQueryString
ApiJobStatusQueryString
ApiExecutionQueryString
ApiSearchQueryString
ApiNodeQueryString
JobQueryParams
GetRPCConfigResp
JobCountResp
QueryResult
QueryJobRunParams
Search
Params
Result
Job
JobStatus
Execution
Node

Index

Constants

This section is empty.

Variables

View Source 
var Ops_name = map[int32]string{
	0: "READ",
	1: "ADD",
	2: "MODIFY",
	3: "DELETE",
}
View Source 
var Ops_value = map[string]int32{
	"READ":   0,
	"ADD":    1,
	"MODIFY": 2,
	"DELETE": 3,
}

Functions

func RegisterJobServer 

func RegisterJobServer(s *grpc.Server, srv JobServer)

Types

type ApiExecutionQueryString 

type ApiExecutionQueryString struct {
	// @inject_tag: form:"execution"
	Execution *Execution `protobuf:"bytes,1,opt,name=Execution" json:"Execution,omitempty" form:"execution"`
	// @inject_tag: form:"pageing"
	Pageing *Pageing `protobuf:"bytes,2,opt,name=Pageing" json:"Pageing,omitempty" form:"pageing"`
}

func (*ApiExecutionQueryString) Descriptor 

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

func (*ApiExecutionQueryString) GetExecution 

func (m *ApiExecutionQueryString) GetExecution() *Execution

func (*ApiExecutionQueryString) GetPageing 

func (m *ApiExecutionQueryString) GetPageing() *Pageing

func (*ApiExecutionQueryString) ProtoMessage 

func (*ApiExecutionQueryString) ProtoMessage()

func (*ApiExecutionQueryString) Reset 

func (m *ApiExecutionQueryString) Reset()

func (*ApiExecutionQueryString) String 

func (m *ApiExecutionQueryString) String() string

type ApiExecutionResponse 

type ApiExecutionResponse struct {
	Succeed    bool         `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	Message    string       `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	MaxPageNum int32        `protobuf:"varint,3,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Data       []*Execution `protobuf:"bytes,4,rep,name=Data" json:"Data,omitempty"`
}

func (*ApiExecutionResponse) Descriptor 

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

func (*ApiExecutionResponse) GetData 

func (m *ApiExecutionResponse) GetData() []*Execution

func (*ApiExecutionResponse) GetMaxPageNum 

func (m *ApiExecutionResponse) GetMaxPageNum() int32

func (*ApiExecutionResponse) GetMessage 

func (m *ApiExecutionResponse) GetMessage() string

func (*ApiExecutionResponse) GetSucceed 

func (m *ApiExecutionResponse) GetSucceed() bool

func (*ApiExecutionResponse) ProtoMessage 

func (*ApiExecutionResponse) ProtoMessage()

func (*ApiExecutionResponse) Reset 

func (m *ApiExecutionResponse) Reset()

func (*ApiExecutionResponse) String 

func (m *ApiExecutionResponse) String() string

type ApiJobQueryString 

type ApiJobQueryString struct {
	// @inject_tag: form:"job"
	Job *Job `protobuf:"bytes,1,opt,name=Job" json:"Job,omitempty" form:"job"`
	// @inject_tag: form:"pageing"
	Pageing *Pageing `protobuf:"bytes,2,opt,name=Pageing" json:"Pageing,omitempty" form:"pageing"`
}

func (*ApiJobQueryString) Descriptor 

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

func (*ApiJobQueryString) GetJob 

func (m *ApiJobQueryString) GetJob() *Job

func (*ApiJobQueryString) GetPageing 

func (m *ApiJobQueryString) GetPageing() *Pageing

func (*ApiJobQueryString) ProtoMessage 

func (*ApiJobQueryString) ProtoMessage()

func (*ApiJobQueryString) Reset 

func (m *ApiJobQueryString) Reset()

func (*ApiJobQueryString) String 

func (m *ApiJobQueryString) String() string

type ApiJobResponse 

type ApiJobResponse struct {
	Succeed    bool   `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	MaxPageNum int32  `protobuf:"varint,3,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Data       []*Job `protobuf:"bytes,4,rep,name=Data" json:"Data,omitempty"`
}

func (*ApiJobResponse) Descriptor 

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

func (*ApiJobResponse) GetData 

func (m *ApiJobResponse) GetData() []*Job

func (*ApiJobResponse) GetMaxPageNum 

func (m *ApiJobResponse) GetMaxPageNum() int32

func (*ApiJobResponse) GetMessage 

func (m *ApiJobResponse) GetMessage() string

func (*ApiJobResponse) GetSucceed 

func (m *ApiJobResponse) GetSucceed() bool

func (*ApiJobResponse) ProtoMessage 

func (*ApiJobResponse) ProtoMessage()

func (*ApiJobResponse) Reset 

func (m *ApiJobResponse) Reset()

func (*ApiJobResponse) String 

func (m *ApiJobResponse) String() string

type ApiJobStatusQueryString 

type ApiJobStatusQueryString struct {
	// @inject_tag: form:"status"
	Status *JobStatus `protobuf:"bytes,1,opt,name=Status" json:"Status,omitempty" form:"status"`
	// @inject_tag: form:"pageing"
	Pageing *Pageing `protobuf:"bytes,2,opt,name=Pageing" json:"Pageing,omitempty" form:"pageing"`
}

func (*ApiJobStatusQueryString) Descriptor 

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

func (*ApiJobStatusQueryString) GetPageing 

func (m *ApiJobStatusQueryString) GetPageing() *Pageing

func (*ApiJobStatusQueryString) GetStatus 

func (m *ApiJobStatusQueryString) GetStatus() *JobStatus

func (*ApiJobStatusQueryString) ProtoMessage 

func (*ApiJobStatusQueryString) ProtoMessage()

func (*ApiJobStatusQueryString) Reset 

func (m *ApiJobStatusQueryString) Reset()

func (*ApiJobStatusQueryString) String 

func (m *ApiJobStatusQueryString) String() string

type ApiJobStatusResponse 

type ApiJobStatusResponse struct {
	Succeed    bool         `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	Message    string       `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	MaxPageNum int32        `protobuf:"varint,3,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Data       []*JobStatus `protobuf:"bytes,4,rep,name=Data" json:"Data,omitempty"`
}

func (*ApiJobStatusResponse) Descriptor 

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

func (*ApiJobStatusResponse) GetData 

func (m *ApiJobStatusResponse) GetData() []*JobStatus

func (*ApiJobStatusResponse) GetMaxPageNum 

func (m *ApiJobStatusResponse) GetMaxPageNum() int32

func (*ApiJobStatusResponse) GetMessage 

func (m *ApiJobStatusResponse) GetMessage() string

func (*ApiJobStatusResponse) GetSucceed 

func (m *ApiJobStatusResponse) GetSucceed() bool

func (*ApiJobStatusResponse) ProtoMessage 

func (*ApiJobStatusResponse) ProtoMessage()

func (*ApiJobStatusResponse) Reset 

func (m *ApiJobStatusResponse) Reset()

func (*ApiJobStatusResponse) String 

func (m *ApiJobStatusResponse) String() string

type ApiNodeQueryString 

type ApiNodeQueryString struct {
	// @inject_tag: form:"node"
	Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty" form:"node"`
	// @inject_tag: form:"pageing"
	Pageing *Pageing `protobuf:"bytes,2,opt,name=Pageing" json:"Pageing,omitempty" form:"pageing"`
}

func (*ApiNodeQueryString) Descriptor 

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

func (*ApiNodeQueryString) GetNode 

func (m *ApiNodeQueryString) GetNode() *Node

func (*ApiNodeQueryString) GetPageing 

func (m *ApiNodeQueryString) GetPageing() *Pageing

func (*ApiNodeQueryString) ProtoMessage 

func (*ApiNodeQueryString) ProtoMessage()

func (*ApiNodeQueryString) Reset 

func (m *ApiNodeQueryString) Reset()

func (*ApiNodeQueryString) String 

func (m *ApiNodeQueryString) String() string

type ApiNodeResponse 

type ApiNodeResponse struct {
	Succeed    bool    `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	Message    string  `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	MaxPageNum int32   `protobuf:"varint,3,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Data       []*Node `protobuf:"bytes,4,rep,name=Data" json:"Data,omitempty"`
}

func (*ApiNodeResponse) Descriptor 

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

func (*ApiNodeResponse) GetData 

func (m *ApiNodeResponse) GetData() []*Node

func (*ApiNodeResponse) GetMaxPageNum 

func (m *ApiNodeResponse) GetMaxPageNum() int32

func (*ApiNodeResponse) GetMessage 

func (m *ApiNodeResponse) GetMessage() string

func (*ApiNodeResponse) GetSucceed 

func (m *ApiNodeResponse) GetSucceed() bool

func (*ApiNodeResponse) ProtoMessage 

func (*ApiNodeResponse) ProtoMessage()

func (*ApiNodeResponse) Reset 

func (m *ApiNodeResponse) Reset()

func (*ApiNodeResponse) String 

func (m *ApiNodeResponse) String() string

type ApiSearchQueryString 

type ApiSearchQueryString struct {
	// @inject_tag: form:"q"
	SearchCondition *SearchCondition `protobuf:"bytes,1,opt,name=SearchCondition" json:"SearchCondition,omitempty" form:"q"`
	// @inject_tag: form:"pageing"
	Pageing *Pageing `protobuf:"bytes,2,opt,name=Pageing" json:"Pageing,omitempty" form:"pageing"`
}

func (*ApiSearchQueryString) Descriptor 

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

func (*ApiSearchQueryString) GetPageing 

func (m *ApiSearchQueryString) GetPageing() *Pageing

func (*ApiSearchQueryString) GetSearchCondition 

func (m *ApiSearchQueryString) GetSearchCondition() *SearchCondition

func (*ApiSearchQueryString) ProtoMessage 

func (*ApiSearchQueryString) ProtoMessage()

func (*ApiSearchQueryString) Reset 

func (m *ApiSearchQueryString) Reset()

func (*ApiSearchQueryString) String 

func (m *ApiSearchQueryString) String() string

type ApiStringResponse 

type ApiStringResponse struct {
	Succeed    bool     `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	Message    string   `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	MaxPageNum int32    `protobuf:"varint,3,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Data       []string `protobuf:"bytes,4,rep,name=Data" json:"Data,omitempty"`
}

func (*ApiStringResponse) Descriptor 

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

func (*ApiStringResponse) GetData 

func (m *ApiStringResponse) GetData() []string

func (*ApiStringResponse) GetMaxPageNum 

func (m *ApiStringResponse) GetMaxPageNum() int32

func (*ApiStringResponse) GetMessage 

func (m *ApiStringResponse) GetMessage() string

func (*ApiStringResponse) GetSucceed 

func (m *ApiStringResponse) GetSucceed() bool

func (*ApiStringResponse) ProtoMessage 

func (*ApiStringResponse) ProtoMessage()

func (*ApiStringResponse) Reset 

func (m *ApiStringResponse) Reset()

func (*ApiStringResponse) String 

func (m *ApiStringResponse) String() string

type Execution 

type Execution struct {
	// @inject_tag: gorm:"type:varchar(64);not null"
	SchedulerNodeName string `protobuf:"bytes,1,opt,name=SchedulerNodeName" json:"SchedulerNodeName,omitempty" gorm:"type:varchar(64);not null"`
	// @inject_tag: gorm:"type:blob"
	Output []byte `protobuf:"bytes,2,opt,name=Output,proto3" json:"Output,omitempty" gorm:"type:blob"`
	// @inject_tag: gorm:"type:tinyint(4)"
	Succeed bool `protobuf:"varint,3,opt,name=Succeed" json:"Succeed,omitempty" gorm:"type:tinyint(4)"`
	// @inject_tag: gorm:"type:bigint(21);not null"
	StartTime int64 `protobuf:"varint,4,opt,name=StartTime" json:"StartTime,omitempty" gorm:"type:bigint(21);not null"`
	// @inject_tag: gorm:"type:bigint(21);not null"
	FinishTime int64 `protobuf:"varint,5,opt,name=FinishTime" json:"FinishTime,omitempty" gorm:"type:bigint(21);not null"`
	// @inject_tag: gorm:"type:varchar(64);primary_key;not null" form:"Name"
	Name string `protobuf:"bytes,6,opt,name=Name" json:"Name,omitempty" gorm:"type:varchar(64);primary_key;not null" form:"Name"`
	// @inject_tag: gorm:"type:varchar(64);primary_key;not null" form:"Rgion"
	Region string `protobuf:"bytes,7,opt,name=Region" json:"Region,omitempty" gorm:"type:varchar(64);primary_key;not null" form:"Rgion"`
	// @inject_tag: gorm:"type:int(11);not null"
	Retries int64 `protobuf:"varint,8,opt,name=Retries" json:"Retries,omitempty" gorm:"type:int(11);not null"`
	// @inject_tag: gorm:"type:bigint(21);primary_key;not null" form:"Group"
	Group int64 `protobuf:"varint,9,opt,name=Group" json:"Group,omitempty" gorm:"type:bigint(21);primary_key;not null" form:"Group"`
	// @inject_tag: gorm:"type:varchar(64);primary_key;not null" form:"NodeName"
	RunNodeName string `` /* 130-byte string literal not displayed */
}

func (*Execution) Descriptor 

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

func (*Execution) GetFinishTime 

func (m *Execution) GetFinishTime() int64

func (*Execution) GetGroup 

func (m *Execution) GetGroup() int64

func (*Execution) GetName 

func (m *Execution) GetName() string

func (*Execution) GetOutput 

func (m *Execution) GetOutput() []byte

func (*Execution) GetRegion 

func (m *Execution) GetRegion() string

func (*Execution) GetRetries 

func (m *Execution) GetRetries() int64

func (*Execution) GetRunNodeName 

func (m *Execution) GetRunNodeName() string

func (*Execution) GetSchedulerNodeName 

func (m *Execution) GetSchedulerNodeName() string

func (*Execution) GetStartTime 

func (m *Execution) GetStartTime() int64

func (*Execution) GetSucceed 

func (m *Execution) GetSucceed() bool

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) Reset 

func (m *Execution) Reset()

func (*Execution) String 

func (m *Execution) String() string

type GetRPCConfigResp 

type GetRPCConfigResp struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

func (*GetRPCConfigResp) Descriptor 

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

func (*GetRPCConfigResp) GetIp 

func (m *GetRPCConfigResp) GetIp() string

func (*GetRPCConfigResp) GetPort 

func (m *GetRPCConfigResp) GetPort() int32

func (*GetRPCConfigResp) ProtoMessage 

func (*GetRPCConfigResp) ProtoMessage()

func (*GetRPCConfigResp) Reset 

func (m *GetRPCConfigResp) Reset()

func (*GetRPCConfigResp) String 

func (m *GetRPCConfigResp) String() string

type Job 

type Job struct {
	// @inject_tag: gorm:"type:varchar(64);not null;primary_key"
	Name string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty" gorm:"type:varchar(64);not null;primary_key"`
	// @inject_tag: gorm:"type:varchar(64);not null;primary_key"
	Region string `protobuf:"bytes,2,opt,name=Region" json:"Region,omitempty" gorm:"type:varchar(64);not null;primary_key"`
	// @inject_tag: gorm:"type:varchar(64)"
	Schedule string `protobuf:"bytes,3,opt,name=Schedule" json:"Schedule,omitempty" gorm:"type:varchar(64)"`
	// @inject_tag: gorm:"type:tinyint(4)"
	Shell bool `protobuf:"varint,4,opt,name=Shell" json:"Shell,omitempty" gorm:"type:tinyint(4)"`
	// @inject_tag: gorm:"type:varchar(512);not null"
	Command string `protobuf:"bytes,5,opt,name=Command" json:"Command,omitempty" gorm:"type:varchar(512);not null"`
	// @inject_tag: gorm:"type:varchar(64);not null"
	Expression string `protobuf:"bytes,6,opt,name=Expression" json:"Expression,omitempty" gorm:"type:varchar(64);not null"`
	// @inject_tag: gorm:"type:tinyint(4)"
	Idempotent bool `protobuf:"varint,7,opt,name=Idempotent" json:"Idempotent,omitempty" gorm:"type:tinyint(4)"`
	// @inject_tag: gorm:"type:tinyint(4)"
	Disable bool `protobuf:"varint,8,opt,name=Disable" json:"Disable,omitempty" gorm:"type:tinyint(4)"`
	// @inject_tag: gorm:"type:varchar(64); not null"
	SchedulerNodeName string `protobuf:"bytes,9,opt,name=SchedulerNodeName" json:"SchedulerNodeName,omitempty" gorm:"type:varchar(64); not null"`
	// @inject_tag: gorm:"type:varchar(64);not null;index:pjn_idx"
	ParentJobName string `protobuf:"bytes,10,opt,name=ParentJobName" json:"ParentJobName,omitempty" gorm:"type:varchar(64);not null;index:pjn_idx"`
	// @inject_tag: gorm:"-"
	ParentJob *Job `protobuf:"bytes,11,opt,name=ParentJob" json:"ParentJob,omitempty" gorm:"-"`
	// @inject_tag: gorm:"type:decimal(3,2);not null;default:'1.00'"
	Threshold float64 `protobuf:"fixed64,12,opt,name=Threshold" json:"Threshold,omitempty" gorm:"type:decimal(3,2);not null;default:'1.00'"`
	// @inject_tag: gorm:"type:bigint(21);not null;default:'3600'"
	MaxRunTime int32 `protobuf:"varint,13,opt,name=MaxRunTime" json:"MaxRunTime,omitempty" gorm:"type:bigint(21);not null;default:'3600'"`
}

func (*Job) Descriptor 

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

func (*Job) GetCommand 

func (m *Job) GetCommand() string

func (*Job) GetDisable 

func (m *Job) GetDisable() bool

func (*Job) GetExpression 

func (m *Job) GetExpression() string

func (*Job) GetIdempotent 

func (m *Job) GetIdempotent() bool

func (*Job) GetMaxRunTime 

func (m *Job) GetMaxRunTime() int32

func (*Job) GetName 

func (m *Job) GetName() string

func (*Job) GetParentJob 

func (m *Job) GetParentJob() *Job

func (*Job) GetParentJobName 

func (m *Job) GetParentJobName() string

func (*Job) GetRegion 

func (m *Job) GetRegion() string

func (*Job) GetSchedule 

func (m *Job) GetSchedule() string

func (*Job) GetSchedulerNodeName 

func (m *Job) GetSchedulerNodeName() string

func (*Job) GetShell 

func (m *Job) GetShell() bool

func (*Job) GetThreshold 

func (m *Job) GetThreshold() float64

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

type JobClient 

type JobClient interface {
	GetJob(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Job, error)
	ExecDone(ctx context.Context, in *Execution, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	DoOps(ctx context.Context, in *Params, opts ...grpc.CallOption) (*Result, error)
	ProxyJobRun(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Execution, error)
}

func NewJobClient 

func NewJobClient(cc *grpc.ClientConn) JobClient

type JobCountResp 

type JobCountResp struct {
	Name  string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Count int64  `protobuf:"varint,2,opt,name=Count" json:"Count,omitempty"`
}

func (*JobCountResp) Descriptor 

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

func (*JobCountResp) GetCount 

func (m *JobCountResp) GetCount() int64

func (*JobCountResp) GetName 

func (m *JobCountResp) GetName() string

func (*JobCountResp) ProtoMessage 

func (*JobCountResp) ProtoMessage()

func (*JobCountResp) Reset 

func (m *JobCountResp) Reset()

func (*JobCountResp) String 

func (m *JobCountResp) String() string

type JobQueryParams 

type JobQueryParams struct {
	Name           string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Region         string `protobuf:"bytes,2,opt,name=Region" json:"Region,omitempty"`
	SourceNodeName string `protobuf:"bytes,3,opt,name=SourceNodeName" json:"SourceNodeName,omitempty"`
	DistNodeName   string `protobuf:"bytes,4,opt,name=DistNodeName" json:"DistNodeName,omitempty"`
}

func (*JobQueryParams) Descriptor 

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

func (*JobQueryParams) GetDistNodeName 

func (m *JobQueryParams) GetDistNodeName() string

func (*JobQueryParams) GetName 

func (m *JobQueryParams) GetName() string

func (*JobQueryParams) GetRegion 

func (m *JobQueryParams) GetRegion() string

func (*JobQueryParams) GetSourceNodeName 

func (m *JobQueryParams) GetSourceNodeName() string

func (*JobQueryParams) ProtoMessage 

func (*JobQueryParams) ProtoMessage()

func (*JobQueryParams) Reset 

func (m *JobQueryParams) Reset()

func (*JobQueryParams) String 

func (m *JobQueryParams) String() string

type JobServer 

type JobServer interface {
	GetJob(context.Context, *Job) (*Job, error)
	ExecDone(context.Context, *Execution) (*google_protobuf.Empty, error)
	DoOps(context.Context, *Params) (*Result, error)
	ProxyJobRun(context.Context, *Job) (*Execution, error)
}

type JobStatus 

type JobStatus struct {
	Name            string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Region          string `protobuf:"bytes,2,opt,name=Region" json:"Region,omitempty"`
	SuccessCount    int64  `protobuf:"varint,3,opt,name=SuccessCount" json:"SuccessCount,omitempty"`
	ErrorCount      int64  `protobuf:"varint,4,opt,name=ErrorCount" json:"ErrorCount,omitempty"`
	LastHandleAgent string `protobuf:"bytes,5,opt,name=LastHandleAgent" json:"LastHandleAgent,omitempty"`
	LastSuccess     string `protobuf:"bytes,6,opt,name=LastSuccess" json:"LastSuccess,omitempty"`
	LastError       string `protobuf:"bytes,7,opt,name=LastError" json:"LastError,omitempty"`
}

func (*JobStatus) Descriptor 

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

func (*JobStatus) GetErrorCount 

func (m *JobStatus) GetErrorCount() int64

func (*JobStatus) GetLastError 

func (m *JobStatus) GetLastError() string

func (*JobStatus) GetLastHandleAgent 

func (m *JobStatus) GetLastHandleAgent() string

func (*JobStatus) GetLastSuccess 

func (m *JobStatus) GetLastSuccess() string

func (*JobStatus) GetName 

func (m *JobStatus) GetName() string

func (*JobStatus) GetRegion 

func (m *JobStatus) GetRegion() string

func (*JobStatus) GetSuccessCount 

func (m *JobStatus) GetSuccessCount() int64

func (*JobStatus) ProtoMessage 

func (*JobStatus) ProtoMessage()

func (*JobStatus) Reset 

func (m *JobStatus) Reset()

func (*JobStatus) String 

func (m *JobStatus) String() string

type Node 

type Node struct {
	Name    string            `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Region  string            `protobuf:"bytes,2,opt,name=Region" json:"Region,omitempty"`
	Version string            `protobuf:"bytes,3,opt,name=Version" json:"Version,omitempty"`
	Alived  bool              `protobuf:"varint,4,opt,name=Alived" json:"Alived,omitempty"`
	Role    string            `protobuf:"bytes,5,opt,name=Role" json:"Role,omitempty"`
	Tags    map[string]string `` /* 128-byte string literal not displayed */
}

func (*Node) Descriptor 

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

func (*Node) GetAlived 

func (m *Node) GetAlived() bool

func (*Node) GetName 

func (m *Node) GetName() string

func (*Node) GetRegion 

func (m *Node) GetRegion() string

func (*Node) GetRole 

func (m *Node) GetRole() string

func (*Node) GetTags 

func (m *Node) GetTags() map[string]string

func (*Node) GetVersion added in v0.2.6 

func (m *Node) GetVersion() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

type Ops 

type Ops int32
const (
	Ops_READ   Ops = 0
	Ops_ADD    Ops = 1
	Ops_MODIFY Ops = 2
	Ops_DELETE Ops = 3
)

func (Ops) EnumDescriptor 

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

func (Ops) String 

func (x Ops) String() string

type Pageing 

type Pageing struct {
	// @inject_tag: form:"pagenum"
	PageNum int32 `protobuf:"varint,1,opt,name=PageNum" json:"PageNum,omitempty" form:"pagenum"`
	// @inject_tag: form:"pagesize"
	PageSize int32 `protobuf:"varint,2,opt,name=PageSize" json:"PageSize,omitempty" form:"pagesize"`
	// @inject_tag: form:"maxpage"
	OutMaxPage bool `protobuf:"varint,3,opt,name=OutMaxPage" json:"OutMaxPage,omitempty" form:"maxpage"`
}

func (*Pageing) Descriptor 

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

func (*Pageing) GetOutMaxPage 

func (m *Pageing) GetOutMaxPage() bool

func (*Pageing) GetPageNum 

func (m *Pageing) GetPageNum() int32

func (*Pageing) GetPageSize 

func (m *Pageing) GetPageSize() int32

func (*Pageing) ProtoMessage 

func (*Pageing) ProtoMessage()

func (*Pageing) Reset 

func (m *Pageing) Reset()

func (*Pageing) String 

func (m *Pageing) String() string

type Params 

type Params struct {
	Obj    *google_protobuf1.Any `protobuf:"bytes,1,opt,name=Obj" json:"Obj,omitempty"`
	Ops    Ops                   `protobuf:"varint,2,opt,name=Ops,enum=message.Ops" json:"Ops,omitempty"`
	Search *Search               `protobuf:"bytes,3,opt,name=Search" json:"Search,omitempty"`
}

func (*Params) Descriptor 

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

func (*Params) GetObj 

func (m *Params) GetObj() *google_protobuf1.Any

func (*Params) GetOps 

func (m *Params) GetOps() Ops

func (*Params) GetSearch 

func (m *Params) GetSearch() *Search

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) String 

func (m *Params) String() string

type QueryJobRunParams 

type QueryJobRunParams struct {
	Execution *Execution `protobuf:"bytes,1,opt,name=Execution" json:"Execution,omitempty"`
	Exp       string     `protobuf:"bytes,2,opt,name=exp" json:"exp,omitempty"`
}

func (*QueryJobRunParams) Descriptor 

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

func (*QueryJobRunParams) GetExecution 

func (m *QueryJobRunParams) GetExecution() *Execution

func (*QueryJobRunParams) GetExp 

func (m *QueryJobRunParams) GetExp() string

func (*QueryJobRunParams) ProtoMessage 

func (*QueryJobRunParams) ProtoMessage()

func (*QueryJobRunParams) Reset 

func (m *QueryJobRunParams) Reset()

func (*QueryJobRunParams) String 

func (m *QueryJobRunParams) String() string

type QueryResult 

type QueryResult struct {
	Status  int32  `protobuf:"varint,1,opt,name=Status" json:"Status,omitempty"`
	Node    string `protobuf:"bytes,2,opt,name=Node" json:"Node,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=Message" json:"Message,omitempty"`
}

func (*QueryResult) Descriptor 

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

func (*QueryResult) GetMessage 

func (m *QueryResult) GetMessage() string

func (*QueryResult) GetNode 

func (m *QueryResult) GetNode() string

func (*QueryResult) GetStatus 

func (m *QueryResult) GetStatus() int32

func (*QueryResult) ProtoMessage 

func (*QueryResult) ProtoMessage()

func (*QueryResult) Reset 

func (m *QueryResult) Reset()

func (*QueryResult) String 

func (m *QueryResult) String() string

type Result 

type Result struct {
	Succeed    bool                    `protobuf:"varint,1,opt,name=Succeed" json:"Succeed,omitempty"`
	MaxPageNum int32                   `protobuf:"varint,2,opt,name=MaxPageNum" json:"MaxPageNum,omitempty"`
	Objs       []*google_protobuf1.Any `protobuf:"bytes,3,rep,name=Objs" json:"Objs,omitempty"`
}

func (*Result) Descriptor 

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

func (*Result) GetMaxPageNum 

func (m *Result) GetMaxPageNum() int32

func (*Result) GetObjs 

func (m *Result) GetObjs() []*google_protobuf1.Any

func (*Result) GetSucceed 

func (m *Result) GetSucceed() bool

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) String 

func (m *Result) String() string
type Search struct {
	Conditions []string `protobuf:"bytes,1,rep,name=Conditions" json:"Conditions,omitempty"`
	Links      []string `protobuf:"bytes,2,rep,name=Links" json:"Links,omitempty"`
	PageNum    int32    `protobuf:"varint,3,opt,name=PageNum" json:"PageNum,omitempty"`
	PageSize   int32    `protobuf:"varint,4,opt,name=PageSize" json:"PageSize,omitempty"`
	Count      bool     `protobuf:"varint,5,opt,name=Count" json:"Count,omitempty"`
}

func (*Search) Descriptor 

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

func (*Search) GetConditions 

func (m *Search) GetConditions() []string

func (*Search) GetCount 

func (m *Search) GetCount() bool
func (m *Search) GetLinks() []string

func (*Search) GetPageNum 

func (m *Search) GetPageNum() int32

func (*Search) GetPageSize 

func (m *Search) GetPageSize() int32

func (*Search) ProtoMessage 

func (*Search) ProtoMessage()

func (*Search) Reset 

func (m *Search) Reset()

func (*Search) String 

func (m *Search) String() string

type SearchCondition 

type SearchCondition struct {
	// @inject_tag: form:"conditions"
	Conditions []string `protobuf:"bytes,1,rep,name=Conditions" json:"Conditions,omitempty" form:"conditions"`
	// @inject_tag: form:"links"
	Links []string `protobuf:"bytes,2,rep,name=Links" json:"Links,omitempty" form:"links"`
}

func (*SearchCondition) Descriptor 

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

func (*SearchCondition) GetConditions 

func (m *SearchCondition) GetConditions() []string
func (m *SearchCondition) GetLinks() []string

func (*SearchCondition) ProtoMessage 

func (*SearchCondition) ProtoMessage()

func (*SearchCondition) Reset 

func (m *SearchCondition) Reset()

func (*SearchCondition) String 

func (m *SearchCondition) 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.