Versions in this module Expand all Collapse all v0 v0.2.6 Dec 13, 2017 Changes in this version type Node + Version string + func (m *Node) GetVersion() string v0.2.2 Nov 24, 2017 Changes in this version + var Ops_name = map[int32]string + var Ops_value = map[string]int32 + func RegisterJobServer(s *grpc.Server, srv JobServer) + type ApiExecutionQueryString struct + Execution *Execution + Pageing *Pageing + func (*ApiExecutionQueryString) Descriptor() ([]byte, []int) + func (*ApiExecutionQueryString) ProtoMessage() + func (m *ApiExecutionQueryString) GetExecution() *Execution + func (m *ApiExecutionQueryString) GetPageing() *Pageing + func (m *ApiExecutionQueryString) Reset() + func (m *ApiExecutionQueryString) String() string + type ApiExecutionResponse struct + Data []*Execution + MaxPageNum int32 + Message string + Succeed bool + func (*ApiExecutionResponse) Descriptor() ([]byte, []int) + func (*ApiExecutionResponse) ProtoMessage() + func (m *ApiExecutionResponse) GetData() []*Execution + func (m *ApiExecutionResponse) GetMaxPageNum() int32 + func (m *ApiExecutionResponse) GetMessage() string + func (m *ApiExecutionResponse) GetSucceed() bool + func (m *ApiExecutionResponse) Reset() + func (m *ApiExecutionResponse) String() string + type ApiJobQueryString struct + Job *Job + Pageing *Pageing + func (*ApiJobQueryString) Descriptor() ([]byte, []int) + func (*ApiJobQueryString) ProtoMessage() + func (m *ApiJobQueryString) GetJob() *Job + func (m *ApiJobQueryString) GetPageing() *Pageing + func (m *ApiJobQueryString) Reset() + func (m *ApiJobQueryString) String() string + type ApiJobResponse struct + Data []*Job + MaxPageNum int32 + Message string + Succeed bool + func (*ApiJobResponse) Descriptor() ([]byte, []int) + func (*ApiJobResponse) ProtoMessage() + func (m *ApiJobResponse) GetData() []*Job + func (m *ApiJobResponse) GetMaxPageNum() int32 + func (m *ApiJobResponse) GetMessage() string + func (m *ApiJobResponse) GetSucceed() bool + func (m *ApiJobResponse) Reset() + func (m *ApiJobResponse) String() string + type ApiJobStatusQueryString struct + Pageing *Pageing + Status *JobStatus + func (*ApiJobStatusQueryString) Descriptor() ([]byte, []int) + func (*ApiJobStatusQueryString) ProtoMessage() + func (m *ApiJobStatusQueryString) GetPageing() *Pageing + func (m *ApiJobStatusQueryString) GetStatus() *JobStatus + func (m *ApiJobStatusQueryString) Reset() + func (m *ApiJobStatusQueryString) String() string + type ApiJobStatusResponse struct + Data []*JobStatus + MaxPageNum int32 + Message string + Succeed bool + func (*ApiJobStatusResponse) Descriptor() ([]byte, []int) + func (*ApiJobStatusResponse) ProtoMessage() + func (m *ApiJobStatusResponse) GetData() []*JobStatus + func (m *ApiJobStatusResponse) GetMaxPageNum() int32 + func (m *ApiJobStatusResponse) GetMessage() string + func (m *ApiJobStatusResponse) GetSucceed() bool + func (m *ApiJobStatusResponse) Reset() + func (m *ApiJobStatusResponse) String() string + type ApiNodeQueryString struct + Node *Node + Pageing *Pageing + func (*ApiNodeQueryString) Descriptor() ([]byte, []int) + func (*ApiNodeQueryString) ProtoMessage() + func (m *ApiNodeQueryString) GetNode() *Node + func (m *ApiNodeQueryString) GetPageing() *Pageing + func (m *ApiNodeQueryString) Reset() + func (m *ApiNodeQueryString) String() string + type ApiNodeResponse struct + Data []*Node + MaxPageNum int32 + Message string + Succeed bool + func (*ApiNodeResponse) Descriptor() ([]byte, []int) + func (*ApiNodeResponse) ProtoMessage() + func (m *ApiNodeResponse) GetData() []*Node + func (m *ApiNodeResponse) GetMaxPageNum() int32 + func (m *ApiNodeResponse) GetMessage() string + func (m *ApiNodeResponse) GetSucceed() bool + func (m *ApiNodeResponse) Reset() + func (m *ApiNodeResponse) String() string + type ApiSearchQueryString struct + Pageing *Pageing + SearchCondition *SearchCondition + func (*ApiSearchQueryString) Descriptor() ([]byte, []int) + func (*ApiSearchQueryString) ProtoMessage() + func (m *ApiSearchQueryString) GetPageing() *Pageing + func (m *ApiSearchQueryString) GetSearchCondition() *SearchCondition + func (m *ApiSearchQueryString) Reset() + func (m *ApiSearchQueryString) String() string + type ApiStringResponse struct + Data []string + MaxPageNum int32 + Message string + Succeed bool + func (*ApiStringResponse) Descriptor() ([]byte, []int) + func (*ApiStringResponse) ProtoMessage() + func (m *ApiStringResponse) GetData() []string + func (m *ApiStringResponse) GetMaxPageNum() int32 + func (m *ApiStringResponse) GetMessage() string + func (m *ApiStringResponse) GetSucceed() bool + func (m *ApiStringResponse) Reset() + func (m *ApiStringResponse) String() string + type Execution struct + FinishTime int64 + Group int64 + Name string + Output []byte + Region string + Retries int64 + RunNodeName string + SchedulerNodeName string + StartTime int64 + Succeed bool + func (*Execution) Descriptor() ([]byte, []int) + func (*Execution) ProtoMessage() + func (m *Execution) GetFinishTime() int64 + func (m *Execution) GetGroup() int64 + func (m *Execution) GetName() string + func (m *Execution) GetOutput() []byte + func (m *Execution) GetRegion() string + func (m *Execution) GetRetries() int64 + func (m *Execution) GetRunNodeName() string + func (m *Execution) GetSchedulerNodeName() string + func (m *Execution) GetStartTime() int64 + func (m *Execution) GetSucceed() bool + func (m *Execution) Reset() + func (m *Execution) String() string + type GetRPCConfigResp struct + Ip string + Port int32 + func (*GetRPCConfigResp) Descriptor() ([]byte, []int) + func (*GetRPCConfigResp) ProtoMessage() + func (m *GetRPCConfigResp) GetIp() string + func (m *GetRPCConfigResp) GetPort() int32 + func (m *GetRPCConfigResp) Reset() + func (m *GetRPCConfigResp) String() string + type Job struct + Command string + Disable bool + Expression string + Idempotent bool + MaxRunTime int32 + Name string + ParentJob *Job + ParentJobName string + Region string + Schedule string + SchedulerNodeName string + Shell bool + Threshold float64 + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) GetCommand() string + func (m *Job) GetDisable() bool + func (m *Job) GetExpression() string + func (m *Job) GetIdempotent() bool + func (m *Job) GetMaxRunTime() int32 + func (m *Job) GetName() string + func (m *Job) GetParentJob() *Job + func (m *Job) GetParentJobName() string + func (m *Job) GetRegion() string + func (m *Job) GetSchedule() string + func (m *Job) GetSchedulerNodeName() string + func (m *Job) GetShell() bool + func (m *Job) GetThreshold() float64 + func (m *Job) Reset() + func (m *Job) String() string + type JobClient interface + DoOps func(ctx context.Context, in *Params, opts ...grpc.CallOption) (*Result, error) + ExecDone func(ctx context.Context, in *Execution, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + GetJob func(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Job, error) + ProxyJobRun func(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Execution, error) + func NewJobClient(cc *grpc.ClientConn) JobClient + type JobCountResp struct + Count int64 + Name string + func (*JobCountResp) Descriptor() ([]byte, []int) + func (*JobCountResp) ProtoMessage() + func (m *JobCountResp) GetCount() int64 + func (m *JobCountResp) GetName() string + func (m *JobCountResp) Reset() + func (m *JobCountResp) String() string + type JobQueryParams struct + DistNodeName string + Name string + Region string + SourceNodeName string + func (*JobQueryParams) Descriptor() ([]byte, []int) + func (*JobQueryParams) ProtoMessage() + func (m *JobQueryParams) GetDistNodeName() string + func (m *JobQueryParams) GetName() string + func (m *JobQueryParams) GetRegion() string + func (m *JobQueryParams) GetSourceNodeName() string + func (m *JobQueryParams) Reset() + func (m *JobQueryParams) String() string + type JobServer interface + DoOps func(context.Context, *Params) (*Result, error) + ExecDone func(context.Context, *Execution) (*google_protobuf.Empty, error) + GetJob func(context.Context, *Job) (*Job, error) + ProxyJobRun func(context.Context, *Job) (*Execution, error) + type JobStatus struct + ErrorCount int64 + LastError string + LastHandleAgent string + LastSuccess string + Name string + Region string + SuccessCount int64 + func (*JobStatus) Descriptor() ([]byte, []int) + func (*JobStatus) ProtoMessage() + func (m *JobStatus) GetErrorCount() int64 + func (m *JobStatus) GetLastError() string + func (m *JobStatus) GetLastHandleAgent() string + func (m *JobStatus) GetLastSuccess() string + func (m *JobStatus) GetName() string + func (m *JobStatus) GetRegion() string + func (m *JobStatus) GetSuccessCount() int64 + func (m *JobStatus) Reset() + func (m *JobStatus) String() string + type Node struct + Alived bool + Name string + Region string + Role string + Tags map[string]string + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAlived() bool + func (m *Node) GetName() string + func (m *Node) GetRegion() string + func (m *Node) GetRole() string + func (m *Node) GetTags() map[string]string + func (m *Node) Reset() + func (m *Node) String() string + type Ops int32 + const Ops_ADD + const Ops_DELETE + const Ops_MODIFY + const Ops_READ + func (Ops) EnumDescriptor() ([]byte, []int) + func (x Ops) String() string + type Pageing struct + OutMaxPage bool + PageNum int32 + PageSize int32 + func (*Pageing) Descriptor() ([]byte, []int) + func (*Pageing) ProtoMessage() + func (m *Pageing) GetOutMaxPage() bool + func (m *Pageing) GetPageNum() int32 + func (m *Pageing) GetPageSize() int32 + func (m *Pageing) Reset() + func (m *Pageing) String() string + type Params struct + Obj *google_protobuf1.Any + Ops Ops + Search *Search + func (*Params) Descriptor() ([]byte, []int) + func (*Params) ProtoMessage() + func (m *Params) GetObj() *google_protobuf1.Any + func (m *Params) GetOps() Ops + func (m *Params) GetSearch() *Search + func (m *Params) Reset() + func (m *Params) String() string + type QueryJobRunParams struct + Execution *Execution + Exp string + func (*QueryJobRunParams) Descriptor() ([]byte, []int) + func (*QueryJobRunParams) ProtoMessage() + func (m *QueryJobRunParams) GetExecution() *Execution + func (m *QueryJobRunParams) GetExp() string + func (m *QueryJobRunParams) Reset() + func (m *QueryJobRunParams) String() string + type QueryResult struct + Message string + Node string + Status int32 + func (*QueryResult) Descriptor() ([]byte, []int) + func (*QueryResult) ProtoMessage() + func (m *QueryResult) GetMessage() string + func (m *QueryResult) GetNode() string + func (m *QueryResult) GetStatus() int32 + func (m *QueryResult) Reset() + func (m *QueryResult) String() string + type Result struct + MaxPageNum int32 + Objs []*google_protobuf1.Any + Succeed bool + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (m *Result) GetMaxPageNum() int32 + func (m *Result) GetObjs() []*google_protobuf1.Any + func (m *Result) GetSucceed() bool + func (m *Result) Reset() + func (m *Result) String() string + type Search struct + Conditions []string + Count bool + Links []string + PageNum int32 + PageSize int32 + func (*Search) Descriptor() ([]byte, []int) + func (*Search) ProtoMessage() + func (m *Search) GetConditions() []string + func (m *Search) GetCount() bool + func (m *Search) GetLinks() []string + func (m *Search) GetPageNum() int32 + func (m *Search) GetPageSize() int32 + func (m *Search) Reset() + func (m *Search) String() string + type SearchCondition struct + Conditions []string + Links []string + func (*SearchCondition) Descriptor() ([]byte, []int) + func (*SearchCondition) ProtoMessage() + func (m *SearchCondition) GetConditions() []string + func (m *SearchCondition) GetLinks() []string + func (m *SearchCondition) Reset() + func (m *SearchCondition) String() string