proto

type PubConnectClient interface {
	DoWork(ctx context.Context, opts ...grpc.CallOption) (PubConnect_DoWorkClient, error)
	Register(ctx context.Context, in *RegReq, opts ...grpc.CallOption) (*RegResp, error)
	DeRegister(ctx context.Context, in *RegReq, opts ...grpc.CallOption) (*RegResp, error)
}

type PubConnectServer interface {
	DoWork(PubConnect_DoWorkServer) error
	Register(context.Context, *RegReq) (*RegResp, error)
	DeRegister(context.Context, *RegReq) (*RegResp, error)
}

type PubConnect_DoWorkClient interface {
	Send(*WorkDetail) error
	Recv() (*WorkDetail, error)
	grpc.ClientStream
}

type PubConnect_DoWorkServer interface {
	Send(*WorkDetail) error
	Recv() (*WorkDetail, error)
	grpc.ServerStream
}

type RegReq struct {
	PriKey  string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	AppName string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"`
	Uuid    string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` //注册节点启动uuid
	// contains filtered or unexported fields
}

type RegResp struct {
	PriKey string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Remark string `protobuf:"bytes,3,opt,name=remark,proto3" json:"remark,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedPubConnectServer struct {
}

type WorkDetail struct {
	PriKey       string `protobuf:"bytes,1,opt,name=priKey,proto3" json:"priKey,omitempty"`
	AppName      string `protobuf:"bytes,2,opt,name=appName,proto3" json:"appName,omitempty"` // 需要调度的执行器的应用名称
	AppUuid      string `protobuf:"bytes,3,opt,name=appUuid,proto3" json:"appUuid,omitempty"`
	Name         string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`                  // 执行的任务名称
	Uuid         string `protobuf:"bytes,5,opt,name=uuid,proto3" json:"uuid,omitempty"`                  // 执行任务的uid
	Params       string `protobuf:"bytes,6,opt,name=params,proto3" json:"params,omitempty"`              // 执行任务的参数
	RequestTime  int64  `protobuf:"varint,7,opt,name=requestTime,proto3" json:"requestTime,omitempty"`   // 提交任务的时间
	ResponseTime int64  `protobuf:"varint,8,opt,name=responseTime,proto3" json:"responseTime,omitempty"` // 响应任务的时间
	Status       string `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`              // 任务的状态
	Results      string `protobuf:"bytes,10,opt,name=results,proto3" json:"results,omitempty"`           // 查询任务的返回
	ErrCode      int32  `protobuf:"varint,11,opt,name=errCode,proto3" json:"errCode,omitempty"`          // 失败错误吗
	// contains filtered or unexported fields
}