Documentation
¶
Index ¶
- Constants
- func RegisterJobsServer(s *grpc.Server, srv JobsServer)
- type AddRequest
- func (*AddRequest) Descriptor() ([]byte, []int)
- func (m *AddRequest) GetJob() *Job
- func (*AddRequest) ProtoMessage()
- func (m *AddRequest) Reset()
- func (m *AddRequest) String() string
- func (m *AddRequest) XXX_DiscardUnknown()
- func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddRequest) XXX_Merge(src proto.Message)
- func (m *AddRequest) XXX_Size() int
- func (m *AddRequest) XXX_Unmarshal(b []byte) error
- type AddResponse
- func (*AddResponse) Descriptor() ([]byte, []int)
- func (m *AddResponse) GetError() *v1alpha.Error
- func (m *AddResponse) GetJob() *Job
- func (*AddResponse) ProtoMessage()
- func (m *AddResponse) Reset()
- func (m *AddResponse) String() string
- func (m *AddResponse) XXX_DiscardUnknown()
- func (m *AddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddResponse) XXX_Merge(src proto.Message)
- func (m *AddResponse) XXX_Size() int
- func (m *AddResponse) XXX_Unmarshal(b []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetJob() *Job
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) XXX_DiscardUnknown()
- func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRequest) XXX_Size() int
- func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (m *DeleteResponse) GetError() *v1alpha.Error
- func (m *DeleteResponse) GetJob() *Job
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) XXX_DiscardUnknown()
- func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteResponse) XXX_Merge(src proto.Message)
- func (m *DeleteResponse) XXX_Size() int
- func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetGetOptions() *v1alpha.GetOptions
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) String() string
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetError() *v1alpha.Error
- func (m *GetResponse) GetJob() *Job
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) String() string
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetMetadata() *v1alpha.ObjectMetadata
- func (m *Job) GetSpec() *v1alpha.Include
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (m *Job) String() string
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type JobsClient
- type JobsServer
- type JobsService
- func (n *JobsService) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)
- func (n *JobsService) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)
- func (n *JobsService) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (n *JobsService) List(ctx context.Context, req *ListRequest) (*ListResponse, error)
- func (n *JobsService) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)
- func (n *JobsService) Watch(req *WatchRequest, watch Jobs_WatchServer) error
- type Jobs_WatchClient
- type Jobs_WatchServer
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetListOptions() *v1alpha.ListOptions
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)
- func (m *ListResponse) GetError() *v1alpha.Error
- func (m *ListResponse) GetJobs() []*Job
- func (*ListResponse) ProtoMessage()
- func (m *ListResponse) Reset()
- func (m *ListResponse) String() string
- func (m *ListResponse) XXX_DiscardUnknown()
- func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListResponse) XXX_Merge(src proto.Message)
- func (m *ListResponse) XXX_Size() int
- func (m *ListResponse) XXX_Unmarshal(b []byte) error
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) GetJob() *Job
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) String() string
- func (m *UpdateRequest) XXX_DiscardUnknown()
- func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRequest) XXX_Size() int
- func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
- type UpdateResponse
- func (*UpdateResponse) Descriptor() ([]byte, []int)
- func (m *UpdateResponse) GetError() *v1alpha.Error
- func (m *UpdateResponse) GetJob() *Job
- func (*UpdateResponse) ProtoMessage()
- func (m *UpdateResponse) Reset()
- func (m *UpdateResponse) String() string
- func (m *UpdateResponse) XXX_DiscardUnknown()
- func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateResponse) XXX_Merge(src proto.Message)
- func (m *UpdateResponse) XXX_Size() int
- func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)
- func (m *WatchRequest) GetWatchOptions() *v1alpha.WatchOptions
- func (*WatchRequest) ProtoMessage()
- func (m *WatchRequest) Reset()
- func (m *WatchRequest) String() string
- func (m *WatchRequest) XXX_DiscardUnknown()
- func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchRequest) XXX_Merge(src proto.Message)
- func (m *WatchRequest) XXX_Size() int
- func (m *WatchRequest) XXX_Unmarshal(b []byte) error
- type WatchResponse
- func (*WatchResponse) Descriptor() ([]byte, []int)
- func (m *WatchResponse) GetError() *v1alpha.Error
- func (m *WatchResponse) GetEvent() *v1alpha1.Event
- func (m *WatchResponse) GetJob() *Job
- func (*WatchResponse) ProtoMessage()
- func (m *WatchResponse) Reset()
- func (m *WatchResponse) String() string
- func (m *WatchResponse) XXX_DiscardUnknown()
- func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchResponse) XXX_Merge(src proto.Message)
- func (m *WatchResponse) XXX_Size() int
- func (m *WatchResponse) XXX_Unmarshal(b []byte) error
Constants ¶
View Source
const ( // Kind the name of the object kind (singular). Kind = "Job" // KindPlural the name of the object kind (plural). KindPlural = "Jobs" // APIVersion of the API. APIVersion = "v1alpha" // DataStorePath API object path in the data store. DataStorePath = api.APIName + "/" + APIVersion )
Variables ¶
This section is empty.
Functions ¶
func RegisterJobsServer ¶
func RegisterJobsServer(s *grpc.Server, srv JobsServer)
Types ¶
type AddRequest ¶
type AddRequest struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Add
func (*AddRequest) Descriptor ¶
func (*AddRequest) Descriptor() ([]byte, []int)
func (*AddRequest) GetJob ¶
func (m *AddRequest) GetJob() *Job
func (*AddRequest) ProtoMessage ¶
func (*AddRequest) ProtoMessage()
func (*AddRequest) Reset ¶
func (m *AddRequest) Reset()
func (*AddRequest) String ¶
func (m *AddRequest) String() string
func (*AddRequest) XXX_DiscardUnknown ¶
func (m *AddRequest) XXX_DiscardUnknown()
func (*AddRequest) XXX_Marshal ¶
func (m *AddRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddRequest) XXX_Merge ¶
func (m *AddRequest) XXX_Merge(src proto.Message)
func (*AddRequest) XXX_Size ¶
func (m *AddRequest) XXX_Size() int
func (*AddRequest) XXX_Unmarshal ¶
func (m *AddRequest) XXX_Unmarshal(b []byte) error
type AddResponse ¶
type AddResponse struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AddResponse) Descriptor ¶
func (*AddResponse) Descriptor() ([]byte, []int)
func (*AddResponse) GetError ¶
func (m *AddResponse) GetError() *v1alpha.Error
func (*AddResponse) GetJob ¶
func (m *AddResponse) GetJob() *Job
func (*AddResponse) ProtoMessage ¶
func (*AddResponse) ProtoMessage()
func (*AddResponse) Reset ¶
func (m *AddResponse) Reset()
func (*AddResponse) String ¶
func (m *AddResponse) String() string
func (*AddResponse) XXX_DiscardUnknown ¶
func (m *AddResponse) XXX_DiscardUnknown()
func (*AddResponse) XXX_Marshal ¶
func (m *AddResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddResponse) XXX_Merge ¶
func (m *AddResponse) XXX_Merge(src proto.Message)
func (*AddResponse) XXX_Size ¶
func (m *AddResponse) XXX_Size() int
func (*AddResponse) XXX_Unmarshal ¶
func (m *AddResponse) XXX_Unmarshal(b []byte) error
type DeleteRequest ¶
type DeleteRequest struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Delete
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetJob ¶
func (m *DeleteRequest) GetJob() *Job
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) XXX_DiscardUnknown ¶
func (m *DeleteRequest) XXX_DiscardUnknown()
func (*DeleteRequest) XXX_Marshal ¶
func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRequest) XXX_Merge ¶
func (m *DeleteRequest) XXX_Merge(src proto.Message)
func (*DeleteRequest) XXX_Size ¶
func (m *DeleteRequest) XXX_Size() int
func (*DeleteRequest) XXX_Unmarshal ¶
func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
type DeleteResponse ¶
type DeleteResponse struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) GetError ¶
func (m *DeleteResponse) GetError() *v1alpha.Error
func (*DeleteResponse) GetJob ¶
func (m *DeleteResponse) GetJob() *Job
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) XXX_DiscardUnknown ¶
func (m *DeleteResponse) XXX_DiscardUnknown()
func (*DeleteResponse) XXX_Marshal ¶
func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteResponse) XXX_Merge ¶
func (m *DeleteResponse) XXX_Merge(src proto.Message)
func (*DeleteResponse) XXX_Size ¶
func (m *DeleteResponse) XXX_Size() int
func (*DeleteResponse) XXX_Unmarshal ¶
func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { // GetOptions options for a GetRequest. GetOptions *v1alpha.GetOptions `protobuf:"bytes,1,opt,name=getOptions,proto3" json:"getOptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Get
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetGetOptions ¶
func (m *GetRequest) GetGetOptions() *v1alpha.GetOptions
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetError ¶
func (m *GetResponse) GetError() *v1alpha.Error
func (*GetResponse) GetJob ¶
func (m *GetResponse) GetJob() *Job
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type Job ¶
type Job struct { // Metadata for Job object. Metadata *v1alpha.ObjectMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"` // Spec for Job. Spec *v1alpha.Include `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Job) Descriptor ¶
func (*Job) GetMetadata ¶
func (m *Job) GetMetadata() *v1alpha.ObjectMetadata
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type JobsClient ¶
type JobsClient interface { // Get a Job. Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // List Jobs. List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) // Add a Job. Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error) // Update a Job. Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) // Delete a Job. Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) // Watch Job. Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Jobs_WatchClient, error) }
JobsClient is the client API for Jobs service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobsClient ¶
func NewJobsClient(cc *grpc.ClientConn) JobsClient
type JobsServer ¶
type JobsServer interface { // Get a Job. Get(context.Context, *GetRequest) (*GetResponse, error) // List Jobs. List(context.Context, *ListRequest) (*ListResponse, error) // Add a Job. Add(context.Context, *AddRequest) (*AddResponse, error) // Update a Job. Update(context.Context, *UpdateRequest) (*UpdateResponse, error) // Delete a Job. Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) // Watch Job. Watch(*WatchRequest, Jobs_WatchServer) error }
JobsServer is the server API for Jobs service.
type JobsService ¶
type JobsService struct {
JobsServer
}
JobsService handler for config events.
func (*JobsService) Add ¶
func (n *JobsService) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)
Add add a Job.
func (*JobsService) Delete ¶
func (n *JobsService) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)
Delete delete a Job.
func (*JobsService) Get ¶
func (n *JobsService) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)
Get get a Job.
func (*JobsService) List ¶
func (n *JobsService) List(ctx context.Context, req *ListRequest) (*ListResponse, error)
List list Jobs.
func (*JobsService) Update ¶
func (n *JobsService) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)
Update update a Job.
func (*JobsService) Watch ¶
func (n *JobsService) Watch(req *WatchRequest, watch Jobs_WatchServer) error
Watch Watch Jobs.
type Jobs_WatchClient ¶
type Jobs_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type Jobs_WatchServer ¶
type Jobs_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type ListRequest ¶
type ListRequest struct { // ListOptions options for a ListRequest. ListOptions *v1alpha.ListOptions `protobuf:"bytes,1,opt,name=listOptions,proto3" json:"listOptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
List
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetListOptions ¶
func (m *ListRequest) GetListOptions() *v1alpha.ListOptions
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type ListResponse ¶
type ListResponse struct { // Config list. Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListResponse) Descriptor ¶
func (*ListResponse) Descriptor() ([]byte, []int)
func (*ListResponse) GetError ¶
func (m *ListResponse) GetError() *v1alpha.Error
func (*ListResponse) GetJobs ¶
func (m *ListResponse) GetJobs() []*Job
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) Reset ¶
func (m *ListResponse) Reset()
func (*ListResponse) String ¶
func (m *ListResponse) String() string
func (*ListResponse) XXX_DiscardUnknown ¶
func (m *ListResponse) XXX_DiscardUnknown()
func (*ListResponse) XXX_Marshal ¶
func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListResponse) XXX_Merge ¶
func (m *ListResponse) XXX_Merge(src proto.Message)
func (*ListResponse) XXX_Size ¶
func (m *ListResponse) XXX_Size() int
func (*ListResponse) XXX_Unmarshal ¶
func (m *ListResponse) XXX_Unmarshal(b []byte) error
type UpdateRequest ¶
type UpdateRequest struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Update
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) GetJob ¶
func (m *UpdateRequest) GetJob() *Job
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (m *UpdateRequest) String() string
func (*UpdateRequest) XXX_DiscardUnknown ¶
func (m *UpdateRequest) XXX_DiscardUnknown()
func (*UpdateRequest) XXX_Marshal ¶
func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRequest) XXX_Merge ¶
func (m *UpdateRequest) XXX_Merge(src proto.Message)
func (*UpdateRequest) XXX_Size ¶
func (m *UpdateRequest) XXX_Size() int
func (*UpdateRequest) XXX_Unmarshal ¶
func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
type UpdateResponse ¶
type UpdateResponse struct { // Job object. Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateResponse) Descriptor ¶
func (*UpdateResponse) Descriptor() ([]byte, []int)
func (*UpdateResponse) GetError ¶
func (m *UpdateResponse) GetError() *v1alpha.Error
func (*UpdateResponse) GetJob ¶
func (m *UpdateResponse) GetJob() *Job
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) Reset ¶
func (m *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (m *UpdateResponse) String() string
func (*UpdateResponse) XXX_DiscardUnknown ¶
func (m *UpdateResponse) XXX_DiscardUnknown()
func (*UpdateResponse) XXX_Marshal ¶
func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateResponse) XXX_Merge ¶
func (m *UpdateResponse) XXX_Merge(src proto.Message)
func (*UpdateResponse) XXX_Size ¶
func (m *UpdateResponse) XXX_Size() int
func (*UpdateResponse) XXX_Unmarshal ¶
func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
type WatchRequest ¶
type WatchRequest struct { // WatchOptions options for WatchRequest. WatchOptions *v1alpha.WatchOptions `protobuf:"bytes,1,opt,name=watchOptions,proto3" json:"watchOptions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Watch
func (*WatchRequest) Descriptor ¶
func (*WatchRequest) Descriptor() ([]byte, []int)
func (*WatchRequest) GetWatchOptions ¶
func (m *WatchRequest) GetWatchOptions() *v1alpha.WatchOptions
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) Reset ¶
func (m *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (m *WatchRequest) String() string
func (*WatchRequest) XXX_DiscardUnknown ¶
func (m *WatchRequest) XXX_DiscardUnknown()
func (*WatchRequest) XXX_Marshal ¶
func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchRequest) XXX_Merge ¶
func (m *WatchRequest) XXX_Merge(src proto.Message)
func (*WatchRequest) XXX_Size ¶
func (m *WatchRequest) XXX_Size() int
func (*WatchRequest) XXX_Unmarshal ¶
func (m *WatchRequest) XXX_Unmarshal(b []byte) error
type WatchResponse ¶
type WatchResponse struct { // Event info for watch response. Event *v1alpha1.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` // Job for watch response. Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"` // Error object. Error *v1alpha.Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WatchResponse) Descriptor ¶
func (*WatchResponse) Descriptor() ([]byte, []int)
func (*WatchResponse) GetError ¶
func (m *WatchResponse) GetError() *v1alpha.Error
func (*WatchResponse) GetEvent ¶
func (m *WatchResponse) GetEvent() *v1alpha1.Event
func (*WatchResponse) GetJob ¶
func (m *WatchResponse) GetJob() *Job
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) Reset ¶
func (m *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (m *WatchResponse) String() string
func (*WatchResponse) XXX_DiscardUnknown ¶
func (m *WatchResponse) XXX_DiscardUnknown()
func (*WatchResponse) XXX_Marshal ¶
func (m *WatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchResponse) XXX_Merge ¶
func (m *WatchResponse) XXX_Merge(src proto.Message)
func (*WatchResponse) XXX_Size ¶
func (m *WatchResponse) XXX_Size() int
func (*WatchResponse) XXX_Unmarshal ¶
func (m *WatchResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.