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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL