jobs

package
v0.0.0-...-130476d Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Query_OrderType_name = map[int32]string{
		0: "ASC",
		1: "DESC",
	}
	Query_OrderType_value = map[string]int32{
		"ASC":  0,
		"DESC": 1,
	}
)

Enum value maps for Query_OrderType.

View Source 
var File_interservice_compliance_jobs_jobs_proto protoreflect.FileDescriptor

Functions

func RegisterJobsServiceServer 

func RegisterJobsServiceServer(s *grpc.Server, srv JobsServiceServer)

Types

type GetJobResultByNodeIdRequest 

type GetJobResultByNodeIdRequest struct {
	JobId  string `` /* 132-byte string literal not displayed */
	NodeId string `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetJobResultByNodeIdRequest) Descriptor deprecated 

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

Deprecated: Use GetJobResultByNodeIdRequest.ProtoReflect.Descriptor instead.

func (*GetJobResultByNodeIdRequest) GetJobId 

func (x *GetJobResultByNodeIdRequest) GetJobId() string

func (*GetJobResultByNodeIdRequest) GetNodeId 

func (x *GetJobResultByNodeIdRequest) GetNodeId() string

func (*GetJobResultByNodeIdRequest) ProtoMessage 

func (*GetJobResultByNodeIdRequest) ProtoMessage()

func (*GetJobResultByNodeIdRequest) ProtoReflect 

func (x *GetJobResultByNodeIdRequest) ProtoReflect() protoreflect.Message

func (*GetJobResultByNodeIdRequest) Reset 

func (x *GetJobResultByNodeIdRequest) Reset()

func (*GetJobResultByNodeIdRequest) String 

func (x *GetJobResultByNodeIdRequest) String() string

type Id 

type Id struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Id) Descriptor deprecated 

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

Deprecated: Use Id.ProtoReflect.Descriptor instead.

func (*Id) GetId 

func (x *Id) GetId() string

func (*Id) GetName 

func (x *Id) GetName() string

func (*Id) ProtoMessage 

func (*Id) ProtoMessage()

func (*Id) ProtoReflect 

func (x *Id) ProtoReflect() protoreflect.Message

func (*Id) Reset 

func (x *Id) Reset()

func (*Id) String 

func (x *Id) String() string

type Ids 

type Ids struct {
	Ids         []string       `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty" toml:"ids,omitempty" mapstructure:"ids,omitempty"`
	IdsWithTime []*IdsWithTime `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Ids) Descriptor deprecated 

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

Deprecated: Use Ids.ProtoReflect.Descriptor instead.

func (*Ids) GetIds 

func (x *Ids) GetIds() []string

func (*Ids) GetIdsWithTime 

func (x *Ids) GetIdsWithTime() []*IdsWithTime

func (*Ids) ProtoMessage 

func (*Ids) ProtoMessage()

func (*Ids) ProtoReflect 

func (x *Ids) ProtoReflect() protoreflect.Message

func (*Ids) Reset 

func (x *Ids) Reset()

func (*Ids) String 

func (x *Ids) String() string

type IdsWithTime 

type IdsWithTime struct {
	Id      string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	EndTime *timestamppb.Timestamp `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*IdsWithTime) Descriptor deprecated 

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

Deprecated: Use IdsWithTime.ProtoReflect.Descriptor instead.

func (*IdsWithTime) GetEndTime 

func (x *IdsWithTime) GetEndTime() *timestamppb.Timestamp

func (*IdsWithTime) GetId 

func (x *IdsWithTime) GetId() string

func (*IdsWithTime) ProtoMessage 

func (*IdsWithTime) ProtoMessage()

func (*IdsWithTime) ProtoReflect 

func (x *IdsWithTime) ProtoReflect() protoreflect.Message

func (*IdsWithTime) Reset 

func (x *IdsWithTime) Reset()

func (*IdsWithTime) String 

func (x *IdsWithTime) String() string

type Job 

type Job struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name          string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	Type          string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty" toml:"type,omitempty" mapstructure:"type,omitempty"`
	Timeout       int32                  `` /* 126-byte string literal not displayed */
	Tags          []*common.Kv           `protobuf:"bytes,20,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	StartTime     *timestamppb.Timestamp `` /* 153-byte string literal not displayed */
	EndTime       *timestamppb.Timestamp `` /* 143-byte string literal not displayed */
	Status        string                 `protobuf:"bytes,23,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	Retries       int32                  `` /* 127-byte string literal not displayed */
	RetriesLeft   int32                  `` /* 164-byte string literal not displayed */
	Results       []*ResultsRow          `` /* 126-byte string literal not displayed */
	Nodes         []string               `protobuf:"bytes,100,rep,name=nodes,proto3" json:"nodes,omitempty" toml:"nodes,omitempty" mapstructure:"nodes,omitempty"`
	Profiles      []string               `` /* 131-byte string literal not displayed */
	NodeCount     int32                  `` /* 155-byte string literal not displayed */
	ProfileCount  int32                  `` /* 170-byte string literal not displayed */
	NodeSelectors []*ManagerFilter       `` /* 174-byte string literal not displayed */
	ScheduledTime *timestamppb.Timestamp `` /* 174-byte string literal not displayed */
	Recurrence    string                 `` /* 139-byte string literal not displayed */
	ParentId      string                 `` /* 149-byte string literal not displayed */
	JobCount      int32                  `` /* 150-byte string literal not displayed */
	Deleted       bool                   `` /* 128-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetDeleted 

func (x *Job) GetDeleted() bool

func (*Job) GetEndTime 

func (x *Job) GetEndTime() *timestamppb.Timestamp

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetJobCount 

func (x *Job) GetJobCount() int32

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetNodeCount 

func (x *Job) GetNodeCount() int32

func (*Job) GetNodeSelectors 

func (x *Job) GetNodeSelectors() []*ManagerFilter

func (*Job) GetNodes 

func (x *Job) GetNodes() []string

func (*Job) GetParentId 

func (x *Job) GetParentId() string

func (*Job) GetProfileCount 

func (x *Job) GetProfileCount() int32

func (*Job) GetProfiles 

func (x *Job) GetProfiles() []string

func (*Job) GetRecurrence 

func (x *Job) GetRecurrence() string

func (*Job) GetResults 

func (x *Job) GetResults() []*ResultsRow

func (*Job) GetRetries 

func (x *Job) GetRetries() int32

func (*Job) GetRetriesLeft 

func (x *Job) GetRetriesLeft() int32

func (*Job) GetScheduledTime 

func (x *Job) GetScheduledTime() *timestamppb.Timestamp

func (*Job) GetStartTime 

func (x *Job) GetStartTime() *timestamppb.Timestamp

func (*Job) GetStatus 

func (x *Job) GetStatus() string

func (*Job) GetTags 

func (x *Job) GetTags() []*common.Kv

func (*Job) GetTimeout 

func (x *Job) GetTimeout() int32

func (*Job) GetType 

func (x *Job) GetType() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type Jobs 

type Jobs struct {
	Jobs  []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty" toml:"jobs,omitempty" mapstructure:"jobs,omitempty"`
	Total int32  `protobuf:"varint,20,opt,name=total,proto3" json:"total,omitempty" toml:"total,omitempty" mapstructure:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*Jobs) Descriptor deprecated 

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

Deprecated: Use Jobs.ProtoReflect.Descriptor instead.

func (*Jobs) GetJobs 

func (x *Jobs) GetJobs() []*Job

func (*Jobs) GetTotal 

func (x *Jobs) GetTotal() int32

func (*Jobs) ProtoMessage 

func (*Jobs) ProtoMessage()

func (*Jobs) ProtoReflect 

func (x *Jobs) ProtoReflect() protoreflect.Message

func (*Jobs) Reset 

func (x *Jobs) Reset()

func (*Jobs) String 

func (x *Jobs) String() string

type JobsServiceClient 

type JobsServiceClient interface {
	Create(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Id, error)
	Read(ctx context.Context, in *Id, opts ...grpc.CallOption) (*Job, error)
	Update(ctx context.Context, in *Job, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Delete(ctx context.Context, in *Id, opts ...grpc.CallOption) (*emptypb.Empty, error)
	List(ctx context.Context, in *Query, opts ...grpc.CallOption) (*Jobs, error)
	Rerun(ctx context.Context, in *Id, opts ...grpc.CallOption) (*RerunResponse, error)
	ListInitiatedScans(ctx context.Context, in *TimeQuery, opts ...grpc.CallOption) (*Ids, error)
	GetJobResultByNodeId(ctx context.Context, in *GetJobResultByNodeIdRequest, opts ...grpc.CallOption) (*ResultsRow, error)
}

JobsServiceClient is the client API for JobsService service.

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

func NewJobsServiceClient 

func NewJobsServiceClient(cc grpc.ClientConnInterface) JobsServiceClient

type JobsServiceServer 

type JobsServiceServer interface {
	Create(context.Context, *Job) (*Id, error)
	Read(context.Context, *Id) (*Job, error)
	Update(context.Context, *Job) (*emptypb.Empty, error)
	Delete(context.Context, *Id) (*emptypb.Empty, error)
	List(context.Context, *Query) (*Jobs, error)
	Rerun(context.Context, *Id) (*RerunResponse, error)
	ListInitiatedScans(context.Context, *TimeQuery) (*Ids, error)
	GetJobResultByNodeId(context.Context, *GetJobResultByNodeIdRequest) (*ResultsRow, error)
}

JobsServiceServer is the server API for JobsService service.

type ManagerFilter 

type ManagerFilter struct {
	ManagerId string           `` /* 152-byte string literal not displayed */
	Filters   []*common.Filter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty" toml:"filters,omitempty" mapstructure:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*ManagerFilter) Descriptor deprecated 

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

Deprecated: Use ManagerFilter.ProtoReflect.Descriptor instead.

func (*ManagerFilter) GetFilters 

func (x *ManagerFilter) GetFilters() []*common.Filter

func (*ManagerFilter) GetManagerId 

func (x *ManagerFilter) GetManagerId() string

func (*ManagerFilter) ProtoMessage 

func (*ManagerFilter) ProtoMessage()

func (*ManagerFilter) ProtoReflect 

func (x *ManagerFilter) ProtoReflect() protoreflect.Message

func (*ManagerFilter) Reset 

func (x *ManagerFilter) Reset()

func (*ManagerFilter) String 

func (x *ManagerFilter) String() string

type Query 

type Query struct {
	Filters []*common.Filter `` /* 126-byte string literal not displayed */
	Order   Query_OrderType  `` /* 177-byte string literal not displayed */
	Sort    string           `protobuf:"bytes,22,opt,name=sort,proto3" json:"sort,omitempty" toml:"sort,omitempty" mapstructure:"sort,omitempty"`
	Page    int32            `protobuf:"varint,23,opt,name=page,proto3" json:"page,omitempty" toml:"page,omitempty" mapstructure:"page,omitempty"`
	PerPage int32            `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetFilters 

func (x *Query) GetFilters() []*common.Filter

func (*Query) GetOrder 

func (x *Query) GetOrder() Query_OrderType

func (*Query) GetPage 

func (x *Query) GetPage() int32

func (*Query) GetPerPage 

func (x *Query) GetPerPage() int32

func (*Query) GetSort 

func (x *Query) GetSort() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type Query_OrderType 

type Query_OrderType int32
const (
	Query_ASC  Query_OrderType = 0
	Query_DESC Query_OrderType = 1
)

func (Query_OrderType) Descriptor 

func (Query_OrderType) Descriptor() protoreflect.EnumDescriptor

func (Query_OrderType) Enum 

func (x Query_OrderType) Enum() *Query_OrderType

func (Query_OrderType) EnumDescriptor deprecated 

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

Deprecated: Use Query_OrderType.Descriptor instead.

func (Query_OrderType) Number 

func (x Query_OrderType) Number() protoreflect.EnumNumber

func (Query_OrderType) String 

func (x Query_OrderType) String() string

func (Query_OrderType) Type 

func (Query_OrderType) Type() protoreflect.EnumType

type RerunResponse 

type RerunResponse struct {
	// contains filtered or unexported fields
}

func (*RerunResponse) Descriptor deprecated 

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

Deprecated: Use RerunResponse.ProtoReflect.Descriptor instead.

func (*RerunResponse) ProtoMessage 

func (*RerunResponse) ProtoMessage()

func (*RerunResponse) ProtoReflect 

func (x *RerunResponse) ProtoReflect() protoreflect.Message

func (*RerunResponse) Reset 

func (x *RerunResponse) Reset()

func (*RerunResponse) String 

func (x *RerunResponse) String() string

type ResultsRow 

type ResultsRow struct {
	NodeId    string                 `` /* 137-byte string literal not displayed */
	ReportId  string                 `` /* 147-byte string literal not displayed */
	Status    string                 `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty" toml:"status,omitempty" mapstructure:"status,omitempty"`
	Result    string                 `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty" toml:"result,omitempty" mapstructure:"result,omitempty"`
	JobId     string                 `` /* 132-byte string literal not displayed */
	StartTime *timestamppb.Timestamp `` /* 153-byte string literal not displayed */
	EndTime   *timestamppb.Timestamp `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResultsRow) Descriptor deprecated 

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

Deprecated: Use ResultsRow.ProtoReflect.Descriptor instead.

func (*ResultsRow) GetEndTime 

func (x *ResultsRow) GetEndTime() *timestamppb.Timestamp

func (*ResultsRow) GetJobId 

func (x *ResultsRow) GetJobId() string

func (*ResultsRow) GetNodeId 

func (x *ResultsRow) GetNodeId() string

func (*ResultsRow) GetReportId 

func (x *ResultsRow) GetReportId() string

func (*ResultsRow) GetResult 

func (x *ResultsRow) GetResult() string

func (*ResultsRow) GetStartTime 

func (x *ResultsRow) GetStartTime() *timestamppb.Timestamp

func (*ResultsRow) GetStatus 

func (x *ResultsRow) GetStatus() string

func (*ResultsRow) ProtoMessage 

func (*ResultsRow) ProtoMessage()

func (*ResultsRow) ProtoReflect 

func (x *ResultsRow) ProtoReflect() protoreflect.Message

func (*ResultsRow) Reset 

func (x *ResultsRow) Reset()

func (*ResultsRow) String 

func (x *ResultsRow) String() string

type TimeQuery 

type TimeQuery struct {
	StartTime *timestamppb.Timestamp `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TimeQuery) Descriptor deprecated 

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

Deprecated: Use TimeQuery.ProtoReflect.Descriptor instead.

func (*TimeQuery) GetStartTime 

func (x *TimeQuery) GetStartTime() *timestamppb.Timestamp

func (*TimeQuery) ProtoMessage 

func (*TimeQuery) ProtoMessage()

func (*TimeQuery) ProtoReflect 

func (x *TimeQuery) ProtoReflect() protoreflect.Message

func (*TimeQuery) Reset 

func (x *TimeQuery) Reset()

func (*TimeQuery) String 

func (x *TimeQuery) String() string

type UnimplementedJobsServiceServer 

type UnimplementedJobsServiceServer struct {
}

UnimplementedJobsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobsServiceServer) Create 

func (*UnimplementedJobsServiceServer) Create(context.Context, *Job) (*Id, error)

func (*UnimplementedJobsServiceServer) Delete 

func (*UnimplementedJobsServiceServer) Delete(context.Context, *Id) (*emptypb.Empty, error)

func (*UnimplementedJobsServiceServer) GetJobResultByNodeId 

func (*UnimplementedJobsServiceServer) GetJobResultByNodeId(context.Context, *GetJobResultByNodeIdRequest) (*ResultsRow, error)

func (*UnimplementedJobsServiceServer) List 

func (*UnimplementedJobsServiceServer) List(context.Context, *Query) (*Jobs, error)

func (*UnimplementedJobsServiceServer) ListInitiatedScans 

func (*UnimplementedJobsServiceServer) ListInitiatedScans(context.Context, *TimeQuery) (*Ids, error)

func (*UnimplementedJobsServiceServer) Read 

func (*UnimplementedJobsServiceServer) Read(context.Context, *Id) (*Job, error)

func (*UnimplementedJobsServiceServer) Rerun 

func (*UnimplementedJobsServiceServer) Rerun(context.Context, *Id) (*RerunResponse, error)

func (*UnimplementedJobsServiceServer) Update 

func (*UnimplementedJobsServiceServer) Update(context.Context, *Job) (*emptypb.Empty, error)

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.