api

package
v0.1.15 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2020 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthQueue = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQueue   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthSubmit = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSubmit   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthUsage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowUsage   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterAggregatedQueueServer 

func RegisterAggregatedQueueServer(s *grpc.Server, srv AggregatedQueueServer)

func RegisterEventHandler 

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

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

func RegisterEventHandlerClient 

func RegisterEventHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EventClient) error

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

func RegisterEventHandlerFromEndpoint 

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

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

func RegisterEventHandlerServer 

func RegisterEventHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EventServer) error

RegisterEventHandlerServer registers the http handlers for service Event to "mux". UnaryRPC :call EventServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterEventServer 

func RegisterEventServer(s *grpc.Server, srv EventServer)

func RegisterSubmitHandler 

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

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

func RegisterSubmitHandlerClient 

func RegisterSubmitHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SubmitClient) error

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

func RegisterSubmitHandlerFromEndpoint 

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

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

func RegisterSubmitHandlerServer 

func RegisterSubmitHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SubmitServer) error

RegisterSubmitHandlerServer registers the http handlers for service Submit to "mux". UnaryRPC :call SubmitServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterSubmitServer 

func RegisterSubmitServer(s *grpc.Server, srv SubmitServer)

func RegisterUsageServer 

func RegisterUsageServer(s *grpc.Server, srv UsageServer)

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 AggregatedQueueClient 

type AggregatedQueueClient interface {
	LeaseJobs(ctx context.Context, in *LeaseRequest, opts ...grpc.CallOption) (*JobLease, error)
	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*IdList, error)
	ReturnLease(ctx context.Context, in *ReturnLeaseRequest, opts ...grpc.CallOption) (*types.Empty, error)
	ReportDone(ctx context.Context, in *IdList, opts ...grpc.CallOption) (*IdList, error)
}

AggregatedQueueClient is the client API for AggregatedQueue service.

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

func NewAggregatedQueueClient 

func NewAggregatedQueueClient(cc *grpc.ClientConn) AggregatedQueueClient

type AggregatedQueueServer 

type AggregatedQueueServer interface {
	LeaseJobs(context.Context, *LeaseRequest) (*JobLease, error)
	RenewLease(context.Context, *RenewLeaseRequest) (*IdList, error)
	ReturnLease(context.Context, *ReturnLeaseRequest) (*types.Empty, error)
	ReportDone(context.Context, *IdList) (*IdList, error)
}

AggregatedQueueServer is the server API for AggregatedQueue service.

type CancellationResult 

type CancellationResult struct {
	CancelledIds []string `protobuf:"bytes,1,rep,name=CancelledIds,proto3" json:"CancelledIds,omitempty"`
}

swagger:model

func (*CancellationResult) Descriptor 

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

func (*CancellationResult) GetCancelledIds 

func (m *CancellationResult) GetCancelledIds() []string

func (*CancellationResult) Marshal 

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

func (*CancellationResult) MarshalTo 

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

func (*CancellationResult) ProtoMessage 

func (*CancellationResult) ProtoMessage()

func (*CancellationResult) Reset 

func (m *CancellationResult) Reset()

func (*CancellationResult) Size 

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

func (*CancellationResult) String 

func (this *CancellationResult) String() string

func (*CancellationResult) Unmarshal 

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

func (*CancellationResult) XXX_DiscardUnknown 

func (m *CancellationResult) XXX_DiscardUnknown()

func (*CancellationResult) XXX_Marshal 

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

func (*CancellationResult) XXX_Merge 

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

func (*CancellationResult) XXX_Size 

func (m *CancellationResult) XXX_Size() int

func (*CancellationResult) XXX_Unmarshal 

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

type ClusterLeasedReport added in v0.1.6 

type ClusterLeasedReport struct {
	ClusterId  string               `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	ReportTime time.Time            `protobuf:"bytes,2,opt,name=ReportTime,proto3,stdtime" json:"ReportTime"`
	Queues     []*QueueLeasedReport `protobuf:"bytes,3,rep,name=Queues,proto3" json:"Queues,omitempty"`
}

func (*ClusterLeasedReport) Descriptor added in v0.1.6 

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

func (*ClusterLeasedReport) GetClusterId added in v0.1.6 

func (m *ClusterLeasedReport) GetClusterId() string

func (*ClusterLeasedReport) GetQueues added in v0.1.6 

func (m *ClusterLeasedReport) GetQueues() []*QueueLeasedReport

func (*ClusterLeasedReport) GetReportTime added in v0.1.6 

func (m *ClusterLeasedReport) GetReportTime() time.Time

func (*ClusterLeasedReport) Marshal added in v0.1.6 

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

func (*ClusterLeasedReport) MarshalTo added in v0.1.6 

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

func (*ClusterLeasedReport) ProtoMessage added in v0.1.6 

func (*ClusterLeasedReport) ProtoMessage()

func (*ClusterLeasedReport) Reset added in v0.1.6 

func (m *ClusterLeasedReport) Reset()

func (*ClusterLeasedReport) Size added in v0.1.6 

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

func (*ClusterLeasedReport) String added in v0.1.6 

func (this *ClusterLeasedReport) String() string

func (*ClusterLeasedReport) Unmarshal added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_DiscardUnknown added in v0.1.6 

func (m *ClusterLeasedReport) XXX_DiscardUnknown()

func (*ClusterLeasedReport) XXX_Marshal added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_Merge added in v0.1.6 

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

func (*ClusterLeasedReport) XXX_Size added in v0.1.6 

func (m *ClusterLeasedReport) XXX_Size() int

func (*ClusterLeasedReport) XXX_Unmarshal added in v0.1.6 

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

type ClusterSchedulingInfoReport added in v0.1.6 

type ClusterSchedulingInfoReport struct {
	ClusterId      string                       `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	ReportTime     time.Time                    `protobuf:"bytes,2,opt,name=ReportTime,proto3,stdtime" json:"ReportTime"`
	NodeTypes      []*NodeType                  `protobuf:"bytes,5,rep,name=NodeTypes,proto3" json:"NodeTypes,omitempty"`
	MinimumJobSize map[string]resource.Quantity `` /* 159-byte string literal not displayed */
}

Used to store last info in Redis

func (*ClusterSchedulingInfoReport) Descriptor added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) GetClusterId added in v0.1.6 

func (m *ClusterSchedulingInfoReport) GetClusterId() string

func (*ClusterSchedulingInfoReport) GetMinimumJobSize added in v0.1.6 

func (m *ClusterSchedulingInfoReport) GetMinimumJobSize() map[string]resource.Quantity

func (*ClusterSchedulingInfoReport) GetNodeTypes added in v0.1.14 

func (m *ClusterSchedulingInfoReport) GetNodeTypes() []*NodeType

func (*ClusterSchedulingInfoReport) GetReportTime added in v0.1.6 

func (m *ClusterSchedulingInfoReport) GetReportTime() time.Time

func (*ClusterSchedulingInfoReport) Marshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) MarshalTo added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) ProtoMessage added in v0.1.6 

func (*ClusterSchedulingInfoReport) ProtoMessage()

func (*ClusterSchedulingInfoReport) Reset added in v0.1.6 

func (m *ClusterSchedulingInfoReport) Reset()

func (*ClusterSchedulingInfoReport) Size added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) String added in v0.1.6 

func (this *ClusterSchedulingInfoReport) String() string

func (*ClusterSchedulingInfoReport) Unmarshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_DiscardUnknown added in v0.1.6 

func (m *ClusterSchedulingInfoReport) XXX_DiscardUnknown()

func (*ClusterSchedulingInfoReport) XXX_Marshal added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_Merge added in v0.1.6 

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

func (*ClusterSchedulingInfoReport) XXX_Size added in v0.1.6 

func (m *ClusterSchedulingInfoReport) XXX_Size() int

func (*ClusterSchedulingInfoReport) XXX_Unmarshal added in v0.1.6 

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

type ClusterUsageReport 

type ClusterUsageReport struct {
	ClusterId                string                       `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	ReportTime               time.Time                    `protobuf:"bytes,2,opt,name=ReportTime,proto3,stdtime" json:"ReportTime"`
	Queues                   []*QueueReport               `protobuf:"bytes,3,rep,name=Queues,proto3" json:"Queues,omitempty"`
	ClusterCapacity          map[string]resource.Quantity `` /* 161-byte string literal not displayed */
	ClusterAvailableCapacity map[string]resource.Quantity `` /* 179-byte string literal not displayed */
}

func (*ClusterUsageReport) Descriptor 

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

func (*ClusterUsageReport) GetClusterAvailableCapacity 

func (m *ClusterUsageReport) GetClusterAvailableCapacity() map[string]resource.Quantity

func (*ClusterUsageReport) GetClusterCapacity 

func (m *ClusterUsageReport) GetClusterCapacity() map[string]resource.Quantity

func (*ClusterUsageReport) GetClusterId 

func (m *ClusterUsageReport) GetClusterId() string

func (*ClusterUsageReport) GetQueues 

func (m *ClusterUsageReport) GetQueues() []*QueueReport

func (*ClusterUsageReport) GetReportTime 

func (m *ClusterUsageReport) GetReportTime() time.Time

func (*ClusterUsageReport) Marshal 

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

func (*ClusterUsageReport) MarshalTo 

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

func (*ClusterUsageReport) ProtoMessage 

func (*ClusterUsageReport) ProtoMessage()

func (*ClusterUsageReport) Reset 

func (m *ClusterUsageReport) Reset()

func (*ClusterUsageReport) Size 

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

func (*ClusterUsageReport) String 

func (this *ClusterUsageReport) String() string

func (*ClusterUsageReport) Unmarshal 

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

func (*ClusterUsageReport) XXX_DiscardUnknown 

func (m *ClusterUsageReport) XXX_DiscardUnknown()

func (*ClusterUsageReport) XXX_Marshal 

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

func (*ClusterUsageReport) XXX_Merge 

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

func (*ClusterUsageReport) XXX_Size 

func (m *ClusterUsageReport) XXX_Size() int

func (*ClusterUsageReport) XXX_Unmarshal 

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

type ComputeResource added in v0.1.6 

type ComputeResource struct {
	Resources map[string]resource.Quantity `` /* 149-byte string literal not displayed */
}

func (*ComputeResource) Descriptor added in v0.1.6 

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

func (*ComputeResource) GetResources added in v0.1.6 

func (m *ComputeResource) GetResources() map[string]resource.Quantity

func (*ComputeResource) Marshal added in v0.1.6 

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

func (*ComputeResource) MarshalTo added in v0.1.6 

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

func (*ComputeResource) ProtoMessage added in v0.1.6 

func (*ComputeResource) ProtoMessage()

func (*ComputeResource) Reset added in v0.1.6 

func (m *ComputeResource) Reset()

func (*ComputeResource) Size added in v0.1.6 

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

func (*ComputeResource) String added in v0.1.6 

func (this *ComputeResource) String() string

func (*ComputeResource) Unmarshal added in v0.1.6 

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

func (*ComputeResource) XXX_DiscardUnknown added in v0.1.6 

func (m *ComputeResource) XXX_DiscardUnknown()

func (*ComputeResource) XXX_Marshal added in v0.1.6 

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

func (*ComputeResource) XXX_Merge added in v0.1.6 

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

func (*ComputeResource) XXX_Size added in v0.1.6 

func (m *ComputeResource) XXX_Size() int

func (*ComputeResource) XXX_Unmarshal added in v0.1.6 

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

type Event 

type Event interface {
	GetJobId() string
	GetJobSetId() string
	GetQueue() string
	GetCreated() time.Time
}

func UnwrapEvent 

func UnwrapEvent(message *EventMessage) (Event, error)

type EventClient 

type EventClient interface {
	ReportMultiple(ctx context.Context, in *EventList, opts ...grpc.CallOption) (*types.Empty, error)
	Report(ctx context.Context, in *EventMessage, opts ...grpc.CallOption) (*types.Empty, error)
	GetJobSetEvents(ctx context.Context, in *JobSetRequest, opts ...grpc.CallOption) (Event_GetJobSetEventsClient, error)
}

EventClient is the client API for Event service.

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

func NewEventClient 

func NewEventClient(cc *grpc.ClientConn) EventClient

type EventList 

type EventList struct {
	Events []*EventMessage `protobuf:"bytes,1,rep,name=Events,proto3" json:"Events,omitempty"`
}

func (*EventList) Descriptor 

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

func (*EventList) GetEvents 

func (m *EventList) GetEvents() []*EventMessage

func (*EventList) Marshal 

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

func (*EventList) MarshalTo 

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

func (*EventList) ProtoMessage 

func (*EventList) ProtoMessage()

func (*EventList) Reset 

func (m *EventList) Reset()

func (*EventList) Size 

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

func (*EventList) String 

func (this *EventList) String() string

func (*EventList) Unmarshal 

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

func (*EventList) XXX_DiscardUnknown 

func (m *EventList) XXX_DiscardUnknown()

func (*EventList) XXX_Marshal 

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

func (*EventList) XXX_Merge 

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

func (*EventList) XXX_Size 

func (m *EventList) XXX_Size() int

func (*EventList) XXX_Unmarshal 

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

type EventMessage 

type EventMessage struct {
	// Types that are valid to be assigned to Events:
	//	*EventMessage_Submitted
	//	*EventMessage_Queued
	//	*EventMessage_Leased
	//	*EventMessage_LeaseReturned
	//	*EventMessage_LeaseExpired
	//	*EventMessage_Pending
	//	*EventMessage_Running
	//	*EventMessage_UnableToSchedule
	//	*EventMessage_Failed
	//	*EventMessage_Succeeded
	//	*EventMessage_Reprioritized
	//	*EventMessage_Cancelling
	//	*EventMessage_Cancelled
	//	*EventMessage_Terminated
	//	*EventMessage_Utilisation
	Events isEventMessage_Events `protobuf_oneof:"events"`
}

func Wrap 

func Wrap(event Event) (*EventMessage, error)

func (*EventMessage) Descriptor 

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

func (*EventMessage) GetCancelled 

func (m *EventMessage) GetCancelled() *JobCancelledEvent

func (*EventMessage) GetCancelling 

func (m *EventMessage) GetCancelling() *JobCancellingEvent

func (*EventMessage) GetEvents 

func (m *EventMessage) GetEvents() isEventMessage_Events

func (*EventMessage) GetFailed 

func (m *EventMessage) GetFailed() *JobFailedEvent

func (*EventMessage) GetLeaseExpired 

func (m *EventMessage) GetLeaseExpired() *JobLeaseExpiredEvent

func (*EventMessage) GetLeaseReturned 

func (m *EventMessage) GetLeaseReturned() *JobLeaseReturnedEvent

func (*EventMessage) GetLeased 

func (m *EventMessage) GetLeased() *JobLeasedEvent

func (*EventMessage) GetPending 

func (m *EventMessage) GetPending() *JobPendingEvent

func (*EventMessage) GetQueued 

func (m *EventMessage) GetQueued() *JobQueuedEvent

func (*EventMessage) GetReprioritized 

func (m *EventMessage) GetReprioritized() *JobReprioritizedEvent

func (*EventMessage) GetRunning 

func (m *EventMessage) GetRunning() *JobRunningEvent

func (*EventMessage) GetSubmitted 

func (m *EventMessage) GetSubmitted() *JobSubmittedEvent

func (*EventMessage) GetSucceeded 

func (m *EventMessage) GetSucceeded() *JobSucceededEvent

func (*EventMessage) GetTerminated 

func (m *EventMessage) GetTerminated() *JobTerminatedEvent

func (*EventMessage) GetUnableToSchedule 

func (m *EventMessage) GetUnableToSchedule() *JobUnableToScheduleEvent

func (*EventMessage) GetUtilisation added in v0.1.9 

func (m *EventMessage) GetUtilisation() *JobUtilisationEvent

func (*EventMessage) Marshal 

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

func (*EventMessage) MarshalJSON 

func (message *EventMessage) MarshalJSON() ([]byte, error)

customize oneof serialization

func (*EventMessage) MarshalTo 

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

func (*EventMessage) ProtoMessage 

func (*EventMessage) ProtoMessage()

func (*EventMessage) Reset 

func (m *EventMessage) Reset()

func (*EventMessage) Size 

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

func (*EventMessage) String 

func (this *EventMessage) String() string

func (*EventMessage) Unmarshal 

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

func (*EventMessage) UnmarshalJSON 

func (message *EventMessage) UnmarshalJSON(data []byte) error

func (*EventMessage) XXX_DiscardUnknown 

func (m *EventMessage) XXX_DiscardUnknown()

func (*EventMessage) XXX_Marshal 

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

func (*EventMessage) XXX_Merge 

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

func (*EventMessage) XXX_OneofFuncs 

func (*EventMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*EventMessage) XXX_Size 

func (m *EventMessage) XXX_Size() int

func (*EventMessage) XXX_Unmarshal 

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

type EventMessage_Cancelled 

type EventMessage_Cancelled struct {
	Cancelled *JobCancelledEvent `protobuf:"bytes,13,opt,name=cancelled,proto3,oneof"`
}

func (*EventMessage_Cancelled) MarshalTo 

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

func (*EventMessage_Cancelled) Size 

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

func (*EventMessage_Cancelled) String added in v0.1.9 

func (this *EventMessage_Cancelled) String() string

type EventMessage_Cancelling 

type EventMessage_Cancelling struct {
	Cancelling *JobCancellingEvent `protobuf:"bytes,12,opt,name=cancelling,proto3,oneof"`
}

func (*EventMessage_Cancelling) MarshalTo 

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

func (*EventMessage_Cancelling) Size 

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

func (*EventMessage_Cancelling) String added in v0.1.9 

func (this *EventMessage_Cancelling) String() string

type EventMessage_Failed 

type EventMessage_Failed struct {
	Failed *JobFailedEvent `protobuf:"bytes,9,opt,name=failed,proto3,oneof"`
}

func (*EventMessage_Failed) MarshalTo 

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

func (*EventMessage_Failed) Size 

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

func (*EventMessage_Failed) String added in v0.1.9 

func (this *EventMessage_Failed) String() string

type EventMessage_LeaseExpired 

type EventMessage_LeaseExpired struct {
	LeaseExpired *JobLeaseExpiredEvent `protobuf:"bytes,5,opt,name=leaseExpired,proto3,oneof"`
}

func (*EventMessage_LeaseExpired) MarshalTo 

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

func (*EventMessage_LeaseExpired) Size 

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

func (*EventMessage_LeaseExpired) String added in v0.1.9 

func (this *EventMessage_LeaseExpired) String() string

type EventMessage_LeaseReturned 

type EventMessage_LeaseReturned struct {
	LeaseReturned *JobLeaseReturnedEvent `protobuf:"bytes,4,opt,name=leaseReturned,proto3,oneof"`
}

func (*EventMessage_LeaseReturned) MarshalTo 

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

func (*EventMessage_LeaseReturned) Size 

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

func (*EventMessage_LeaseReturned) String added in v0.1.9 

func (this *EventMessage_LeaseReturned) String() string

type EventMessage_Leased 

type EventMessage_Leased struct {
	Leased *JobLeasedEvent `protobuf:"bytes,3,opt,name=leased,proto3,oneof"`
}

func (*EventMessage_Leased) MarshalTo 

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

func (*EventMessage_Leased) Size 

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

func (*EventMessage_Leased) String added in v0.1.9 

func (this *EventMessage_Leased) String() string

type EventMessage_Pending 

type EventMessage_Pending struct {
	Pending *JobPendingEvent `protobuf:"bytes,6,opt,name=pending,proto3,oneof"`
}

func (*EventMessage_Pending) MarshalTo 

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

func (*EventMessage_Pending) Size 

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

func (*EventMessage_Pending) String added in v0.1.9 

func (this *EventMessage_Pending) String() string

type EventMessage_Queued 

type EventMessage_Queued struct {
	Queued *JobQueuedEvent `protobuf:"bytes,2,opt,name=queued,proto3,oneof"`
}

func (*EventMessage_Queued) MarshalTo 

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

func (*EventMessage_Queued) Size 

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

func (*EventMessage_Queued) String added in v0.1.9 

func (this *EventMessage_Queued) String() string

type EventMessage_Reprioritized 

type EventMessage_Reprioritized struct {
	Reprioritized *JobReprioritizedEvent `protobuf:"bytes,11,opt,name=reprioritized,proto3,oneof"`
}

func (*EventMessage_Reprioritized) MarshalTo 

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

func (*EventMessage_Reprioritized) Size 

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

func (*EventMessage_Reprioritized) String added in v0.1.9 

func (this *EventMessage_Reprioritized) String() string

type EventMessage_Running 

type EventMessage_Running struct {
	Running *JobRunningEvent `protobuf:"bytes,7,opt,name=running,proto3,oneof"`
}

func (*EventMessage_Running) MarshalTo 

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

func (*EventMessage_Running) Size 

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

func (*EventMessage_Running) String added in v0.1.9 

func (this *EventMessage_Running) String() string

type EventMessage_Submitted 

type EventMessage_Submitted struct {
	Submitted *JobSubmittedEvent `protobuf:"bytes,1,opt,name=submitted,proto3,oneof"`
}

func (*EventMessage_Submitted) MarshalTo 

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

func (*EventMessage_Submitted) Size 

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

func (*EventMessage_Submitted) String added in v0.1.9 

func (this *EventMessage_Submitted) String() string

type EventMessage_Succeeded 

type EventMessage_Succeeded struct {
	Succeeded *JobSucceededEvent `protobuf:"bytes,10,opt,name=succeeded,proto3,oneof"`
}

func (*EventMessage_Succeeded) MarshalTo 

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

func (*EventMessage_Succeeded) Size 

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

func (*EventMessage_Succeeded) String added in v0.1.9 

func (this *EventMessage_Succeeded) String() string

type EventMessage_Terminated 

type EventMessage_Terminated struct {
	Terminated *JobTerminatedEvent `protobuf:"bytes,14,opt,name=terminated,proto3,oneof"`
}

func (*EventMessage_Terminated) MarshalTo 

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

func (*EventMessage_Terminated) Size 

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

func (*EventMessage_Terminated) String added in v0.1.9 

func (this *EventMessage_Terminated) String() string

type EventMessage_UnableToSchedule 

type EventMessage_UnableToSchedule struct {
	UnableToSchedule *JobUnableToScheduleEvent `protobuf:"bytes,8,opt,name=unableToSchedule,proto3,oneof"`
}

func (*EventMessage_UnableToSchedule) MarshalTo 

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

func (*EventMessage_UnableToSchedule) Size 

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

func (*EventMessage_UnableToSchedule) String added in v0.1.9 

func (this *EventMessage_UnableToSchedule) String() string

type EventMessage_Utilisation added in v0.1.9 

type EventMessage_Utilisation struct {
	Utilisation *JobUtilisationEvent `protobuf:"bytes,15,opt,name=utilisation,proto3,oneof"`
}

func (*EventMessage_Utilisation) MarshalTo added in v0.1.9 

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

func (*EventMessage_Utilisation) Size added in v0.1.9 

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

func (*EventMessage_Utilisation) String added in v0.1.9 

func (this *EventMessage_Utilisation) String() string

type EventServer 

type EventServer interface {
	ReportMultiple(context.Context, *EventList) (*types.Empty, error)
	Report(context.Context, *EventMessage) (*types.Empty, error)
	GetJobSetEvents(*JobSetRequest, Event_GetJobSetEventsServer) error
}

EventServer is the server API for Event service.

type EventStreamMessage 

type EventStreamMessage struct {
	Id      string        `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Message *EventMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

swagger:model

func (*EventStreamMessage) Descriptor 

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

func (*EventStreamMessage) GetId 

func (m *EventStreamMessage) GetId() string

func (*EventStreamMessage) GetMessage 

func (m *EventStreamMessage) GetMessage() *EventMessage

func (*EventStreamMessage) Marshal 

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

func (*EventStreamMessage) MarshalTo 

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

func (*EventStreamMessage) ProtoMessage 

func (*EventStreamMessage) ProtoMessage()

func (*EventStreamMessage) Reset 

func (m *EventStreamMessage) Reset()

func (*EventStreamMessage) Size 

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

func (*EventStreamMessage) String 

func (this *EventStreamMessage) String() string

func (*EventStreamMessage) Unmarshal 

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

func (*EventStreamMessage) XXX_DiscardUnknown 

func (m *EventStreamMessage) XXX_DiscardUnknown()

func (*EventStreamMessage) XXX_Marshal 

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

func (*EventStreamMessage) XXX_Merge 

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

func (*EventStreamMessage) XXX_Size 

func (m *EventStreamMessage) XXX_Size() int

func (*EventStreamMessage) XXX_Unmarshal 

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

type Event_GetJobSetEventsClient 

type Event_GetJobSetEventsClient interface {
	Recv() (*EventStreamMessage, error)
	grpc.ClientStream
}

type Event_GetJobSetEventsServer 

type Event_GetJobSetEventsServer interface {
	Send(*EventStreamMessage) error
	grpc.ServerStream
}

type IdList 

type IdList struct {
	Ids []string `protobuf:"bytes,1,rep,name=Ids,proto3" json:"Ids,omitempty"`
}

func (*IdList) Descriptor 

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

func (*IdList) GetIds 

func (m *IdList) GetIds() []string

func (*IdList) Marshal 

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

func (*IdList) MarshalTo 

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

func (*IdList) ProtoMessage 

func (*IdList) ProtoMessage()

func (*IdList) Reset 

func (m *IdList) Reset()

func (*IdList) Size 

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

func (*IdList) String 

func (this *IdList) String() string

func (*IdList) Unmarshal 

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

func (*IdList) XXX_DiscardUnknown 

func (m *IdList) XXX_DiscardUnknown()

func (*IdList) XXX_Marshal 

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

func (*IdList) XXX_Merge 

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

func (*IdList) XXX_Size 

func (m *IdList) XXX_Size() int

func (*IdList) XXX_Unmarshal 

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

type Job 

type Job struct {
	Id                 string            `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	JobSetId           string            `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue              string            `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Namespace          string            `protobuf:"bytes,7,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Labels             map[string]string `` /* 153-byte string literal not displayed */
	Annotations        map[string]string `` /* 164-byte string literal not displayed */
	RequiredNodeLabels map[string]string `` // Deprecated: Do not use.
	/* 178-byte string literal not displayed */
	Owner    string      `protobuf:"bytes,8,opt,name=Owner,proto3" json:"Owner,omitempty"`
	Priority float64     `protobuf:"fixed64,4,opt,name=Priority,proto3" json:"Priority,omitempty"`
	PodSpec  *v1.PodSpec `protobuf:"bytes,5,opt,name=PodSpec,proto3" json:"PodSpec,omitempty"`
	Created  time.Time   `protobuf:"bytes,6,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*Job) Descriptor 

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

func (*Job) GetAnnotations 

func (m *Job) GetAnnotations() map[string]string

func (*Job) GetCreated 

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

func (*Job) GetId 

func (m *Job) GetId() string

func (*Job) GetJobSetId 

func (m *Job) GetJobSetId() string

func (*Job) GetLabels 

func (m *Job) GetLabels() map[string]string

func (*Job) GetNamespace 

func (m *Job) GetNamespace() string

func (*Job) GetOwner 

func (m *Job) GetOwner() string

func (*Job) GetPodSpec 

func (m *Job) GetPodSpec() *v1.PodSpec

func (*Job) GetPriority 

func (m *Job) GetPriority() float64

func (*Job) GetQueue 

func (m *Job) GetQueue() string

func (*Job) GetRequiredNodeLabels deprecated 

func (m *Job) GetRequiredNodeLabels() map[string]string

Deprecated: Do not use.

func (*Job) Marshal 

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

func (*Job) MarshalTo 

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

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

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

func (*Job) String 

func (this *Job) String() string

func (*Job) Unmarshal 

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

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

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

func (*Job) XXX_Merge 

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

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

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

type JobCancelRequest 

type JobCancelRequest struct {
	JobId    string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
}

swagger:model

func (*JobCancelRequest) Descriptor 

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

func (*JobCancelRequest) GetJobId 

func (m *JobCancelRequest) GetJobId() string

func (*JobCancelRequest) GetJobSetId 

func (m *JobCancelRequest) GetJobSetId() string

func (*JobCancelRequest) GetQueue 

func (m *JobCancelRequest) GetQueue() string

func (*JobCancelRequest) Marshal 

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

func (*JobCancelRequest) MarshalTo 

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

func (*JobCancelRequest) ProtoMessage 

func (*JobCancelRequest) ProtoMessage()

func (*JobCancelRequest) Reset 

func (m *JobCancelRequest) Reset()

func (*JobCancelRequest) Size 

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

func (*JobCancelRequest) String 

func (this *JobCancelRequest) String() string

func (*JobCancelRequest) Unmarshal 

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

func (*JobCancelRequest) XXX_DiscardUnknown 

func (m *JobCancelRequest) XXX_DiscardUnknown()

func (*JobCancelRequest) XXX_Marshal 

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

func (*JobCancelRequest) XXX_Merge 

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

func (*JobCancelRequest) XXX_Size 

func (m *JobCancelRequest) XXX_Size() int

func (*JobCancelRequest) XXX_Unmarshal 

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

type JobCancelledEvent 

type JobCancelledEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*JobCancelledEvent) Descriptor 

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

func (*JobCancelledEvent) GetCreated 

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

func (*JobCancelledEvent) GetJobId 

func (m *JobCancelledEvent) GetJobId() string

func (*JobCancelledEvent) GetJobSetId 

func (m *JobCancelledEvent) GetJobSetId() string

func (*JobCancelledEvent) GetQueue 

func (m *JobCancelledEvent) GetQueue() string

func (*JobCancelledEvent) Marshal 

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

func (*JobCancelledEvent) MarshalTo 

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

func (*JobCancelledEvent) ProtoMessage 

func (*JobCancelledEvent) ProtoMessage()

func (*JobCancelledEvent) Reset 

func (m *JobCancelledEvent) Reset()

func (*JobCancelledEvent) Size 

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

func (*JobCancelledEvent) String 

func (this *JobCancelledEvent) String() string

func (*JobCancelledEvent) Unmarshal 

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

func (*JobCancelledEvent) XXX_DiscardUnknown 

func (m *JobCancelledEvent) XXX_DiscardUnknown()

func (*JobCancelledEvent) XXX_Marshal 

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

func (*JobCancelledEvent) XXX_Merge 

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

func (*JobCancelledEvent) XXX_Size 

func (m *JobCancelledEvent) XXX_Size() int

func (*JobCancelledEvent) XXX_Unmarshal 

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

type JobCancellingEvent 

type JobCancellingEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*JobCancellingEvent) Descriptor 

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

func (*JobCancellingEvent) GetCreated 

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

func (*JobCancellingEvent) GetJobId 

func (m *JobCancellingEvent) GetJobId() string

func (*JobCancellingEvent) GetJobSetId 

func (m *JobCancellingEvent) GetJobSetId() string

func (*JobCancellingEvent) GetQueue 

func (m *JobCancellingEvent) GetQueue() string

func (*JobCancellingEvent) Marshal 

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

func (*JobCancellingEvent) MarshalTo 

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

func (*JobCancellingEvent) ProtoMessage 

func (*JobCancellingEvent) ProtoMessage()

func (*JobCancellingEvent) Reset 

func (m *JobCancellingEvent) Reset()

func (*JobCancellingEvent) Size 

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

func (*JobCancellingEvent) String 

func (this *JobCancellingEvent) String() string

func (*JobCancellingEvent) Unmarshal 

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

func (*JobCancellingEvent) XXX_DiscardUnknown 

func (m *JobCancellingEvent) XXX_DiscardUnknown()

func (*JobCancellingEvent) XXX_Marshal 

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

func (*JobCancellingEvent) XXX_Merge 

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

func (*JobCancellingEvent) XXX_Size 

func (m *JobCancellingEvent) XXX_Size() int

func (*JobCancellingEvent) XXX_Unmarshal 

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

type JobFailedEvent 

type JobFailedEvent struct {
	JobId        string           `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId     string           `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue        string           `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created      time.Time        `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId    string           `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	Reason       string           `protobuf:"bytes,6,opt,name=Reason,proto3" json:"Reason,omitempty"`
	ExitCodes    map[string]int32 `` /* 160-byte string literal not displayed */
	KubernetesId string           `protobuf:"bytes,8,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
	NodeName     string           `protobuf:"bytes,9,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
}

func (*JobFailedEvent) Descriptor 

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

func (*JobFailedEvent) GetClusterId 

func (m *JobFailedEvent) GetClusterId() string

func (*JobFailedEvent) GetCreated 

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

func (*JobFailedEvent) GetExitCodes 

func (m *JobFailedEvent) GetExitCodes() map[string]int32

func (*JobFailedEvent) GetJobId 

func (m *JobFailedEvent) GetJobId() string

func (*JobFailedEvent) GetJobSetId 

func (m *JobFailedEvent) GetJobSetId() string

func (*JobFailedEvent) GetKubernetesId added in v0.1.6 

func (m *JobFailedEvent) GetKubernetesId() string

func (*JobFailedEvent) GetNodeName added in v0.1.12 

func (m *JobFailedEvent) GetNodeName() string

func (*JobFailedEvent) GetQueue 

func (m *JobFailedEvent) GetQueue() string

func (*JobFailedEvent) GetReason 

func (m *JobFailedEvent) GetReason() string

func (*JobFailedEvent) Marshal 

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

func (*JobFailedEvent) MarshalTo 

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

func (*JobFailedEvent) ProtoMessage 

func (*JobFailedEvent) ProtoMessage()

func (*JobFailedEvent) Reset 

func (m *JobFailedEvent) Reset()

func (*JobFailedEvent) Size 

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

func (*JobFailedEvent) String 

func (this *JobFailedEvent) String() string

func (*JobFailedEvent) Unmarshal 

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

func (*JobFailedEvent) XXX_DiscardUnknown 

func (m *JobFailedEvent) XXX_DiscardUnknown()

func (*JobFailedEvent) XXX_Marshal 

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

func (*JobFailedEvent) XXX_Merge 

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

func (*JobFailedEvent) XXX_Size 

func (m *JobFailedEvent) XXX_Size() int

func (*JobFailedEvent) XXX_Unmarshal 

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

type JobLease 

type JobLease struct {
	Job []*Job `protobuf:"bytes,1,rep,name=Job,proto3" json:"Job,omitempty"`
}

func (*JobLease) Descriptor 

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

func (*JobLease) GetJob 

func (m *JobLease) GetJob() []*Job

func (*JobLease) Marshal 

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

func (*JobLease) MarshalTo 

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

func (*JobLease) ProtoMessage 

func (*JobLease) ProtoMessage()

func (*JobLease) Reset 

func (m *JobLease) Reset()

func (*JobLease) Size 

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

func (*JobLease) String 

func (this *JobLease) String() string

func (*JobLease) Unmarshal 

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

func (*JobLease) XXX_DiscardUnknown 

func (m *JobLease) XXX_DiscardUnknown()

func (*JobLease) XXX_Marshal 

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

func (*JobLease) XXX_Merge 

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

func (*JobLease) XXX_Size 

func (m *JobLease) XXX_Size() int

func (*JobLease) XXX_Unmarshal 

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

type JobLeaseExpiredEvent 

type JobLeaseExpiredEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*JobLeaseExpiredEvent) Descriptor 

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

func (*JobLeaseExpiredEvent) GetCreated 

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

func (*JobLeaseExpiredEvent) GetJobId 

func (m *JobLeaseExpiredEvent) GetJobId() string

func (*JobLeaseExpiredEvent) GetJobSetId 

func (m *JobLeaseExpiredEvent) GetJobSetId() string

func (*JobLeaseExpiredEvent) GetQueue 

func (m *JobLeaseExpiredEvent) GetQueue() string

func (*JobLeaseExpiredEvent) Marshal 

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

func (*JobLeaseExpiredEvent) MarshalTo 

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

func (*JobLeaseExpiredEvent) ProtoMessage 

func (*JobLeaseExpiredEvent) ProtoMessage()

func (*JobLeaseExpiredEvent) Reset 

func (m *JobLeaseExpiredEvent) Reset()

func (*JobLeaseExpiredEvent) Size 

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

func (*JobLeaseExpiredEvent) String 

func (this *JobLeaseExpiredEvent) String() string

func (*JobLeaseExpiredEvent) Unmarshal 

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

func (*JobLeaseExpiredEvent) XXX_DiscardUnknown 

func (m *JobLeaseExpiredEvent) XXX_DiscardUnknown()

func (*JobLeaseExpiredEvent) XXX_Marshal 

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

func (*JobLeaseExpiredEvent) XXX_Merge 

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

func (*JobLeaseExpiredEvent) XXX_Size 

func (m *JobLeaseExpiredEvent) XXX_Size() int

func (*JobLeaseExpiredEvent) XXX_Unmarshal 

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

type JobLeaseReturnedEvent 

type JobLeaseReturnedEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	Reason    string    `protobuf:"bytes,6,opt,name=Reason,proto3" json:"Reason,omitempty"`
}

func (*JobLeaseReturnedEvent) Descriptor 

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

func (*JobLeaseReturnedEvent) GetClusterId 

func (m *JobLeaseReturnedEvent) GetClusterId() string

func (*JobLeaseReturnedEvent) GetCreated 

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

func (*JobLeaseReturnedEvent) GetJobId 

func (m *JobLeaseReturnedEvent) GetJobId() string

func (*JobLeaseReturnedEvent) GetJobSetId 

func (m *JobLeaseReturnedEvent) GetJobSetId() string

func (*JobLeaseReturnedEvent) GetQueue 

func (m *JobLeaseReturnedEvent) GetQueue() string

func (*JobLeaseReturnedEvent) GetReason 

func (m *JobLeaseReturnedEvent) GetReason() string

func (*JobLeaseReturnedEvent) Marshal 

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

func (*JobLeaseReturnedEvent) MarshalTo 

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

func (*JobLeaseReturnedEvent) ProtoMessage 

func (*JobLeaseReturnedEvent) ProtoMessage()

func (*JobLeaseReturnedEvent) Reset 

func (m *JobLeaseReturnedEvent) Reset()

func (*JobLeaseReturnedEvent) Size 

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

func (*JobLeaseReturnedEvent) String 

func (this *JobLeaseReturnedEvent) String() string

func (*JobLeaseReturnedEvent) Unmarshal 

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

func (*JobLeaseReturnedEvent) XXX_DiscardUnknown 

func (m *JobLeaseReturnedEvent) XXX_DiscardUnknown()

func (*JobLeaseReturnedEvent) XXX_Marshal 

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

func (*JobLeaseReturnedEvent) XXX_Merge 

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

func (*JobLeaseReturnedEvent) XXX_Size 

func (m *JobLeaseReturnedEvent) XXX_Size() int

func (*JobLeaseReturnedEvent) XXX_Unmarshal 

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

type JobLeasedEvent 

type JobLeasedEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
}

func (*JobLeasedEvent) Descriptor 

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

func (*JobLeasedEvent) GetClusterId 

func (m *JobLeasedEvent) GetClusterId() string

func (*JobLeasedEvent) GetCreated 

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

func (*JobLeasedEvent) GetJobId 

func (m *JobLeasedEvent) GetJobId() string

func (*JobLeasedEvent) GetJobSetId 

func (m *JobLeasedEvent) GetJobSetId() string

func (*JobLeasedEvent) GetQueue 

func (m *JobLeasedEvent) GetQueue() string

func (*JobLeasedEvent) Marshal 

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

func (*JobLeasedEvent) MarshalTo 

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

func (*JobLeasedEvent) ProtoMessage 

func (*JobLeasedEvent) ProtoMessage()

func (*JobLeasedEvent) Reset 

func (m *JobLeasedEvent) Reset()

func (*JobLeasedEvent) Size 

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

func (*JobLeasedEvent) String 

func (this *JobLeasedEvent) String() string

func (*JobLeasedEvent) Unmarshal 

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

func (*JobLeasedEvent) XXX_DiscardUnknown 

func (m *JobLeasedEvent) XXX_DiscardUnknown()

func (*JobLeasedEvent) XXX_Marshal 

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

func (*JobLeasedEvent) XXX_Merge 

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

func (*JobLeasedEvent) XXX_Size 

func (m *JobLeasedEvent) XXX_Size() int

func (*JobLeasedEvent) XXX_Unmarshal 

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

type JobPendingEvent 

type JobPendingEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
}

func (*JobPendingEvent) Descriptor 

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

func (*JobPendingEvent) GetClusterId 

func (m *JobPendingEvent) GetClusterId() string

func (*JobPendingEvent) GetCreated 

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

func (*JobPendingEvent) GetJobId 

func (m *JobPendingEvent) GetJobId() string

func (*JobPendingEvent) GetJobSetId 

func (m *JobPendingEvent) GetJobSetId() string

func (*JobPendingEvent) GetKubernetesId added in v0.1.6 

func (m *JobPendingEvent) GetKubernetesId() string

func (*JobPendingEvent) GetQueue 

func (m *JobPendingEvent) GetQueue() string

func (*JobPendingEvent) Marshal 

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

func (*JobPendingEvent) MarshalTo 

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

func (*JobPendingEvent) ProtoMessage 

func (*JobPendingEvent) ProtoMessage()

func (*JobPendingEvent) Reset 

func (m *JobPendingEvent) Reset()

func (*JobPendingEvent) Size 

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

func (*JobPendingEvent) String 

func (this *JobPendingEvent) String() string

func (*JobPendingEvent) Unmarshal 

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

func (*JobPendingEvent) XXX_DiscardUnknown 

func (m *JobPendingEvent) XXX_DiscardUnknown()

func (*JobPendingEvent) XXX_Marshal 

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

func (*JobPendingEvent) XXX_Merge 

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

func (*JobPendingEvent) XXX_Size 

func (m *JobPendingEvent) XXX_Size() int

func (*JobPendingEvent) XXX_Unmarshal 

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

type JobQueuedEvent 

type JobQueuedEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*JobQueuedEvent) Descriptor 

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

func (*JobQueuedEvent) GetCreated 

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

func (*JobQueuedEvent) GetJobId 

func (m *JobQueuedEvent) GetJobId() string

func (*JobQueuedEvent) GetJobSetId 

func (m *JobQueuedEvent) GetJobSetId() string

func (*JobQueuedEvent) GetQueue 

func (m *JobQueuedEvent) GetQueue() string

func (*JobQueuedEvent) Marshal 

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

func (*JobQueuedEvent) MarshalTo 

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

func (*JobQueuedEvent) ProtoMessage 

func (*JobQueuedEvent) ProtoMessage()

func (*JobQueuedEvent) Reset 

func (m *JobQueuedEvent) Reset()

func (*JobQueuedEvent) Size 

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

func (*JobQueuedEvent) String 

func (this *JobQueuedEvent) String() string

func (*JobQueuedEvent) Unmarshal 

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

func (*JobQueuedEvent) XXX_DiscardUnknown 

func (m *JobQueuedEvent) XXX_DiscardUnknown()

func (*JobQueuedEvent) XXX_Marshal 

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

func (*JobQueuedEvent) XXX_Merge 

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

func (*JobQueuedEvent) XXX_Size 

func (m *JobQueuedEvent) XXX_Size() int

func (*JobQueuedEvent) XXX_Unmarshal 

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

type JobReprioritizedEvent 

type JobReprioritizedEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
}

func (*JobReprioritizedEvent) Descriptor 

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

func (*JobReprioritizedEvent) GetCreated 

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

func (*JobReprioritizedEvent) GetJobId 

func (m *JobReprioritizedEvent) GetJobId() string

func (*JobReprioritizedEvent) GetJobSetId 

func (m *JobReprioritizedEvent) GetJobSetId() string

func (*JobReprioritizedEvent) GetQueue 

func (m *JobReprioritizedEvent) GetQueue() string

func (*JobReprioritizedEvent) Marshal 

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

func (*JobReprioritizedEvent) MarshalTo 

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

func (*JobReprioritizedEvent) ProtoMessage 

func (*JobReprioritizedEvent) ProtoMessage()

func (*JobReprioritizedEvent) Reset 

func (m *JobReprioritizedEvent) Reset()

func (*JobReprioritizedEvent) Size 

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

func (*JobReprioritizedEvent) String 

func (this *JobReprioritizedEvent) String() string

func (*JobReprioritizedEvent) Unmarshal 

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

func (*JobReprioritizedEvent) XXX_DiscardUnknown 

func (m *JobReprioritizedEvent) XXX_DiscardUnknown()

func (*JobReprioritizedEvent) XXX_Marshal 

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

func (*JobReprioritizedEvent) XXX_Merge 

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

func (*JobReprioritizedEvent) XXX_Size 

func (m *JobReprioritizedEvent) XXX_Size() int

func (*JobReprioritizedEvent) XXX_Unmarshal 

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

type JobRunningEvent 

type JobRunningEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,7,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
}

func (*JobRunningEvent) Descriptor 

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

func (*JobRunningEvent) GetClusterId 

func (m *JobRunningEvent) GetClusterId() string

func (*JobRunningEvent) GetCreated 

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

func (*JobRunningEvent) GetJobId 

func (m *JobRunningEvent) GetJobId() string

func (*JobRunningEvent) GetJobSetId 

func (m *JobRunningEvent) GetJobSetId() string

func (*JobRunningEvent) GetKubernetesId added in v0.1.6 

func (m *JobRunningEvent) GetKubernetesId() string

func (*JobRunningEvent) GetNodeName added in v0.1.12 

func (m *JobRunningEvent) GetNodeName() string

func (*JobRunningEvent) GetQueue 

func (m *JobRunningEvent) GetQueue() string

func (*JobRunningEvent) Marshal 

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

func (*JobRunningEvent) MarshalTo 

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

func (*JobRunningEvent) ProtoMessage 

func (*JobRunningEvent) ProtoMessage()

func (*JobRunningEvent) Reset 

func (m *JobRunningEvent) Reset()

func (*JobRunningEvent) Size 

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

func (*JobRunningEvent) String 

func (this *JobRunningEvent) String() string

func (*JobRunningEvent) Unmarshal 

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

func (*JobRunningEvent) XXX_DiscardUnknown 

func (m *JobRunningEvent) XXX_DiscardUnknown()

func (*JobRunningEvent) XXX_Marshal 

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

func (*JobRunningEvent) XXX_Merge 

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

func (*JobRunningEvent) XXX_Size 

func (m *JobRunningEvent) XXX_Size() int

func (*JobRunningEvent) XXX_Unmarshal 

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

type JobSetInfo 

type JobSetInfo struct {
	Name       string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	QueuedJobs int32  `protobuf:"varint,2,opt,name=QueuedJobs,proto3" json:"QueuedJobs,omitempty"`
	LeasedJobs int32  `protobuf:"varint,3,opt,name=LeasedJobs,proto3" json:"LeasedJobs,omitempty"`
}

func (*JobSetInfo) Descriptor 

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

func (*JobSetInfo) GetLeasedJobs 

func (m *JobSetInfo) GetLeasedJobs() int32

func (*JobSetInfo) GetName 

func (m *JobSetInfo) GetName() string

func (*JobSetInfo) GetQueuedJobs 

func (m *JobSetInfo) GetQueuedJobs() int32

func (*JobSetInfo) Marshal 

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

func (*JobSetInfo) MarshalTo 

func (m *JobSetInfo) MarshalTo(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 JobSetRequest 

type JobSetRequest struct {
	Id            string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Watch         bool   `protobuf:"varint,2,opt,name=Watch,proto3" json:"Watch,omitempty"`
	FromMessageId string `protobuf:"bytes,3,opt,name=FromMessageId,proto3" json:"FromMessageId,omitempty"`
	Queue         string `protobuf:"bytes,4,opt,name=Queue,proto3" json:"Queue,omitempty"`
}

swagger:model

func (*JobSetRequest) Descriptor 

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

func (*JobSetRequest) GetFromMessageId 

func (m *JobSetRequest) GetFromMessageId() string

func (*JobSetRequest) GetId 

func (m *JobSetRequest) GetId() string

func (*JobSetRequest) GetQueue 

func (m *JobSetRequest) GetQueue() string

func (*JobSetRequest) GetWatch 

func (m *JobSetRequest) GetWatch() bool

func (*JobSetRequest) Marshal 

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

func (*JobSetRequest) MarshalTo 

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

func (*JobSetRequest) ProtoMessage 

func (*JobSetRequest) ProtoMessage()

func (*JobSetRequest) Reset 

func (m *JobSetRequest) Reset()

func (*JobSetRequest) Size 

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

func (*JobSetRequest) String 

func (this *JobSetRequest) String() string

func (*JobSetRequest) Unmarshal 

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

func (*JobSetRequest) XXX_DiscardUnknown 

func (m *JobSetRequest) XXX_DiscardUnknown()

func (*JobSetRequest) XXX_Marshal 

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

func (*JobSetRequest) XXX_Merge 

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

func (*JobSetRequest) XXX_Size 

func (m *JobSetRequest) XXX_Size() int

func (*JobSetRequest) XXX_Unmarshal 

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

type JobSubmitRequest 

type JobSubmitRequest struct {
	Queue           string                  `protobuf:"bytes,1,opt,name=Queue,proto3" json:"Queue,omitempty"`
	JobSetId        string                  `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	JobRequestItems []*JobSubmitRequestItem `protobuf:"bytes,3,rep,name=JobRequestItems,proto3" json:"JobRequestItems,omitempty"`
}

swagger:model

func (*JobSubmitRequest) Descriptor 

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

func (*JobSubmitRequest) GetJobRequestItems 

func (m *JobSubmitRequest) GetJobRequestItems() []*JobSubmitRequestItem

func (*JobSubmitRequest) GetJobSetId 

func (m *JobSubmitRequest) GetJobSetId() string

func (*JobSubmitRequest) GetQueue 

func (m *JobSubmitRequest) GetQueue() string

func (*JobSubmitRequest) Marshal 

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

func (*JobSubmitRequest) MarshalTo 

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

func (*JobSubmitRequest) ProtoMessage 

func (*JobSubmitRequest) ProtoMessage()

func (*JobSubmitRequest) Reset 

func (m *JobSubmitRequest) Reset()

func (*JobSubmitRequest) Size 

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

func (*JobSubmitRequest) String 

func (this *JobSubmitRequest) String() string

func (*JobSubmitRequest) Unmarshal 

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

func (*JobSubmitRequest) XXX_DiscardUnknown 

func (m *JobSubmitRequest) XXX_DiscardUnknown()

func (*JobSubmitRequest) XXX_Marshal 

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

func (*JobSubmitRequest) XXX_Merge 

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

func (*JobSubmitRequest) XXX_Size 

func (m *JobSubmitRequest) XXX_Size() int

func (*JobSubmitRequest) XXX_Unmarshal 

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

type JobSubmitRequestItem 

type JobSubmitRequestItem struct {
	Priority           float64           `protobuf:"fixed64,1,opt,name=Priority,proto3" json:"Priority,omitempty"`
	Namespace          string            `protobuf:"bytes,3,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Labels             map[string]string `` /* 153-byte string literal not displayed */
	Annotations        map[string]string `` /* 163-byte string literal not displayed */
	RequiredNodeLabels map[string]string `` // Deprecated: Do not use.
	/* 177-byte string literal not displayed */
	PodSpec *v1.PodSpec `protobuf:"bytes,2,opt,name=PodSpec,proto3" json:"PodSpec,omitempty"`
}

func (*JobSubmitRequestItem) Descriptor 

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

func (*JobSubmitRequestItem) GetAnnotations 

func (m *JobSubmitRequestItem) GetAnnotations() map[string]string

func (*JobSubmitRequestItem) GetLabels 

func (m *JobSubmitRequestItem) GetLabels() map[string]string

func (*JobSubmitRequestItem) GetNamespace 

func (m *JobSubmitRequestItem) GetNamespace() string

func (*JobSubmitRequestItem) GetPodSpec 

func (m *JobSubmitRequestItem) GetPodSpec() *v1.PodSpec

func (*JobSubmitRequestItem) GetPriority 

func (m *JobSubmitRequestItem) GetPriority() float64

func (*JobSubmitRequestItem) GetRequiredNodeLabels deprecated 

func (m *JobSubmitRequestItem) GetRequiredNodeLabels() map[string]string

Deprecated: Do not use.

func (*JobSubmitRequestItem) Marshal 

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

func (*JobSubmitRequestItem) MarshalTo 

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

func (*JobSubmitRequestItem) ProtoMessage 

func (*JobSubmitRequestItem) ProtoMessage()

func (*JobSubmitRequestItem) Reset 

func (m *JobSubmitRequestItem) Reset()

func (*JobSubmitRequestItem) Size 

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

func (*JobSubmitRequestItem) String 

func (this *JobSubmitRequestItem) String() string

func (*JobSubmitRequestItem) Unmarshal 

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

func (*JobSubmitRequestItem) XXX_DiscardUnknown 

func (m *JobSubmitRequestItem) XXX_DiscardUnknown()

func (*JobSubmitRequestItem) XXX_Marshal 

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

func (*JobSubmitRequestItem) XXX_Merge 

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

func (*JobSubmitRequestItem) XXX_Size 

func (m *JobSubmitRequestItem) XXX_Size() int

func (*JobSubmitRequestItem) XXX_Unmarshal 

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

type JobSubmitResponse 

type JobSubmitResponse struct {
	JobResponseItems []*JobSubmitResponseItem `protobuf:"bytes,1,rep,name=JobResponseItems,proto3" json:"JobResponseItems,omitempty"`
}

swagger:model

func (*JobSubmitResponse) Descriptor 

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

func (*JobSubmitResponse) GetJobResponseItems 

func (m *JobSubmitResponse) GetJobResponseItems() []*JobSubmitResponseItem

func (*JobSubmitResponse) Marshal 

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

func (*JobSubmitResponse) MarshalTo 

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

func (*JobSubmitResponse) ProtoMessage 

func (*JobSubmitResponse) ProtoMessage()

func (*JobSubmitResponse) Reset 

func (m *JobSubmitResponse) Reset()

func (*JobSubmitResponse) Size 

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

func (*JobSubmitResponse) String 

func (this *JobSubmitResponse) String() string

func (*JobSubmitResponse) Unmarshal 

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

func (*JobSubmitResponse) XXX_DiscardUnknown 

func (m *JobSubmitResponse) XXX_DiscardUnknown()

func (*JobSubmitResponse) XXX_Marshal 

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

func (*JobSubmitResponse) XXX_Merge 

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

func (*JobSubmitResponse) XXX_Size 

func (m *JobSubmitResponse) XXX_Size() int

func (*JobSubmitResponse) XXX_Unmarshal 

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

type JobSubmitResponseItem 

type JobSubmitResponseItem struct {
	JobId string `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
}

func (*JobSubmitResponseItem) Descriptor 

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

func (*JobSubmitResponseItem) GetError 

func (m *JobSubmitResponseItem) GetError() string

func (*JobSubmitResponseItem) GetJobId 

func (m *JobSubmitResponseItem) GetJobId() string

func (*JobSubmitResponseItem) Marshal 

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

func (*JobSubmitResponseItem) MarshalTo 

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

func (*JobSubmitResponseItem) ProtoMessage 

func (*JobSubmitResponseItem) ProtoMessage()

func (*JobSubmitResponseItem) Reset 

func (m *JobSubmitResponseItem) Reset()

func (*JobSubmitResponseItem) Size 

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

func (*JobSubmitResponseItem) String 

func (this *JobSubmitResponseItem) String() string

func (*JobSubmitResponseItem) Unmarshal 

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

func (*JobSubmitResponseItem) XXX_DiscardUnknown 

func (m *JobSubmitResponseItem) XXX_DiscardUnknown()

func (*JobSubmitResponseItem) XXX_Marshal 

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

func (*JobSubmitResponseItem) XXX_Merge 

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

func (*JobSubmitResponseItem) XXX_Size 

func (m *JobSubmitResponseItem) XXX_Size() int

func (*JobSubmitResponseItem) XXX_Unmarshal 

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

type JobSubmittedEvent 

type JobSubmittedEvent struct {
	JobId    string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue    string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created  time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	Job      Job       `protobuf:"bytes,5,opt,name=Job,proto3" json:"Job"`
}

func (*JobSubmittedEvent) Descriptor 

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

func (*JobSubmittedEvent) GetCreated 

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

func (*JobSubmittedEvent) GetJob 

func (m *JobSubmittedEvent) GetJob() Job

func (*JobSubmittedEvent) GetJobId 

func (m *JobSubmittedEvent) GetJobId() string

func (*JobSubmittedEvent) GetJobSetId 

func (m *JobSubmittedEvent) GetJobSetId() string

func (*JobSubmittedEvent) GetQueue 

func (m *JobSubmittedEvent) GetQueue() string

func (*JobSubmittedEvent) Marshal 

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

func (*JobSubmittedEvent) MarshalTo 

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

func (*JobSubmittedEvent) ProtoMessage 

func (*JobSubmittedEvent) ProtoMessage()

func (*JobSubmittedEvent) Reset 

func (m *JobSubmittedEvent) Reset()

func (*JobSubmittedEvent) Size 

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

func (*JobSubmittedEvent) String 

func (this *JobSubmittedEvent) String() string

func (*JobSubmittedEvent) Unmarshal 

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

func (*JobSubmittedEvent) XXX_DiscardUnknown 

func (m *JobSubmittedEvent) XXX_DiscardUnknown()

func (*JobSubmittedEvent) XXX_Marshal 

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

func (*JobSubmittedEvent) XXX_Merge 

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

func (*JobSubmittedEvent) XXX_Size 

func (m *JobSubmittedEvent) XXX_Size() int

func (*JobSubmittedEvent) XXX_Unmarshal 

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

type JobSucceededEvent 

type JobSucceededEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	KubernetesId string    `protobuf:"bytes,6,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,7,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
}

func (*JobSucceededEvent) Descriptor 

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

func (*JobSucceededEvent) GetClusterId 

func (m *JobSucceededEvent) GetClusterId() string

func (*JobSucceededEvent) GetCreated 

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

func (*JobSucceededEvent) GetJobId 

func (m *JobSucceededEvent) GetJobId() string

func (*JobSucceededEvent) GetJobSetId 

func (m *JobSucceededEvent) GetJobSetId() string

func (*JobSucceededEvent) GetKubernetesId added in v0.1.6 

func (m *JobSucceededEvent) GetKubernetesId() string

func (*JobSucceededEvent) GetNodeName added in v0.1.12 

func (m *JobSucceededEvent) GetNodeName() string

func (*JobSucceededEvent) GetQueue 

func (m *JobSucceededEvent) GetQueue() string

func (*JobSucceededEvent) Marshal 

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

func (*JobSucceededEvent) MarshalTo 

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

func (*JobSucceededEvent) ProtoMessage 

func (*JobSucceededEvent) ProtoMessage()

func (*JobSucceededEvent) Reset 

func (m *JobSucceededEvent) Reset()

func (*JobSucceededEvent) Size 

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

func (*JobSucceededEvent) String 

func (this *JobSucceededEvent) String() string

func (*JobSucceededEvent) Unmarshal 

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

func (*JobSucceededEvent) XXX_DiscardUnknown 

func (m *JobSucceededEvent) XXX_DiscardUnknown()

func (*JobSucceededEvent) XXX_Marshal 

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

func (*JobSucceededEvent) XXX_Merge 

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

func (*JobSucceededEvent) XXX_Size 

func (m *JobSucceededEvent) XXX_Size() int

func (*JobSucceededEvent) XXX_Unmarshal 

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

type JobTerminatedEvent 

type JobTerminatedEvent struct {
	JobId     string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId  string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue     string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created   time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
}

func (*JobTerminatedEvent) Descriptor 

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

func (*JobTerminatedEvent) GetClusterId 

func (m *JobTerminatedEvent) GetClusterId() string

func (*JobTerminatedEvent) GetCreated 

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

func (*JobTerminatedEvent) GetJobId 

func (m *JobTerminatedEvent) GetJobId() string

func (*JobTerminatedEvent) GetJobSetId 

func (m *JobTerminatedEvent) GetJobSetId() string

func (*JobTerminatedEvent) GetQueue 

func (m *JobTerminatedEvent) GetQueue() string

func (*JobTerminatedEvent) Marshal 

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

func (*JobTerminatedEvent) MarshalTo 

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

func (*JobTerminatedEvent) ProtoMessage 

func (*JobTerminatedEvent) ProtoMessage()

func (*JobTerminatedEvent) Reset 

func (m *JobTerminatedEvent) Reset()

func (*JobTerminatedEvent) Size 

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

func (*JobTerminatedEvent) String 

func (this *JobTerminatedEvent) String() string

func (*JobTerminatedEvent) Unmarshal 

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

func (*JobTerminatedEvent) XXX_DiscardUnknown 

func (m *JobTerminatedEvent) XXX_DiscardUnknown()

func (*JobTerminatedEvent) XXX_Marshal 

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

func (*JobTerminatedEvent) XXX_Merge 

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

func (*JobTerminatedEvent) XXX_Size 

func (m *JobTerminatedEvent) XXX_Size() int

func (*JobTerminatedEvent) XXX_Unmarshal 

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

type JobUnableToScheduleEvent 

type JobUnableToScheduleEvent struct {
	JobId        string    `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId     string    `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue        string    `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created      time.Time `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId    string    `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	Reason       string    `protobuf:"bytes,6,opt,name=Reason,proto3" json:"Reason,omitempty"`
	KubernetesId string    `protobuf:"bytes,7,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
	NodeName     string    `protobuf:"bytes,8,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
}

func (*JobUnableToScheduleEvent) Descriptor 

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

func (*JobUnableToScheduleEvent) GetClusterId 

func (m *JobUnableToScheduleEvent) GetClusterId() string

func (*JobUnableToScheduleEvent) GetCreated 

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

func (*JobUnableToScheduleEvent) GetJobId 

func (m *JobUnableToScheduleEvent) GetJobId() string

func (*JobUnableToScheduleEvent) GetJobSetId 

func (m *JobUnableToScheduleEvent) GetJobSetId() string

func (*JobUnableToScheduleEvent) GetKubernetesId added in v0.1.6 

func (m *JobUnableToScheduleEvent) GetKubernetesId() string

func (*JobUnableToScheduleEvent) GetNodeName added in v0.1.12 

func (m *JobUnableToScheduleEvent) GetNodeName() string

func (*JobUnableToScheduleEvent) GetQueue 

func (m *JobUnableToScheduleEvent) GetQueue() string

func (*JobUnableToScheduleEvent) GetReason 

func (m *JobUnableToScheduleEvent) GetReason() string

func (*JobUnableToScheduleEvent) Marshal 

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

func (*JobUnableToScheduleEvent) MarshalTo 

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

func (*JobUnableToScheduleEvent) ProtoMessage 

func (*JobUnableToScheduleEvent) ProtoMessage()

func (*JobUnableToScheduleEvent) Reset 

func (m *JobUnableToScheduleEvent) Reset()

func (*JobUnableToScheduleEvent) Size 

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

func (*JobUnableToScheduleEvent) String 

func (this *JobUnableToScheduleEvent) String() string

func (*JobUnableToScheduleEvent) Unmarshal 

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

func (*JobUnableToScheduleEvent) XXX_DiscardUnknown 

func (m *JobUnableToScheduleEvent) XXX_DiscardUnknown()

func (*JobUnableToScheduleEvent) XXX_Marshal 

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

func (*JobUnableToScheduleEvent) XXX_Merge 

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

func (*JobUnableToScheduleEvent) XXX_Size 

func (m *JobUnableToScheduleEvent) XXX_Size() int

func (*JobUnableToScheduleEvent) XXX_Unmarshal 

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

type JobUtilisationEvent added in v0.1.9 

type JobUtilisationEvent struct {
	JobId                 string                       `protobuf:"bytes,1,opt,name=JobId,proto3" json:"JobId,omitempty"`
	JobSetId              string                       `protobuf:"bytes,2,opt,name=JobSetId,proto3" json:"JobSetId,omitempty"`
	Queue                 string                       `protobuf:"bytes,3,opt,name=Queue,proto3" json:"Queue,omitempty"`
	Created               time.Time                    `protobuf:"bytes,4,opt,name=Created,proto3,stdtime" json:"Created"`
	ClusterId             string                       `protobuf:"bytes,5,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	KubernetesId          string                       `protobuf:"bytes,6,opt,name=KubernetesId,proto3" json:"KubernetesId,omitempty"`
	MaxResourcesForPeriod map[string]resource.Quantity `` /* 173-byte string literal not displayed */
	NodeName              string                       `protobuf:"bytes,8,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
}

func (*JobUtilisationEvent) Descriptor added in v0.1.9 

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

func (*JobUtilisationEvent) GetClusterId added in v0.1.9 

func (m *JobUtilisationEvent) GetClusterId() string

func (*JobUtilisationEvent) GetCreated added in v0.1.9 

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

func (*JobUtilisationEvent) GetJobId added in v0.1.9 

func (m *JobUtilisationEvent) GetJobId() string

func (*JobUtilisationEvent) GetJobSetId added in v0.1.9 

func (m *JobUtilisationEvent) GetJobSetId() string

func (*JobUtilisationEvent) GetKubernetesId added in v0.1.9 

func (m *JobUtilisationEvent) GetKubernetesId() string

func (*JobUtilisationEvent) GetMaxResourcesForPeriod added in v0.1.9 

func (m *JobUtilisationEvent) GetMaxResourcesForPeriod() map[string]resource.Quantity

func (*JobUtilisationEvent) GetNodeName added in v0.1.12 

func (m *JobUtilisationEvent) GetNodeName() string

func (*JobUtilisationEvent) GetQueue added in v0.1.9 

func (m *JobUtilisationEvent) GetQueue() string

func (*JobUtilisationEvent) Marshal added in v0.1.9 

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

func (*JobUtilisationEvent) MarshalTo added in v0.1.9 

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

func (*JobUtilisationEvent) ProtoMessage added in v0.1.9 

func (*JobUtilisationEvent) ProtoMessage()

func (*JobUtilisationEvent) Reset added in v0.1.9 

func (m *JobUtilisationEvent) Reset()

func (*JobUtilisationEvent) Size added in v0.1.9 

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

func (*JobUtilisationEvent) String added in v0.1.9 

func (this *JobUtilisationEvent) String() string

func (*JobUtilisationEvent) Unmarshal added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_DiscardUnknown added in v0.1.9 

func (m *JobUtilisationEvent) XXX_DiscardUnknown()

func (*JobUtilisationEvent) XXX_Marshal added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_Merge added in v0.1.9 

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

func (*JobUtilisationEvent) XXX_Size added in v0.1.9 

func (m *JobUtilisationEvent) XXX_Size() int

func (*JobUtilisationEvent) XXX_Unmarshal added in v0.1.9 

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

type LeaseRequest 

type LeaseRequest struct {
	ClusterId           string                       `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	Resources           map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	ClusterLeasedReport ClusterLeasedReport          `protobuf:"bytes,4,opt,name=ClusterLeasedReport,proto3" json:"ClusterLeasedReport"`
	MinimumJobSize      map[string]resource.Quantity `` /* 159-byte string literal not displayed */
	Nodes               []NodeInfo                   `protobuf:"bytes,7,rep,name=Nodes,proto3" json:"Nodes"`
}

func (*LeaseRequest) Descriptor 

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

func (*LeaseRequest) GetClusterId 

func (m *LeaseRequest) GetClusterId() string

func (*LeaseRequest) GetClusterLeasedReport added in v0.1.6 

func (m *LeaseRequest) GetClusterLeasedReport() ClusterLeasedReport

func (*LeaseRequest) GetMinimumJobSize added in v0.1.6 

func (m *LeaseRequest) GetMinimumJobSize() map[string]resource.Quantity

func (*LeaseRequest) GetNodes added in v0.1.14 

func (m *LeaseRequest) GetNodes() []NodeInfo

func (*LeaseRequest) GetResources 

func (m *LeaseRequest) GetResources() map[string]resource.Quantity

func (*LeaseRequest) Marshal 

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

func (*LeaseRequest) MarshalTo 

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

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) Reset 

func (m *LeaseRequest) Reset()

func (*LeaseRequest) Size 

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

func (*LeaseRequest) String 

func (this *LeaseRequest) String() string

func (*LeaseRequest) Unmarshal 

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

func (*LeaseRequest) XXX_DiscardUnknown 

func (m *LeaseRequest) XXX_DiscardUnknown()

func (*LeaseRequest) XXX_Marshal 

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

func (*LeaseRequest) XXX_Merge 

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

func (*LeaseRequest) XXX_Size 

func (m *LeaseRequest) XXX_Size() int

func (*LeaseRequest) XXX_Unmarshal 

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

type NodeInfo added in v0.1.14 

type NodeInfo struct {
	Name                 string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Taints               []v1.Taint                   `protobuf:"bytes,2,rep,name=Taints,proto3" json:"Taints"`
	Labels               map[string]string            `` /* 153-byte string literal not displayed */
	AllocatableResources map[string]resource.Quantity `` /* 171-byte string literal not displayed */
	AvailableResources   map[string]resource.Quantity `` /* 167-byte string literal not displayed */
}

func (*NodeInfo) Descriptor added in v0.1.14 

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

func (*NodeInfo) GetAllocatableResources added in v0.1.14 

func (m *NodeInfo) GetAllocatableResources() map[string]resource.Quantity

func (*NodeInfo) GetAvailableResources added in v0.1.14 

func (m *NodeInfo) GetAvailableResources() map[string]resource.Quantity

func (*NodeInfo) GetLabels added in v0.1.14 

func (m *NodeInfo) GetLabels() map[string]string

func (*NodeInfo) GetName added in v0.1.14 

func (m *NodeInfo) GetName() string

func (*NodeInfo) GetTaints added in v0.1.14 

func (m *NodeInfo) GetTaints() []v1.Taint

func (*NodeInfo) Marshal added in v0.1.14 

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

func (*NodeInfo) MarshalTo added in v0.1.14 

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

func (*NodeInfo) ProtoMessage added in v0.1.14 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset added in v0.1.14 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size added in v0.1.14 

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

func (*NodeInfo) String added in v0.1.14 

func (this *NodeInfo) String() string

func (*NodeInfo) Unmarshal added in v0.1.14 

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

func (*NodeInfo) XXX_DiscardUnknown added in v0.1.14 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v0.1.14 

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

func (*NodeInfo) XXX_Merge added in v0.1.14 

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

func (*NodeInfo) XXX_Size added in v0.1.14 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v0.1.14 

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

type NodeLabeling 

type NodeLabeling struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
}

func (*NodeLabeling) Descriptor 

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

func (*NodeLabeling) GetLabels 

func (m *NodeLabeling) GetLabels() map[string]string

func (*NodeLabeling) Marshal 

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

func (*NodeLabeling) MarshalTo 

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

func (*NodeLabeling) ProtoMessage 

func (*NodeLabeling) ProtoMessage()

func (*NodeLabeling) Reset 

func (m *NodeLabeling) Reset()

func (*NodeLabeling) Size 

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

func (*NodeLabeling) String 

func (this *NodeLabeling) String() string

func (*NodeLabeling) Unmarshal 

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

func (*NodeLabeling) XXX_DiscardUnknown 

func (m *NodeLabeling) XXX_DiscardUnknown()

func (*NodeLabeling) XXX_Marshal 

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

func (*NodeLabeling) XXX_Merge 

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

func (*NodeLabeling) XXX_Size 

func (m *NodeLabeling) XXX_Size() int

func (*NodeLabeling) XXX_Unmarshal 

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

type NodeType added in v0.1.14 

type NodeType struct {
	Taints               []v1.Taint                   `protobuf:"bytes,1,rep,name=Taints,proto3" json:"Taints"`
	Labels               map[string]string            `` /* 153-byte string literal not displayed */
	AllocatableResources map[string]resource.Quantity `` /* 171-byte string literal not displayed */
}

func (*NodeType) Descriptor added in v0.1.14 

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

func (*NodeType) GetAllocatableResources added in v0.1.14 

func (m *NodeType) GetAllocatableResources() map[string]resource.Quantity

func (*NodeType) GetLabels added in v0.1.14 

func (m *NodeType) GetLabels() map[string]string

func (*NodeType) GetTaints added in v0.1.14 

func (m *NodeType) GetTaints() []v1.Taint

func (*NodeType) Marshal added in v0.1.14 

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

func (*NodeType) MarshalTo added in v0.1.14 

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

func (*NodeType) ProtoMessage added in v0.1.14 

func (*NodeType) ProtoMessage()

func (*NodeType) Reset added in v0.1.14 

func (m *NodeType) Reset()

func (*NodeType) Size added in v0.1.14 

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

func (*NodeType) String added in v0.1.14 

func (this *NodeType) String() string

func (*NodeType) Unmarshal added in v0.1.14 

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

func (*NodeType) XXX_DiscardUnknown added in v0.1.14 

func (m *NodeType) XXX_DiscardUnknown()

func (*NodeType) XXX_Marshal added in v0.1.14 

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

func (*NodeType) XXX_Merge added in v0.1.14 

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

func (*NodeType) XXX_Size added in v0.1.14 

func (m *NodeType) XXX_Size() int

func (*NodeType) XXX_Unmarshal added in v0.1.14 

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

type Queue 

type Queue struct {
	Name           string             `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	PriorityFactor float64            `protobuf:"fixed64,2,opt,name=PriorityFactor,proto3" json:"PriorityFactor,omitempty"`
	UserOwners     []string           `protobuf:"bytes,3,rep,name=UserOwners,proto3" json:"UserOwners,omitempty"`
	GroupOwners    []string           `protobuf:"bytes,4,rep,name=GroupOwners,proto3" json:"GroupOwners,omitempty"`
	ResourceLimits map[string]float64 `` /* 171-byte string literal not displayed */
}

swagger:model

func (*Queue) Descriptor 

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

func (*Queue) GetGroupOwners 

func (m *Queue) GetGroupOwners() []string

func (*Queue) GetName 

func (m *Queue) GetName() string

func (*Queue) GetPriorityFactor 

func (m *Queue) GetPriorityFactor() float64

func (*Queue) GetResourceLimits added in v0.1.6 

func (m *Queue) GetResourceLimits() map[string]float64

func (*Queue) GetUserOwners 

func (m *Queue) GetUserOwners() []string

func (*Queue) Marshal 

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

func (*Queue) MarshalTo 

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

func (*Queue) ProtoMessage 

func (*Queue) ProtoMessage()

func (*Queue) Reset 

func (m *Queue) Reset()

func (*Queue) Size 

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

func (*Queue) String 

func (this *Queue) String() string

func (*Queue) Unmarshal 

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

func (*Queue) XXX_DiscardUnknown 

func (m *Queue) XXX_DiscardUnknown()

func (*Queue) XXX_Marshal 

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

func (*Queue) XXX_Merge 

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

func (*Queue) XXX_Size 

func (m *Queue) XXX_Size() int

func (*Queue) XXX_Unmarshal 

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

type QueueDeleteRequest added in v0.1.14 

type QueueDeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
}

func (*QueueDeleteRequest) Descriptor added in v0.1.14 

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

func (*QueueDeleteRequest) GetName added in v0.1.14 

func (m *QueueDeleteRequest) GetName() string

func (*QueueDeleteRequest) Marshal added in v0.1.14 

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

func (*QueueDeleteRequest) MarshalTo added in v0.1.14 

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

func (*QueueDeleteRequest) ProtoMessage added in v0.1.14 

func (*QueueDeleteRequest) ProtoMessage()

func (*QueueDeleteRequest) Reset added in v0.1.14 

func (m *QueueDeleteRequest) Reset()

func (*QueueDeleteRequest) Size added in v0.1.14 

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

func (*QueueDeleteRequest) String added in v0.1.14 

func (this *QueueDeleteRequest) String() string

func (*QueueDeleteRequest) Unmarshal added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_DiscardUnknown added in v0.1.14 

func (m *QueueDeleteRequest) XXX_DiscardUnknown()

func (*QueueDeleteRequest) XXX_Marshal added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_Merge added in v0.1.14 

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

func (*QueueDeleteRequest) XXX_Size added in v0.1.14 

func (m *QueueDeleteRequest) XXX_Size() int

func (*QueueDeleteRequest) XXX_Unmarshal added in v0.1.14 

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

type QueueInfo 

type QueueInfo struct {
	Name          string        `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ActiveJobSets []*JobSetInfo `protobuf:"bytes,2,rep,name=ActiveJobSets,proto3" json:"ActiveJobSets,omitempty"`
}

func (*QueueInfo) Descriptor 

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

func (*QueueInfo) GetActiveJobSets 

func (m *QueueInfo) GetActiveJobSets() []*JobSetInfo

func (*QueueInfo) GetName 

func (m *QueueInfo) GetName() 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) 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 QueueInfoRequest 

type QueueInfoRequest struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
}

func (*QueueInfoRequest) Descriptor 

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

func (*QueueInfoRequest) GetName 

func (m *QueueInfoRequest) GetName() string

func (*QueueInfoRequest) Marshal 

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

func (*QueueInfoRequest) MarshalTo 

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

func (*QueueInfoRequest) ProtoMessage 

func (*QueueInfoRequest) ProtoMessage()

func (*QueueInfoRequest) Reset 

func (m *QueueInfoRequest) Reset()

func (*QueueInfoRequest) Size 

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

func (*QueueInfoRequest) String 

func (this *QueueInfoRequest) String() string

func (*QueueInfoRequest) Unmarshal 

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

func (*QueueInfoRequest) XXX_DiscardUnknown 

func (m *QueueInfoRequest) XXX_DiscardUnknown()

func (*QueueInfoRequest) XXX_Marshal 

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

func (*QueueInfoRequest) XXX_Merge 

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

func (*QueueInfoRequest) XXX_Size 

func (m *QueueInfoRequest) XXX_Size() int

func (*QueueInfoRequest) XXX_Unmarshal 

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

type QueueLeasedReport added in v0.1.6 

type QueueLeasedReport struct {
	Name            string                       `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	ResourcesLeased map[string]resource.Quantity `` /* 161-byte string literal not displayed */
}

func (*QueueLeasedReport) Descriptor added in v0.1.6 

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

func (*QueueLeasedReport) GetName added in v0.1.6 

func (m *QueueLeasedReport) GetName() string

func (*QueueLeasedReport) GetResourcesLeased added in v0.1.6 

func (m *QueueLeasedReport) GetResourcesLeased() map[string]resource.Quantity

func (*QueueLeasedReport) Marshal added in v0.1.6 

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

func (*QueueLeasedReport) MarshalTo added in v0.1.6 

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

func (*QueueLeasedReport) ProtoMessage added in v0.1.6 

func (*QueueLeasedReport) ProtoMessage()

func (*QueueLeasedReport) Reset added in v0.1.6 

func (m *QueueLeasedReport) Reset()

func (*QueueLeasedReport) Size added in v0.1.6 

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

func (*QueueLeasedReport) String added in v0.1.6 

func (this *QueueLeasedReport) String() string

func (*QueueLeasedReport) Unmarshal added in v0.1.6 

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

func (*QueueLeasedReport) XXX_DiscardUnknown added in v0.1.6 

func (m *QueueLeasedReport) XXX_DiscardUnknown()

func (*QueueLeasedReport) XXX_Marshal added in v0.1.6 

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

func (*QueueLeasedReport) XXX_Merge added in v0.1.6 

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

func (*QueueLeasedReport) XXX_Size added in v0.1.6 

func (m *QueueLeasedReport) XXX_Size() int

func (*QueueLeasedReport) XXX_Unmarshal added in v0.1.6 

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

type QueueReport 

type QueueReport struct {
	Name          string                       `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Resources     map[string]resource.Quantity `` /* 149-byte string literal not displayed */
	ResourcesUsed map[string]resource.Quantity `` /* 157-byte string literal not displayed */
}

func (*QueueReport) Descriptor 

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

func (*QueueReport) GetName 

func (m *QueueReport) GetName() string

func (*QueueReport) GetResources 

func (m *QueueReport) GetResources() map[string]resource.Quantity

func (*QueueReport) GetResourcesUsed 

func (m *QueueReport) GetResourcesUsed() map[string]resource.Quantity

func (*QueueReport) Marshal 

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

func (*QueueReport) MarshalTo 

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

func (*QueueReport) ProtoMessage 

func (*QueueReport) ProtoMessage()

func (*QueueReport) Reset 

func (m *QueueReport) Reset()

func (*QueueReport) Size 

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

func (*QueueReport) String 

func (this *QueueReport) String() string

func (*QueueReport) Unmarshal 

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

func (*QueueReport) XXX_DiscardUnknown 

func (m *QueueReport) XXX_DiscardUnknown()

func (*QueueReport) XXX_Marshal 

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

func (*QueueReport) XXX_Merge 

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

func (*QueueReport) XXX_Size 

func (m *QueueReport) XXX_Size() int

func (*QueueReport) XXX_Unmarshal 

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

type RenewLeaseRequest 

type RenewLeaseRequest struct {
	ClusterId string   `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	Ids       []string `protobuf:"bytes,2,rep,name=Ids,proto3" json:"Ids,omitempty"`
}

func (*RenewLeaseRequest) Descriptor 

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

func (*RenewLeaseRequest) GetClusterId 

func (m *RenewLeaseRequest) GetClusterId() string

func (*RenewLeaseRequest) GetIds 

func (m *RenewLeaseRequest) GetIds() []string

func (*RenewLeaseRequest) Marshal 

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

func (*RenewLeaseRequest) MarshalTo 

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

func (*RenewLeaseRequest) ProtoMessage 

func (*RenewLeaseRequest) ProtoMessage()

func (*RenewLeaseRequest) Reset 

func (m *RenewLeaseRequest) Reset()

func (*RenewLeaseRequest) Size 

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

func (*RenewLeaseRequest) String 

func (this *RenewLeaseRequest) String() string

func (*RenewLeaseRequest) Unmarshal 

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

func (*RenewLeaseRequest) XXX_DiscardUnknown 

func (m *RenewLeaseRequest) XXX_DiscardUnknown()

func (*RenewLeaseRequest) XXX_Marshal 

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

func (*RenewLeaseRequest) XXX_Merge 

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

func (*RenewLeaseRequest) XXX_Size 

func (m *RenewLeaseRequest) XXX_Size() int

func (*RenewLeaseRequest) XXX_Unmarshal 

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

type ReturnLeaseRequest 

type ReturnLeaseRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=ClusterId,proto3" json:"ClusterId,omitempty"`
	JobId     string `protobuf:"bytes,2,opt,name=JobId,proto3" json:"JobId,omitempty"`
}

func (*ReturnLeaseRequest) Descriptor 

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

func (*ReturnLeaseRequest) GetClusterId 

func (m *ReturnLeaseRequest) GetClusterId() string

func (*ReturnLeaseRequest) GetJobId 

func (m *ReturnLeaseRequest) GetJobId() string

func (*ReturnLeaseRequest) Marshal 

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

func (*ReturnLeaseRequest) MarshalTo 

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

func (*ReturnLeaseRequest) ProtoMessage 

func (*ReturnLeaseRequest) ProtoMessage()

func (*ReturnLeaseRequest) Reset 

func (m *ReturnLeaseRequest) Reset()

func (*ReturnLeaseRequest) Size 

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

func (*ReturnLeaseRequest) String 

func (this *ReturnLeaseRequest) String() string

func (*ReturnLeaseRequest) Unmarshal 

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

func (*ReturnLeaseRequest) XXX_DiscardUnknown 

func (m *ReturnLeaseRequest) XXX_DiscardUnknown()

func (*ReturnLeaseRequest) XXX_Marshal 

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

func (*ReturnLeaseRequest) XXX_Merge 

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

func (*ReturnLeaseRequest) XXX_Size 

func (m *ReturnLeaseRequest) XXX_Size() int

func (*ReturnLeaseRequest) XXX_Unmarshal 

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

type SubmitClient 

type SubmitClient interface {
	SubmitJobs(ctx context.Context, in *JobSubmitRequest, opts ...grpc.CallOption) (*JobSubmitResponse, error)
	CancelJobs(ctx context.Context, in *JobCancelRequest, opts ...grpc.CallOption) (*CancellationResult, error)
	CreateQueue(ctx context.Context, in *Queue, opts ...grpc.CallOption) (*types.Empty, error)
	DeleteQueue(ctx context.Context, in *QueueDeleteRequest, opts ...grpc.CallOption) (*types.Empty, error)
	GetQueueInfo(ctx context.Context, in *QueueInfoRequest, opts ...grpc.CallOption) (*QueueInfo, error)
}

SubmitClient is the client API for Submit service.

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

func NewSubmitClient 

func NewSubmitClient(cc *grpc.ClientConn) SubmitClient

type SubmitServer 

type SubmitServer interface {
	SubmitJobs(context.Context, *JobSubmitRequest) (*JobSubmitResponse, error)
	CancelJobs(context.Context, *JobCancelRequest) (*CancellationResult, error)
	CreateQueue(context.Context, *Queue) (*types.Empty, error)
	DeleteQueue(context.Context, *QueueDeleteRequest) (*types.Empty, error)
	GetQueueInfo(context.Context, *QueueInfoRequest) (*QueueInfo, error)
}

SubmitServer is the server API for Submit service.

type UsageClient 

type UsageClient interface {
	ReportUsage(ctx context.Context, in *ClusterUsageReport, opts ...grpc.CallOption) (*types.Empty, error)
}

UsageClient is the client API for Usage service.

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

func NewUsageClient 

func NewUsageClient(cc *grpc.ClientConn) UsageClient

type UsageServer 

type UsageServer interface {
	ReportUsage(context.Context, *ClusterUsageReport) (*types.Empty, error)
}

UsageServer is the server API for Usage 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.