lookout

package
v0.3.79-rc-9a1ab98 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 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) GetJobs

func (*UnimplementedLookoutServer) Overview

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL