lookout

package
v0.3.77-rc-f2cdeab Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2023 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Overview

Package lookout is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLookout        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLookout          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLookout = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterLookoutHandler 

func RegisterLookoutHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterLookoutHandler registers the http handlers for service Lookout to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterLookoutHandlerClient 

func RegisterLookoutHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LookoutClient) error

RegisterLookoutHandlerClient registers the http handlers for service Lookout to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "LookoutClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LookoutClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "LookoutClient" to call the correct interceptors.

func RegisterLookoutHandlerFromEndpoint 

func RegisterLookoutHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterLookoutHandlerFromEndpoint is same as RegisterLookoutHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterLookoutHandlerServer 

func RegisterLookoutHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LookoutServer) error

RegisterLookoutHandlerServer registers the http handlers for service Lookout to "mux". UnaryRPC :call LookoutServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterLookoutHandlerFromEndpoint instead.

func RegisterLookoutServer 

func RegisterLookoutServer(s *grpc.Server, srv LookoutServer)

func SwaggerJsonTemplate 

func SwaggerJsonTemplate() string

SwaggerJsonTemplate is a generated function returning the template as a string. That string should be parsed by the functions of the golang's template package.

Types

type DurationStats 

type DurationStats struct {
	Shortest *types.Duration `protobuf:"bytes,1,opt,name=shortest,proto3" json:"shortest,omitempty"`
	Longest  *types.Duration `protobuf:"bytes,2,opt,name=longest,proto3" json:"longest,omitempty"`
	Average  *types.Duration `protobuf:"bytes,3,opt,name=average,proto3" json:"average,omitempty"`
	Median   *types.Duration `protobuf:"bytes,4,opt,name=median,proto3" json:"median,omitempty"`
	Q1       *types.Duration `protobuf:"bytes,5,opt,name=q1,proto3" json:"q1,omitempty"`
	Q3       *types.Duration `protobuf:"bytes,6,opt,name=q3,proto3" json:"q3,omitempty"`
}

func (*DurationStats) Descriptor 

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

func (*DurationStats) GetAverage 

func (m *DurationStats) GetAverage() *types.Duration

func (*DurationStats) GetLongest 

func (m *DurationStats) GetLongest() *types.Duration

func (*DurationStats) GetMedian 

func (m *DurationStats) GetMedian() *types.Duration

func (*DurationStats) GetQ1 

func (m *DurationStats) GetQ1() *types.Duration

func (*DurationStats) GetQ3 

func (m *DurationStats) GetQ3() *types.Duration

func (*DurationStats) GetShortest 

func (m *DurationStats) GetShortest() *types.Duration

func (*DurationStats) Marshal 

func (m *DurationStats) Marshal() (dAtA []byte, err error)

func (*DurationStats) MarshalTo 

func (m *DurationStats) MarshalTo(dAtA []byte) (int, error)

func (*DurationStats) MarshalToSizedBuffer 

func (m *DurationStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DurationStats) ProtoMessage 

func (*DurationStats) ProtoMessage()

func (*DurationStats) Reset 

func (m *DurationStats) Reset()

func (*DurationStats) Size 

func (m *DurationStats) Size() (n int)

func (*DurationStats) String 

func (this *DurationStats) String() string

func (*DurationStats) Unmarshal 

func (m *DurationStats) Unmarshal(dAtA []byte) error

func (*DurationStats) XXX_DiscardUnknown 

func (m *DurationStats) XXX_DiscardUnknown()

func (*DurationStats) XXX_Marshal 

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

func (*DurationStats) XXX_Merge 

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

func (*DurationStats) XXX_Size 

func (m *DurationStats) XXX_Size() int

func (*DurationStats) XXX_Unmarshal 

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

type GetJobSetsRequest 

type GetJobSetsRequest struct {
	Queue       string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	NewestFirst bool   `protobuf:"varint,2,opt,name=newest_first,json=newestFirst,proto3" json:"newestFirst,omitempty"`
	ActiveOnly  bool   `protobuf:"varint,3,opt,name=active_only,json=activeOnly,proto3" json:"activeOnly,omitempty"`
}

func (*GetJobSetsRequest) Descriptor 

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

func (*GetJobSetsRequest) GetActiveOnly 

func (m *GetJobSetsRequest) GetActiveOnly() bool

func (*GetJobSetsRequest) GetNewestFirst 

func (m *GetJobSetsRequest) GetNewestFirst() bool

func (*GetJobSetsRequest) GetQueue 

func (m *GetJobSetsRequest) GetQueue() string

func (*GetJobSetsRequest) Marshal 

func (m *GetJobSetsRequest) Marshal() (dAtA []byte, err error)

func (*GetJobSetsRequest) MarshalTo 

func (m *GetJobSetsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetJobSetsRequest) MarshalToSizedBuffer 

func (m *GetJobSetsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobSetsRequest) ProtoMessage 

func (*GetJobSetsRequest) ProtoMessage()

func (*GetJobSetsRequest) Reset 

func (m *GetJobSetsRequest) Reset()

func (*GetJobSetsRequest) Size 

func (m *GetJobSetsRequest) Size() (n int)

func (*GetJobSetsRequest) String 

func (this *GetJobSetsRequest) String() string

func (*GetJobSetsRequest) Unmarshal 

func (m *GetJobSetsRequest) Unmarshal(dAtA []byte) error

func (*GetJobSetsRequest) XXX_DiscardUnknown 

func (m *GetJobSetsRequest) XXX_DiscardUnknown()

func (*GetJobSetsRequest) XXX_Marshal 

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

func (*GetJobSetsRequest) XXX_Merge 

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

func (*GetJobSetsRequest) XXX_Size 

func (m *GetJobSetsRequest) XXX_Size() int

func (*GetJobSetsRequest) XXX_Unmarshal 

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

type GetJobSetsResponse 

type GetJobSetsResponse struct {
	JobSetInfos []*JobSetInfo `protobuf:"bytes,1,rep,name=job_set_infos,json=jobSetInfos,proto3" json:"jobSetInfos,omitempty"`
}

func (*GetJobSetsResponse) Descriptor 

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

func (*GetJobSetsResponse) GetJobSetInfos 

func (m *GetJobSetsResponse) GetJobSetInfos() []*JobSetInfo

func (*GetJobSetsResponse) Marshal 

func (m *GetJobSetsResponse) Marshal() (dAtA []byte, err error)

func (*GetJobSetsResponse) MarshalTo 

func (m *GetJobSetsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetJobSetsResponse) MarshalToSizedBuffer 

func (m *GetJobSetsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobSetsResponse) ProtoMessage 

func (*GetJobSetsResponse) ProtoMessage()

func (*GetJobSetsResponse) Reset 

func (m *GetJobSetsResponse) Reset()

func (*GetJobSetsResponse) Size 

func (m *GetJobSetsResponse) Size() (n int)

func (*GetJobSetsResponse) String 

func (this *GetJobSetsResponse) String() string

func (*GetJobSetsResponse) Unmarshal 

func (m *GetJobSetsResponse) Unmarshal(dAtA []byte) error

func (*GetJobSetsResponse) XXX_DiscardUnknown 

func (m *GetJobSetsResponse) XXX_DiscardUnknown()

func (*GetJobSetsResponse) XXX_Marshal 

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

func (*GetJobSetsResponse) XXX_Merge 

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

func (*GetJobSetsResponse) XXX_Size 

func (m *GetJobSetsResponse) XXX_Size() int

func (*GetJobSetsResponse) XXX_Unmarshal 

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

type GetJobsRequest 

type GetJobsRequest struct {
	Queue           string            `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	NewestFirst     bool              `protobuf:"varint,2,opt,name=newest_first,json=newestFirst,proto3" json:"newestFirst,omitempty"`
	JobStates       []string          `protobuf:"bytes,3,rep,name=job_states,json=jobStates,proto3" json:"jobStates,omitempty"`
	JobSetIds       []string          `protobuf:"bytes,4,rep,name=job_set_ids,json=jobSetIds,proto3" json:"jobSetIds,omitempty"`
	Take            uint32            `protobuf:"varint,5,opt,name=take,proto3" json:"take,omitempty"`
	Skip            uint32            `protobuf:"varint,6,opt,name=skip,proto3" json:"skip,omitempty"`
	JobId           string            `protobuf:"bytes,7,opt,name=jobId,proto3" json:"jobId,omitempty"`
	Owner           string            `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"`
	UserAnnotations map[string]string `` /* 193-byte string literal not displayed */
}

func (*GetJobsRequest) Descriptor 

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

func (*GetJobsRequest) GetJobId 

func (m *GetJobsRequest) GetJobId() string

func (*GetJobsRequest) GetJobSetIds 

func (m *GetJobsRequest) GetJobSetIds() []string

func (*GetJobsRequest) GetJobStates 

func (m *GetJobsRequest) GetJobStates() []string

func (*GetJobsRequest) GetNewestFirst 

func (m *GetJobsRequest) GetNewestFirst() bool

func (*GetJobsRequest) GetOwner 

func (m *GetJobsRequest) GetOwner() string

func (*GetJobsRequest) GetQueue 

func (m *GetJobsRequest) GetQueue() string

func (*GetJobsRequest) GetSkip 

func (m *GetJobsRequest) GetSkip() uint32

func (*GetJobsRequest) GetTake 

func (m *GetJobsRequest) GetTake() uint32

func (*GetJobsRequest) GetUserAnnotations 

func (m *GetJobsRequest) GetUserAnnotations() map[string]string

func (*GetJobsRequest) Marshal 

func (m *GetJobsRequest) Marshal() (dAtA []byte, err error)

func (*GetJobsRequest) MarshalTo 

func (m *GetJobsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetJobsRequest) MarshalToSizedBuffer 

func (m *GetJobsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobsRequest) ProtoMessage 

func (*GetJobsRequest) ProtoMessage()

func (*GetJobsRequest) Reset 

func (m *GetJobsRequest) Reset()

func (*GetJobsRequest) Size 

func (m *GetJobsRequest) Size() (n int)

func (*GetJobsRequest) String 

func (this *GetJobsRequest) String() string

func (*GetJobsRequest) Unmarshal 

func (m *GetJobsRequest) Unmarshal(dAtA []byte) error

func (*GetJobsRequest) XXX_DiscardUnknown 

func (m *GetJobsRequest) XXX_DiscardUnknown()

func (*GetJobsRequest) XXX_Marshal 

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

func (*GetJobsRequest) XXX_Merge 

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

func (*GetJobsRequest) XXX_Size 

func (m *GetJobsRequest) XXX_Size() int

func (*GetJobsRequest) XXX_Unmarshal 

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

type GetJobsResponse 

type GetJobsResponse struct {
	JobInfos []*JobInfo `protobuf:"bytes,1,rep,name=job_infos,json=jobInfos,proto3" json:"jobInfos,omitempty"`
}

func (*GetJobsResponse) Descriptor 

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

func (*GetJobsResponse) GetJobInfos 

func (m *GetJobsResponse) GetJobInfos() []*JobInfo

func (*GetJobsResponse) Marshal 

func (m *GetJobsResponse) Marshal() (dAtA []byte, err error)

func (*GetJobsResponse) MarshalTo 

func (m *GetJobsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetJobsResponse) MarshalToSizedBuffer 

func (m *GetJobsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetJobsResponse) ProtoMessage 

func (*GetJobsResponse) ProtoMessage()

func (*GetJobsResponse) Reset 

func (m *GetJobsResponse) Reset()

func (*GetJobsResponse) Size 

func (m *GetJobsResponse) Size() (n int)

func (*GetJobsResponse) String 

func (this *GetJobsResponse) String() string

func (*GetJobsResponse) Unmarshal 

func (m *GetJobsResponse) Unmarshal(dAtA []byte) error

func (*GetJobsResponse) XXX_DiscardUnknown 

func (m *GetJobsResponse) XXX_DiscardUnknown()

func (*GetJobsResponse) XXX_Marshal 

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

func (*GetJobsResponse) XXX_Merge 

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

func (*GetJobsResponse) XXX_Size 

func (m *GetJobsResponse) XXX_Size() int

func (*GetJobsResponse) XXX_Unmarshal 

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

type JobInfo 

type JobInfo struct {
	Job              *api.Job   `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Runs             []*RunInfo `protobuf:"bytes,2,rep,name=runs,proto3" json:"runs,omitempty"`
	Cancelled        *time.Time `protobuf:"bytes,3,opt,name=cancelled,proto3,stdtime" json:"cancelled,omitempty"`
	JobState         string     `protobuf:"bytes,4,opt,name=job_state,json=jobState,proto3" json:"jobState,omitempty"`
	JobJson          string     `protobuf:"bytes,5,opt,name=job_json,json=jobJson,proto3" json:"jobJson,omitempty"`
	JobStateDuration string     `protobuf:"bytes,6,opt,name=job_state_duration,json=jobStateDuration,proto3" json:"jobStateDuration,omitempty"`
}

func (*JobInfo) Descriptor 

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

func (*JobInfo) GetCancelled 

func (m *JobInfo) GetCancelled() *time.Time

func (*JobInfo) GetJob 

func (m *JobInfo) GetJob() *api.Job

func (*JobInfo) GetJobJson 

func (m *JobInfo) GetJobJson() string

func (*JobInfo) GetJobState 

func (m *JobInfo) GetJobState() string

func (*JobInfo) GetJobStateDuration 

func (m *JobInfo) GetJobStateDuration() string

func (*JobInfo) GetRuns 

func (m *JobInfo) GetRuns() []*RunInfo

func (*JobInfo) Marshal 

func (m *JobInfo) Marshal() (dAtA []byte, err error)

func (*JobInfo) MarshalTo 

func (m *JobInfo) MarshalTo(dAtA []byte) (int, error)

func (*JobInfo) MarshalToSizedBuffer 

func (m *JobInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobInfo) ProtoMessage 

func (*JobInfo) ProtoMessage()

func (*JobInfo) Reset 

func (m *JobInfo) Reset()

func (*JobInfo) Size 

func (m *JobInfo) Size() (n int)

func (*JobInfo) String 

func (this *JobInfo) String() string

func (*JobInfo) Unmarshal 

func (m *JobInfo) Unmarshal(dAtA []byte) error

func (*JobInfo) XXX_DiscardUnknown 

func (m *JobInfo) XXX_DiscardUnknown()

func (*JobInfo) XXX_Marshal 

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

func (*JobInfo) XXX_Merge 

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

func (*JobInfo) XXX_Size 

func (m *JobInfo) XXX_Size() int

func (*JobInfo) XXX_Unmarshal 

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

type JobSetInfo 

type JobSetInfo struct {
	Queue         string         `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	JobSet        string         `protobuf:"bytes,2,opt,name=job_set,json=jobSet,proto3" json:"jobSet,omitempty"`
	JobsQueued    uint32         `protobuf:"varint,3,opt,name=jobs_queued,json=jobsQueued,proto3" json:"jobsQueued,omitempty"`
	JobsPending   uint32         `protobuf:"varint,4,opt,name=jobs_pending,json=jobsPending,proto3" json:"jobsPending,omitempty"`
	JobsRunning   uint32         `protobuf:"varint,5,opt,name=jobs_running,json=jobsRunning,proto3" json:"jobsRunning,omitempty"`
	JobsSucceeded uint32         `protobuf:"varint,6,opt,name=jobs_succeeded,json=jobsSucceeded,proto3" json:"jobsSucceeded,omitempty"`
	JobsFailed    uint32         `protobuf:"varint,7,opt,name=jobs_failed,json=jobsFailed,proto3" json:"jobsFailed,omitempty"`
	JobsCancelled uint32         `protobuf:"varint,8,opt,name=jobs_cancelled,json=jobsCancelled,proto3" json:"jobsCancelled,omitempty"`
	RunningStats  *DurationStats `protobuf:"bytes,9,opt,name=runningStats,proto3" json:"runningStats,omitempty"`
	QueuedStats   *DurationStats `protobuf:"bytes,10,opt,name=queuedStats,proto3" json:"queuedStats,omitempty"`
	Submitted     *time.Time     `protobuf:"bytes,11,opt,name=submitted,proto3,stdtime" json:"submitted,omitempty"`
}

func (*JobSetInfo) Descriptor 

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

func (*JobSetInfo) GetJobSet 

func (m *JobSetInfo) GetJobSet() string

func (*JobSetInfo) GetJobsCancelled 

func (m *JobSetInfo) GetJobsCancelled() uint32

func (*JobSetInfo) GetJobsFailed 

func (m *JobSetInfo) GetJobsFailed() uint32

func (*JobSetInfo) GetJobsPending 

func (m *JobSetInfo) GetJobsPending() uint32

func (*JobSetInfo) GetJobsQueued 

func (m *JobSetInfo) GetJobsQueued() uint32

func (*JobSetInfo) GetJobsRunning 

func (m *JobSetInfo) GetJobsRunning() uint32

func (*JobSetInfo) GetJobsSucceeded 

func (m *JobSetInfo) GetJobsSucceeded() uint32

func (*JobSetInfo) GetQueue 

func (m *JobSetInfo) GetQueue() string

func (*JobSetInfo) GetQueuedStats 

func (m *JobSetInfo) GetQueuedStats() *DurationStats

func (*JobSetInfo) GetRunningStats 

func (m *JobSetInfo) GetRunningStats() *DurationStats

func (*JobSetInfo) GetSubmitted 

func (m *JobSetInfo) GetSubmitted() *time.Time

func (*JobSetInfo) Marshal 

func (m *JobSetInfo) Marshal() (dAtA []byte, err error)

func (*JobSetInfo) MarshalTo 

func (m *JobSetInfo) MarshalTo(dAtA []byte) (int, error)

func (*JobSetInfo) MarshalToSizedBuffer 

func (m *JobSetInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JobSetInfo) ProtoMessage 

func (*JobSetInfo) ProtoMessage()

func (*JobSetInfo) Reset 

func (m *JobSetInfo) Reset()

func (*JobSetInfo) Size 

func (m *JobSetInfo) Size() (n int)

func (*JobSetInfo) String 

func (this *JobSetInfo) String() string

func (*JobSetInfo) Unmarshal 

func (m *JobSetInfo) Unmarshal(dAtA []byte) error

func (*JobSetInfo) XXX_DiscardUnknown 

func (m *JobSetInfo) XXX_DiscardUnknown()

func (*JobSetInfo) XXX_Marshal 

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

func (*JobSetInfo) XXX_Merge 

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

func (*JobSetInfo) XXX_Size 

func (m *JobSetInfo) XXX_Size() int

func (*JobSetInfo) XXX_Unmarshal 

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

type LookoutClient 

type LookoutClient interface {
	Overview(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*SystemOverview, error)
	GetJobSets(ctx context.Context, in *GetJobSetsRequest, opts ...grpc.CallOption) (*GetJobSetsResponse, error)
	GetJobs(ctx context.Context, in *GetJobsRequest, opts ...grpc.CallOption) (*GetJobsResponse, error)
}

LookoutClient is the client API for Lookout service.

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

func NewLookoutClient 

func NewLookoutClient(cc *grpc.ClientConn) LookoutClient

type LookoutServer 

type LookoutServer interface {
	Overview(context.Context, *types.Empty) (*SystemOverview, error)
	GetJobSets(context.Context, *GetJobSetsRequest) (*GetJobSetsResponse, error)
	GetJobs(context.Context, *GetJobsRequest) (*GetJobsResponse, error)
}

LookoutServer is the server API for Lookout service.

type QueueInfo 

type QueueInfo struct {
	Queue                  string          `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	JobsQueued             uint32          `protobuf:"varint,2,opt,name=jobs_queued,json=jobsQueued,proto3" json:"jobsQueued,omitempty"`
	JobsPending            uint32          `protobuf:"varint,3,opt,name=jobs_pending,json=jobsPending,proto3" json:"jobsPending,omitempty"`
	JobsRunning            uint32          `protobuf:"varint,4,opt,name=jobs_running,json=jobsRunning,proto3" json:"jobsRunning,omitempty"`
	OldestQueuedJob        *JobInfo        `protobuf:"bytes,5,opt,name=oldest_queued_job,json=oldestQueuedJob,proto3" json:"oldestQueuedJob,omitempty"`
	LongestRunningJob      *JobInfo        `protobuf:"bytes,6,opt,name=longest_running_job,json=longestRunningJob,proto3" json:"longestRunningJob,omitempty"`
	OldestQueuedDuration   *types.Duration `protobuf:"bytes,7,opt,name=oldest_queued_duration,json=oldestQueuedDuration,proto3" json:"oldestQueuedDuration,omitempty"`
	LongestRunningDuration *types.Duration `` /* 127-byte string literal not displayed */
}

func (*QueueInfo) Descriptor 

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

func (*QueueInfo) GetJobsPending 

func (m *QueueInfo) GetJobsPending() uint32

func (*QueueInfo) GetJobsQueued 

func (m *QueueInfo) GetJobsQueued() uint32

func (*QueueInfo) GetJobsRunning 

func (m *QueueInfo) GetJobsRunning() uint32

func (*QueueInfo) GetLongestRunningDuration 

func (m *QueueInfo) GetLongestRunningDuration() *types.Duration

func (*QueueInfo) GetLongestRunningJob 

func (m *QueueInfo) GetLongestRunningJob() *JobInfo

func (*QueueInfo) GetOldestQueuedDuration 

func (m *QueueInfo) GetOldestQueuedDuration() *types.Duration

func (*QueueInfo) GetOldestQueuedJob 

func (m *QueueInfo) GetOldestQueuedJob() *JobInfo

func (*QueueInfo) GetQueue 

func (m *QueueInfo) GetQueue() string

func (*QueueInfo) Marshal 

func (m *QueueInfo) Marshal() (dAtA []byte, err error)

func (*QueueInfo) MarshalTo 

func (m *QueueInfo) MarshalTo(dAtA []byte) (int, error)

func (*QueueInfo) MarshalToSizedBuffer 

func (m *QueueInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueueInfo) ProtoMessage 

func (*QueueInfo) ProtoMessage()

func (*QueueInfo) Reset 

func (m *QueueInfo) Reset()

func (*QueueInfo) Size 

func (m *QueueInfo) Size() (n int)

func (*QueueInfo) String 

func (this *QueueInfo) String() string

func (*QueueInfo) Unmarshal 

func (m *QueueInfo) Unmarshal(dAtA []byte) error

func (*QueueInfo) XXX_DiscardUnknown 

func (m *QueueInfo) XXX_DiscardUnknown()

func (*QueueInfo) XXX_Marshal 

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

func (*QueueInfo) XXX_Merge 

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

func (*QueueInfo) XXX_Size 

func (m *QueueInfo) XXX_Size() int

func (*QueueInfo) XXX_Unmarshal 

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

type RunInfo 

type RunInfo struct {
	K8SId            string     `protobuf:"bytes,1,opt,name=k8s_id,json=k8sId,proto3" json:"k8sId,omitempty"`
	Cluster          string     `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Node             string     `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
	Succeeded        bool       `protobuf:"varint,4,opt,name=succeeded,proto3" json:"succeeded,omitempty"`
	Error            string     `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	Created          *time.Time `protobuf:"bytes,6,opt,name=created,proto3,stdtime" json:"created,omitempty"`
	Started          *time.Time `protobuf:"bytes,7,opt,name=started,proto3,stdtime" json:"started,omitempty"`
	Finished         *time.Time `protobuf:"bytes,8,opt,name=finished,proto3,stdtime" json:"finished,omitempty"`
	PodNumber        int32      `protobuf:"varint,9,opt,name=pod_number,json=podNumber,proto3" json:"podNumber,omitempty"`
	RunState         string     `protobuf:"bytes,10,opt,name=run_state,json=runState,proto3" json:"runState,omitempty"`
	UnableToSchedule bool       `protobuf:"varint,11,opt,name=unable_to_schedule,json=unableToSchedule,proto3" json:"unableToSchedule,omitempty"`
	Preempted        *time.Time `protobuf:"bytes,12,opt,name=preempted,proto3,stdtime" json:"preempted,omitempty"`
}

func (*RunInfo) Descriptor 

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

func (*RunInfo) GetCluster 

func (m *RunInfo) GetCluster() string

func (*RunInfo) GetCreated 

func (m *RunInfo) GetCreated() *time.Time

func (*RunInfo) GetError 

func (m *RunInfo) GetError() string

func (*RunInfo) GetFinished 

func (m *RunInfo) GetFinished() *time.Time

func (*RunInfo) GetK8SId 

func (m *RunInfo) GetK8SId() string

func (*RunInfo) GetNode 

func (m *RunInfo) GetNode() string

func (*RunInfo) GetPodNumber 

func (m *RunInfo) GetPodNumber() int32

func (*RunInfo) GetPreempted 

func (m *RunInfo) GetPreempted() *time.Time

func (*RunInfo) GetRunState 

func (m *RunInfo) GetRunState() string

func (*RunInfo) GetStarted 

func (m *RunInfo) GetStarted() *time.Time

func (*RunInfo) GetSucceeded 

func (m *RunInfo) GetSucceeded() bool

func (*RunInfo) GetUnableToSchedule 

func (m *RunInfo) GetUnableToSchedule() bool

func (*RunInfo) Marshal 

func (m *RunInfo) Marshal() (dAtA []byte, err error)

func (*RunInfo) MarshalTo 

func (m *RunInfo) MarshalTo(dAtA []byte) (int, error)

func (*RunInfo) MarshalToSizedBuffer 

func (m *RunInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RunInfo) ProtoMessage 

func (*RunInfo) ProtoMessage()

func (*RunInfo) Reset 

func (m *RunInfo) Reset()

func (*RunInfo) Size 

func (m *RunInfo) Size() (n int)

func (*RunInfo) String 

func (this *RunInfo) String() string

func (*RunInfo) Unmarshal 

func (m *RunInfo) Unmarshal(dAtA []byte) error

func (*RunInfo) XXX_DiscardUnknown 

func (m *RunInfo) XXX_DiscardUnknown()

func (*RunInfo) XXX_Marshal 

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

func (*RunInfo) XXX_Merge 

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

func (*RunInfo) XXX_Size 

func (m *RunInfo) XXX_Size() int

func (*RunInfo) XXX_Unmarshal 

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

type SystemOverview 

type SystemOverview struct {
	Queues []*QueueInfo `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
}

func (*SystemOverview) Descriptor 

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

func (*SystemOverview) GetQueues 

func (m *SystemOverview) GetQueues() []*QueueInfo

func (*SystemOverview) Marshal 

func (m *SystemOverview) Marshal() (dAtA []byte, err error)

func (*SystemOverview) MarshalTo 

func (m *SystemOverview) MarshalTo(dAtA []byte) (int, error)

func (*SystemOverview) MarshalToSizedBuffer 

func (m *SystemOverview) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SystemOverview) ProtoMessage 

func (*SystemOverview) ProtoMessage()

func (*SystemOverview) Reset 

func (m *SystemOverview) Reset()

func (*SystemOverview) Size 

func (m *SystemOverview) Size() (n int)

func (*SystemOverview) String 

func (this *SystemOverview) String() string

func (*SystemOverview) Unmarshal 

func (m *SystemOverview) Unmarshal(dAtA []byte) error

func (*SystemOverview) XXX_DiscardUnknown 

func (m *SystemOverview) XXX_DiscardUnknown()

func (*SystemOverview) XXX_Marshal 

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

func (*SystemOverview) XXX_Merge 

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

func (*SystemOverview) XXX_Size 

func (m *SystemOverview) XXX_Size() int

func (*SystemOverview) XXX_Unmarshal 

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

type UnimplementedLookoutServer 

type UnimplementedLookoutServer struct {
}

UnimplementedLookoutServer can be embedded to have forward compatible implementations.

func (*UnimplementedLookoutServer) GetJobSets 

func (*UnimplementedLookoutServer) GetJobSets(ctx context.Context, req *GetJobSetsRequest) (*GetJobSetsResponse, error)

func (*UnimplementedLookoutServer) GetJobs 

func (*UnimplementedLookoutServer) GetJobs(ctx context.Context, req *GetJobsRequest) (*GetJobsResponse, error)

func (*UnimplementedLookoutServer) Overview 

func (*UnimplementedLookoutServer) Overview(ctx context.Context, req *types.Empty) (*SystemOverview, 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.