jobs

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService 

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client 

type Client interface {
	GetChangedJobs(ctx context.Context, in *GetChangedJobsRequest) (*GetChangedJobsResponse, error)
}

Client is the client API for jobs service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient 

func NewClient(c giraffe_micro.Client) Client

type GetChangedJobsRequest 

type GetChangedJobsRequest struct {
	//
	//采集配置版本号
	CollectorConfigVersion []*GetChangedJobsRequest_CollectorConfigVersion `protobuf:"bytes,1,rep,name=collectorConfigVersion,proto3" json:"collectorConfigVersion" form:"collectorConfigVersion"`
	XXX_NoUnkeyedLiteral   struct{}                                        `json:"-"`
	XXX_unrecognized       []byte                                          `json:"-"`
	XXX_sizecache          int32                                           `json:"-"`
}

GetChangedJobs请求

func (*GetChangedJobsRequest) Descriptor 

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

func (*GetChangedJobsRequest) GetCollectorConfigVersion 

func (m *GetChangedJobsRequest) GetCollectorConfigVersion() []*GetChangedJobsRequest_CollectorConfigVersion

func (*GetChangedJobsRequest) ProtoMessage 

func (*GetChangedJobsRequest) ProtoMessage()

func (*GetChangedJobsRequest) Reset 

func (m *GetChangedJobsRequest) Reset()

func (*GetChangedJobsRequest) String 

func (m *GetChangedJobsRequest) String() string

func (*GetChangedJobsRequest) Validate 

func (this *GetChangedJobsRequest) Validate() error

func (*GetChangedJobsRequest) XXX_DiscardUnknown 

func (m *GetChangedJobsRequest) XXX_DiscardUnknown()

func (*GetChangedJobsRequest) XXX_Marshal 

func (m *GetChangedJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsRequest) XXX_Merge 

func (m *GetChangedJobsRequest) XXX_Merge(src proto.Message)

func (*GetChangedJobsRequest) XXX_Size 

func (m *GetChangedJobsRequest) XXX_Size() int

func (*GetChangedJobsRequest) XXX_Unmarshal 

func (m *GetChangedJobsRequest) XXX_Unmarshal(b []byte) error

type GetChangedJobsRequest_CollectorConfigVersion 

type GetChangedJobsRequest_CollectorConfigVersion struct {
	//
	//配置id
	ConfigId string `protobuf:"bytes,1,opt,name=configId,proto3" json:"configId" form:"configId"`
	//
	//版本id
	VersionId            int64    `protobuf:"varint,2,opt,name=versionId,proto3" json:"versionId" form:"versionId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChangedJobsRequest_CollectorConfigVersion) Descriptor 

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

func (*GetChangedJobsRequest_CollectorConfigVersion) GetConfigId 

func (m *GetChangedJobsRequest_CollectorConfigVersion) GetConfigId() string

func (*GetChangedJobsRequest_CollectorConfigVersion) GetVersionId 

func (m *GetChangedJobsRequest_CollectorConfigVersion) GetVersionId() int64

func (*GetChangedJobsRequest_CollectorConfigVersion) ProtoMessage 

func (*GetChangedJobsRequest_CollectorConfigVersion) ProtoMessage()

func (*GetChangedJobsRequest_CollectorConfigVersion) Reset 

func (m *GetChangedJobsRequest_CollectorConfigVersion) Reset()

func (*GetChangedJobsRequest_CollectorConfigVersion) String 

func (m *GetChangedJobsRequest_CollectorConfigVersion) String() string

func (*GetChangedJobsRequest_CollectorConfigVersion) Validate 

func (this *GetChangedJobsRequest_CollectorConfigVersion) Validate() error

func (*GetChangedJobsRequest_CollectorConfigVersion) XXX_DiscardUnknown 

func (m *GetChangedJobsRequest_CollectorConfigVersion) XXX_DiscardUnknown()

func (*GetChangedJobsRequest_CollectorConfigVersion) XXX_Marshal 

func (m *GetChangedJobsRequest_CollectorConfigVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsRequest_CollectorConfigVersion) XXX_Merge 

func (m *GetChangedJobsRequest_CollectorConfigVersion) XXX_Merge(src proto.Message)

func (*GetChangedJobsRequest_CollectorConfigVersion) XXX_Size 

func (m *GetChangedJobsRequest_CollectorConfigVersion) XXX_Size() int

func (*GetChangedJobsRequest_CollectorConfigVersion) XXX_Unmarshal 

func (m *GetChangedJobsRequest_CollectorConfigVersion) XXX_Unmarshal(b []byte) error

type GetChangedJobsResponse 

type GetChangedJobsResponse struct {
	//
	//变更采集任务
	ChangedJobs          []*GetChangedJobsResponse_ChangedJobs `protobuf:"bytes,1,rep,name=changedJobs,proto3" json:"changedJobs" form:"changedJobs"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

GetChangedJobs返回

func (*GetChangedJobsResponse) Descriptor 

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

func (*GetChangedJobsResponse) GetChangedJobs 

func (m *GetChangedJobsResponse) GetChangedJobs() []*GetChangedJobsResponse_ChangedJobs

func (*GetChangedJobsResponse) ProtoMessage 

func (*GetChangedJobsResponse) ProtoMessage()

func (*GetChangedJobsResponse) Reset 

func (m *GetChangedJobsResponse) Reset()

func (*GetChangedJobsResponse) String 

func (m *GetChangedJobsResponse) String() string

func (*GetChangedJobsResponse) Validate 

func (this *GetChangedJobsResponse) Validate() error

func (*GetChangedJobsResponse) XXX_DiscardUnknown 

func (m *GetChangedJobsResponse) XXX_DiscardUnknown()

func (*GetChangedJobsResponse) XXX_Marshal 

func (m *GetChangedJobsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsResponse) XXX_Merge 

func (m *GetChangedJobsResponse) XXX_Merge(src proto.Message)

func (*GetChangedJobsResponse) XXX_Size 

func (m *GetChangedJobsResponse) XXX_Size() int

func (*GetChangedJobsResponse) XXX_Unmarshal 

func (m *GetChangedJobsResponse) XXX_Unmarshal(b []byte) error

type GetChangedJobsResponseWrapper 

type GetChangedJobsResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *GetChangedJobsResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

GetChangedJobsApi返回

func (*GetChangedJobsResponseWrapper) Descriptor 

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

func (*GetChangedJobsResponseWrapper) GetCode 

func (m *GetChangedJobsResponseWrapper) GetCode() int32

func (*GetChangedJobsResponseWrapper) GetCodeExplain 

func (m *GetChangedJobsResponseWrapper) GetCodeExplain() string

func (*GetChangedJobsResponseWrapper) GetData 

func (m *GetChangedJobsResponseWrapper) GetData() *GetChangedJobsResponse

func (*GetChangedJobsResponseWrapper) GetError 

func (m *GetChangedJobsResponseWrapper) GetError() string

func (*GetChangedJobsResponseWrapper) ProtoMessage 

func (*GetChangedJobsResponseWrapper) ProtoMessage()

func (*GetChangedJobsResponseWrapper) Reset 

func (m *GetChangedJobsResponseWrapper) Reset()

func (*GetChangedJobsResponseWrapper) String 

func (m *GetChangedJobsResponseWrapper) String() string

func (*GetChangedJobsResponseWrapper) Validate 

func (this *GetChangedJobsResponseWrapper) Validate() error

func (*GetChangedJobsResponseWrapper) XXX_DiscardUnknown 

func (m *GetChangedJobsResponseWrapper) XXX_DiscardUnknown()

func (*GetChangedJobsResponseWrapper) XXX_Marshal 

func (m *GetChangedJobsResponseWrapper) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsResponseWrapper) XXX_Merge 

func (m *GetChangedJobsResponseWrapper) XXX_Merge(src proto.Message)

func (*GetChangedJobsResponseWrapper) XXX_Size 

func (m *GetChangedJobsResponseWrapper) XXX_Size() int

func (*GetChangedJobsResponseWrapper) XXX_Unmarshal 

func (m *GetChangedJobsResponseWrapper) XXX_Unmarshal(b []byte) error

type GetChangedJobsResponse_ChangedJobs 

type GetChangedJobsResponse_ChangedJobs struct {
	//
	//采集配置instanceId
	ConfigId string `protobuf:"bytes,1,opt,name=configId,proto3" json:"configId" form:"configId"`
	//
	//采集配置对应的采集任务版本号
	VersionId int64 `protobuf:"varint,2,opt,name=versionId,proto3" json:"versionId" form:"versionId"`
	//
	//采集指标
	Metric *collector_service.CollectorMetric `protobuf:"bytes,3,opt,name=metric,proto3" json:"metric" form:"metric"`
	//
	//采集任务
	Jobs []*GetChangedJobsResponse_ChangedJobs_Jobs `protobuf:"bytes,4,rep,name=jobs,proto3" json:"jobs" form:"jobs"`
	//
	//指标名称
	MetricName string `protobuf:"bytes,5,opt,name=metricName,proto3" json:"metricName" form:"metricName"`
	//
	//采集参数
	Params               []*GetChangedJobsResponse_ChangedJobs_Params `protobuf:"bytes,6,rep,name=params,proto3" json:"params" form:"params"`
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

func (*GetChangedJobsResponse_ChangedJobs) Descriptor 

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

func (*GetChangedJobsResponse_ChangedJobs) GetConfigId 

func (m *GetChangedJobsResponse_ChangedJobs) GetConfigId() string

func (*GetChangedJobsResponse_ChangedJobs) GetJobs 

func (m *GetChangedJobsResponse_ChangedJobs) GetJobs() []*GetChangedJobsResponse_ChangedJobs_Jobs

func (*GetChangedJobsResponse_ChangedJobs) GetMetric 

func (m *GetChangedJobsResponse_ChangedJobs) GetMetric() *collector_service.CollectorMetric

func (*GetChangedJobsResponse_ChangedJobs) GetMetricName 

func (m *GetChangedJobsResponse_ChangedJobs) GetMetricName() string

func (*GetChangedJobsResponse_ChangedJobs) GetParams 

func (m *GetChangedJobsResponse_ChangedJobs) GetParams() []*GetChangedJobsResponse_ChangedJobs_Params

func (*GetChangedJobsResponse_ChangedJobs) GetVersionId 

func (m *GetChangedJobsResponse_ChangedJobs) GetVersionId() int64

func (*GetChangedJobsResponse_ChangedJobs) ProtoMessage 

func (*GetChangedJobsResponse_ChangedJobs) ProtoMessage()

func (*GetChangedJobsResponse_ChangedJobs) Reset 

func (m *GetChangedJobsResponse_ChangedJobs) Reset()

func (*GetChangedJobsResponse_ChangedJobs) String 

func (m *GetChangedJobsResponse_ChangedJobs) String() string

func (*GetChangedJobsResponse_ChangedJobs) Validate 

func (this *GetChangedJobsResponse_ChangedJobs) Validate() error

func (*GetChangedJobsResponse_ChangedJobs) XXX_DiscardUnknown 

func (m *GetChangedJobsResponse_ChangedJobs) XXX_DiscardUnknown()

func (*GetChangedJobsResponse_ChangedJobs) XXX_Marshal 

func (m *GetChangedJobsResponse_ChangedJobs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsResponse_ChangedJobs) XXX_Merge 

func (m *GetChangedJobsResponse_ChangedJobs) XXX_Merge(src proto.Message)

func (*GetChangedJobsResponse_ChangedJobs) XXX_Size 

func (m *GetChangedJobsResponse_ChangedJobs) XXX_Size() int

func (*GetChangedJobsResponse_ChangedJobs) XXX_Unmarshal 

func (m *GetChangedJobsResponse_ChangedJobs) XXX_Unmarshal(b []byte) error

type GetChangedJobsResponse_ChangedJobs_Jobs 

type GetChangedJobsResponse_ChangedJobs_Jobs struct {
	//
	//变更类型, upsert - 插入或更新, delete - 删除
	ChangedType string `protobuf:"bytes,1,opt,name=changedType,proto3" json:"changedType" form:"changedType"`
	//
	//任务id
	JobId string `protobuf:"bytes,2,opt,name=jobId,proto3" json:"jobId" form:"jobId"`
	//
	//采集实例objectId
	ObjectId string `protobuf:"bytes,3,opt,name=objectId,proto3" json:"objectId" form:"objectId"`
	//
	//采集实例instanceId
	InstanceId string `protobuf:"bytes,4,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//指标名称
	MetricName string `protobuf:"bytes,5,opt,name=metricName,proto3" json:"metricName" form:"metricName"`
	//
	//采集ip
	CollectorIp string `protobuf:"bytes,6,opt,name=collectorIp,proto3" json:"collectorIp" form:"collectorIp"`
	//
	//采集ip
	DataSourceIps        []string `protobuf:"bytes,7,rep,name=dataSourceIps,proto3" json:"dataSourceIps" form:"dataSourceIps"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChangedJobsResponse_ChangedJobs_Jobs) Descriptor 

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

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetChangedType 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetChangedType() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetCollectorIp 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetCollectorIp() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetDataSourceIps 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetDataSourceIps() []string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetInstanceId 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetInstanceId() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetJobId 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetJobId() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetMetricName 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetMetricName() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) GetObjectId 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) GetObjectId() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) ProtoMessage 

func (*GetChangedJobsResponse_ChangedJobs_Jobs) ProtoMessage()

func (*GetChangedJobsResponse_ChangedJobs_Jobs) Reset 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) Reset()

func (*GetChangedJobsResponse_ChangedJobs_Jobs) String 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) String() string

func (*GetChangedJobsResponse_ChangedJobs_Jobs) Validate 

func (this *GetChangedJobsResponse_ChangedJobs_Jobs) Validate() error

func (*GetChangedJobsResponse_ChangedJobs_Jobs) XXX_DiscardUnknown 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) XXX_DiscardUnknown()

func (*GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Marshal 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Merge 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Merge(src proto.Message)

func (*GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Size 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Size() int

func (*GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Unmarshal 

func (m *GetChangedJobsResponse_ChangedJobs_Jobs) XXX_Unmarshal(b []byte) error

type GetChangedJobsResponse_ChangedJobs_Params 

type GetChangedJobsResponse_ChangedJobs_Params struct {
	//
	//参数名
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key" form:"key"`
	//
	//参数值
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value" form:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChangedJobsResponse_ChangedJobs_Params) Descriptor 

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

func (*GetChangedJobsResponse_ChangedJobs_Params) GetKey 

func (m *GetChangedJobsResponse_ChangedJobs_Params) GetKey() string

func (*GetChangedJobsResponse_ChangedJobs_Params) GetValue 

func (m *GetChangedJobsResponse_ChangedJobs_Params) GetValue() string

func (*GetChangedJobsResponse_ChangedJobs_Params) ProtoMessage 

func (*GetChangedJobsResponse_ChangedJobs_Params) ProtoMessage()

func (*GetChangedJobsResponse_ChangedJobs_Params) Reset 

func (m *GetChangedJobsResponse_ChangedJobs_Params) Reset()

func (*GetChangedJobsResponse_ChangedJobs_Params) String 

func (m *GetChangedJobsResponse_ChangedJobs_Params) String() string

func (*GetChangedJobsResponse_ChangedJobs_Params) Validate 

func (this *GetChangedJobsResponse_ChangedJobs_Params) Validate() error

func (*GetChangedJobsResponse_ChangedJobs_Params) XXX_DiscardUnknown 

func (m *GetChangedJobsResponse_ChangedJobs_Params) XXX_DiscardUnknown()

func (*GetChangedJobsResponse_ChangedJobs_Params) XXX_Marshal 

func (m *GetChangedJobsResponse_ChangedJobs_Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChangedJobsResponse_ChangedJobs_Params) XXX_Merge 

func (m *GetChangedJobsResponse_ChangedJobs_Params) XXX_Merge(src proto.Message)

func (*GetChangedJobsResponse_ChangedJobs_Params) XXX_Size 

func (m *GetChangedJobsResponse_ChangedJobs_Params) XXX_Size() int

func (*GetChangedJobsResponse_ChangedJobs_Params) XXX_Unmarshal 

func (m *GetChangedJobsResponse_ChangedJobs_Params) XXX_Unmarshal(b []byte) error

type Service 

type Service interface {
	GetChangedJobs(context.Context, *GetChangedJobsRequest) (*GetChangedJobsResponse, error)
}

Service is the server API for jobs service.

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.