Documentation ¶
Index ¶
- Variables
- func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)
- type DeleteReply
- func (*DeleteReply) Descriptor() ([]byte, []int)
- func (m *DeleteReply) GetDeleted() int64
- func (*DeleteReply) ProtoMessage()
- func (m *DeleteReply) Reset()
- func (m *DeleteReply) String() string
- func (m *DeleteReply) XXX_DiscardUnknown()
- func (m *DeleteReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteReply) XXX_Merge(src proto.Message)
- func (m *DeleteReply) XXX_Size() int
- func (m *DeleteReply) XXX_Unmarshal(b []byte) error
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetCallback() bool
- 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 Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetCallbackId() int32
- func (m *Event) GetEcho() string
- func (m *Event) GetJobId() int32
- func (m *Event) GetSucceed() bool
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) String() string
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type InvokeReply
- func (*InvokeReply) Descriptor() ([]byte, []int)
- func (m *InvokeReply) GetJob() *Job
- func (*InvokeReply) ProtoMessage()
- func (m *InvokeReply) Reset()
- func (m *InvokeReply) String() string
- func (m *InvokeReply) XXX_DiscardUnknown()
- func (m *InvokeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InvokeReply) XXX_Merge(src proto.Message)
- func (m *InvokeReply) XXX_Size() int
- func (m *InvokeReply) XXX_Unmarshal(b []byte) error
- type InvokeRequest
- func (*InvokeRequest) Descriptor() ([]byte, []int)
- func (m *InvokeRequest) GetJob() *Job
- func (*InvokeRequest) ProtoMessage()
- func (m *InvokeRequest) Reset()
- func (m *InvokeRequest) String() string
- func (m *InvokeRequest) XXX_DiscardUnknown()
- func (m *InvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InvokeRequest) XXX_Merge(src proto.Message)
- func (m *InvokeRequest) XXX_Size() int
- func (m *InvokeRequest) XXX_Unmarshal(b []byte) error
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetCommand() string
- func (m *Job) GetControl() string
- func (m *Job) GetEchos() int32
- func (m *Job) GetExtra() int32
- func (m *Job) GetHooks() string
- func (m *Job) GetId() int32
- func (m *Job) GetStatus() string
- 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 JobServiceClient
- type JobServiceServer
- type JobService_ListClient
- type JobService_ListServer
- type JobService_RunClient
- type JobService_RunServer
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetCallback() bool
- func (m *ListRequest) GetJob() *Job
- func (m *ListRequest) GetUnscoped() bool
- 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 NotifyReply
- func (*NotifyReply) Descriptor() ([]byte, []int)
- func (*NotifyReply) ProtoMessage()
- func (m *NotifyReply) Reset()
- func (m *NotifyReply) String() string
- func (m *NotifyReply) XXX_DiscardUnknown()
- func (m *NotifyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotifyReply) XXX_Merge(src proto.Message)
- func (m *NotifyReply) XXX_Size() int
- func (m *NotifyReply) XXX_Unmarshal(b []byte) error
- type NotifyRequest
- func (*NotifyRequest) Descriptor() ([]byte, []int)
- func (m *NotifyRequest) GetEvent() *Event
- func (*NotifyRequest) ProtoMessage()
- func (m *NotifyRequest) Reset()
- func (m *NotifyRequest) String() string
- func (m *NotifyRequest) XXX_DiscardUnknown()
- func (m *NotifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotifyRequest) XXX_Merge(src proto.Message)
- func (m *NotifyRequest) XXX_Size() int
- func (m *NotifyRequest) XXX_Unmarshal(b []byte) error
- type RemoteExecReply
- func (*RemoteExecReply) Descriptor() ([]byte, []int)
- func (m *RemoteExecReply) GetStatus() string
- func (*RemoteExecReply) ProtoMessage()
- func (m *RemoteExecReply) Reset()
- func (m *RemoteExecReply) String() string
- func (m *RemoteExecReply) XXX_DiscardUnknown()
- func (m *RemoteExecReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoteExecReply) XXX_Merge(src proto.Message)
- func (m *RemoteExecReply) XXX_Size() int
- func (m *RemoteExecReply) XXX_Unmarshal(b []byte) error
- type RemoteExecRequest
- func (*RemoteExecRequest) Descriptor() ([]byte, []int)
- func (m *RemoteExecRequest) GetCommand() string
- func (m *RemoteExecRequest) GetControl() string
- func (m *RemoteExecRequest) GetExtra() int32
- func (m *RemoteExecRequest) GetId() int32
- func (*RemoteExecRequest) ProtoMessage()
- func (m *RemoteExecRequest) Reset()
- func (m *RemoteExecRequest) String() string
- func (m *RemoteExecRequest) XXX_DiscardUnknown()
- func (m *RemoteExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoteExecRequest) XXX_Merge(src proto.Message)
- func (m *RemoteExecRequest) XXX_Size() int
- func (m *RemoteExecRequest) XXX_Unmarshal(b []byte) error
- type RunReply
- func (*RunReply) Descriptor() ([]byte, []int)
- func (m *RunReply) GetJob() *Job
- func (*RunReply) ProtoMessage()
- func (m *RunReply) Reset()
- func (m *RunReply) String() string
- func (m *RunReply) XXX_DiscardUnknown()
- func (m *RunReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunReply) XXX_Merge(src proto.Message)
- func (m *RunReply) XXX_Size() int
- func (m *RunReply) XXX_Unmarshal(b []byte) error
- type RunRequest
- func (*RunRequest) Descriptor() ([]byte, []int)
- func (m *RunRequest) GetJob() *Job
- func (m *RunRequest) GetWait() int32
- func (*RunRequest) ProtoMessage()
- func (m *RunRequest) Reset()
- func (m *RunRequest) String() string
- func (m *RunRequest) XXX_DiscardUnknown()
- func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunRequest) XXX_Merge(src proto.Message)
- func (m *RunRequest) XXX_Size() int
- func (m *RunRequest) XXX_Unmarshal(b []byte) error
- type Status
- type UnimplementedJobServiceServer
- func (*UnimplementedJobServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteReply, error)
- func (*UnimplementedJobServiceServer) Invoke(ctx context.Context, req *InvokeRequest) (*InvokeReply, error)
- func (*UnimplementedJobServiceServer) List(req *ListRequest, srv JobService_ListServer) error
- func (*UnimplementedJobServiceServer) Notify(ctx context.Context, req *NotifyRequest) (*NotifyReply, error)
- func (*UnimplementedJobServiceServer) RemoteExec(ctx context.Context, req *RemoteExecRequest) (*RemoteExecReply, error)
- func (*UnimplementedJobServiceServer) Run(req *RunRequest, srv JobService_RunServer) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Status_name = map[int32]string{
0: "INIT",
1: "CREATED",
2: "RUNNING",
3: "DONE",
4: "FAILED",
5: "ABORTED",
}
View Source
var Status_value = map[string]int32{
"INIT": 0,
"CREATED": 1,
"RUNNING": 2,
"DONE": 3,
"FAILED": 4,
"ABORTED": 5,
}
Functions ¶
func RegisterJobServiceServer ¶
func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)
Types ¶
type DeleteReply ¶
type DeleteReply struct { Deleted int64 `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteReply) Descriptor ¶
func (*DeleteReply) Descriptor() ([]byte, []int)
func (*DeleteReply) GetDeleted ¶
func (m *DeleteReply) GetDeleted() int64
func (*DeleteReply) ProtoMessage ¶
func (*DeleteReply) ProtoMessage()
func (*DeleteReply) Reset ¶
func (m *DeleteReply) Reset()
func (*DeleteReply) String ¶
func (m *DeleteReply) String() string
func (*DeleteReply) XXX_DiscardUnknown ¶
func (m *DeleteReply) XXX_DiscardUnknown()
func (*DeleteReply) XXX_Marshal ¶
func (m *DeleteReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteReply) XXX_Merge ¶
func (m *DeleteReply) XXX_Merge(src proto.Message)
func (*DeleteReply) XXX_Size ¶
func (m *DeleteReply) XXX_Size() int
func (*DeleteReply) XXX_Unmarshal ¶
func (m *DeleteReply) XXX_Unmarshal(b []byte) error
type DeleteRequest ¶
type DeleteRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` Callback bool `protobuf:"varint,2,opt,name=callback,proto3" json:"callback,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetCallback ¶
func (m *DeleteRequest) GetCallback() bool
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 Event ¶
type Event struct { JobId int32 `protobuf:"varint,1,opt,name=jobId,proto3" json:"jobId,omitempty"` CallbackId int32 `protobuf:"varint,2,opt,name=callbackId,proto3" json:"callbackId,omitempty"` Succeed bool `protobuf:"varint,3,opt,name=succeed,proto3" json:"succeed,omitempty"` Echo string `protobuf:"bytes,4,opt,name=echo,proto3" json:"echo,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Event) Descriptor ¶
func (*Event) GetCallbackId ¶
func (*Event) GetSucceed ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type InvokeReply ¶
type InvokeReply struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InvokeReply) Descriptor ¶
func (*InvokeReply) Descriptor() ([]byte, []int)
func (*InvokeReply) GetJob ¶
func (m *InvokeReply) GetJob() *Job
func (*InvokeReply) ProtoMessage ¶
func (*InvokeReply) ProtoMessage()
func (*InvokeReply) Reset ¶
func (m *InvokeReply) Reset()
func (*InvokeReply) String ¶
func (m *InvokeReply) String() string
func (*InvokeReply) XXX_DiscardUnknown ¶
func (m *InvokeReply) XXX_DiscardUnknown()
func (*InvokeReply) XXX_Marshal ¶
func (m *InvokeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InvokeReply) XXX_Merge ¶
func (m *InvokeReply) XXX_Merge(src proto.Message)
func (*InvokeReply) XXX_Size ¶
func (m *InvokeReply) XXX_Size() int
func (*InvokeReply) XXX_Unmarshal ¶
func (m *InvokeReply) XXX_Unmarshal(b []byte) error
type InvokeRequest ¶
type InvokeRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*InvokeRequest) Descriptor ¶
func (*InvokeRequest) Descriptor() ([]byte, []int)
func (*InvokeRequest) GetJob ¶
func (m *InvokeRequest) GetJob() *Job
func (*InvokeRequest) ProtoMessage ¶
func (*InvokeRequest) ProtoMessage()
func (*InvokeRequest) Reset ¶
func (m *InvokeRequest) Reset()
func (*InvokeRequest) String ¶
func (m *InvokeRequest) String() string
func (*InvokeRequest) XXX_DiscardUnknown ¶
func (m *InvokeRequest) XXX_DiscardUnknown()
func (*InvokeRequest) XXX_Marshal ¶
func (m *InvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InvokeRequest) XXX_Merge ¶
func (m *InvokeRequest) XXX_Merge(src proto.Message)
func (*InvokeRequest) XXX_Size ¶
func (m *InvokeRequest) XXX_Size() int
func (*InvokeRequest) XXX_Unmarshal ¶
func (m *InvokeRequest) XXX_Unmarshal(b []byte) error
type Job ¶
type Job struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` Control string `protobuf:"bytes,3,opt,name=control,proto3" json:"control,omitempty"` Command string `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"` Extra int32 `protobuf:"varint,5,opt,name=extra,proto3" json:"extra,omitempty"` Hooks string `protobuf:"bytes,6,opt,name=hooks,proto3" json:"hooks,omitempty"` Echos int32 `protobuf:"varint,7,opt,name=echos,proto3" json:"echos,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Job) Descriptor ¶
func (*Job) GetCommand ¶
func (*Job) GetControl ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type JobServiceClient ¶
type JobServiceClient interface { Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (JobService_RunClient, error) Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeReply, error) Notify(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyReply, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (JobService_ListClient, error) RemoteExec(ctx context.Context, in *RemoteExecRequest, opts ...grpc.CallOption) (*RemoteExecReply, error) }
JobServiceClient is the client API for JobService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobServiceClient ¶
func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient
type JobServiceServer ¶
type JobServiceServer interface { Run(*RunRequest, JobService_RunServer) error Invoke(context.Context, *InvokeRequest) (*InvokeReply, error) Notify(context.Context, *NotifyRequest) (*NotifyReply, error) Delete(context.Context, *DeleteRequest) (*DeleteReply, error) List(*ListRequest, JobService_ListServer) error RemoteExec(context.Context, *RemoteExecRequest) (*RemoteExecReply, error) }
JobServiceServer is the server API for JobService service.
type JobService_ListClient ¶
type JobService_ListClient interface { Recv() (*Job, error) grpc.ClientStream }
type JobService_ListServer ¶
type JobService_ListServer interface { Send(*Job) error grpc.ServerStream }
type JobService_RunClient ¶
type JobService_RunClient interface { Recv() (*Event, error) grpc.ClientStream }
type JobService_RunServer ¶
type JobService_RunServer interface { Send(*Event) error grpc.ServerStream }
type ListRequest ¶
type ListRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` Callback bool `protobuf:"varint,2,opt,name=callback,proto3" json:"callback,omitempty"` Unscoped bool `protobuf:"varint,3,opt,name=unscoped,proto3" json:"unscoped,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetCallback ¶
func (m *ListRequest) GetCallback() bool
func (*ListRequest) GetJob ¶
func (m *ListRequest) GetJob() *Job
func (*ListRequest) GetUnscoped ¶
func (m *ListRequest) GetUnscoped() bool
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 NotifyReply ¶
type NotifyReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NotifyReply) Descriptor ¶
func (*NotifyReply) Descriptor() ([]byte, []int)
func (*NotifyReply) ProtoMessage ¶
func (*NotifyReply) ProtoMessage()
func (*NotifyReply) Reset ¶
func (m *NotifyReply) Reset()
func (*NotifyReply) String ¶
func (m *NotifyReply) String() string
func (*NotifyReply) XXX_DiscardUnknown ¶
func (m *NotifyReply) XXX_DiscardUnknown()
func (*NotifyReply) XXX_Marshal ¶
func (m *NotifyReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotifyReply) XXX_Merge ¶
func (m *NotifyReply) XXX_Merge(src proto.Message)
func (*NotifyReply) XXX_Size ¶
func (m *NotifyReply) XXX_Size() int
func (*NotifyReply) XXX_Unmarshal ¶
func (m *NotifyReply) XXX_Unmarshal(b []byte) error
type NotifyRequest ¶
type NotifyRequest struct { Event *Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NotifyRequest) Descriptor ¶
func (*NotifyRequest) Descriptor() ([]byte, []int)
func (*NotifyRequest) GetEvent ¶
func (m *NotifyRequest) GetEvent() *Event
func (*NotifyRequest) ProtoMessage ¶
func (*NotifyRequest) ProtoMessage()
func (*NotifyRequest) Reset ¶
func (m *NotifyRequest) Reset()
func (*NotifyRequest) String ¶
func (m *NotifyRequest) String() string
func (*NotifyRequest) XXX_DiscardUnknown ¶
func (m *NotifyRequest) XXX_DiscardUnknown()
func (*NotifyRequest) XXX_Marshal ¶
func (m *NotifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotifyRequest) XXX_Merge ¶
func (m *NotifyRequest) XXX_Merge(src proto.Message)
func (*NotifyRequest) XXX_Size ¶
func (m *NotifyRequest) XXX_Size() int
func (*NotifyRequest) XXX_Unmarshal ¶
func (m *NotifyRequest) XXX_Unmarshal(b []byte) error
type RemoteExecReply ¶
type RemoteExecReply struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoteExecReply) Descriptor ¶
func (*RemoteExecReply) Descriptor() ([]byte, []int)
func (*RemoteExecReply) GetStatus ¶
func (m *RemoteExecReply) GetStatus() string
func (*RemoteExecReply) ProtoMessage ¶
func (*RemoteExecReply) ProtoMessage()
func (*RemoteExecReply) Reset ¶
func (m *RemoteExecReply) Reset()
func (*RemoteExecReply) String ¶
func (m *RemoteExecReply) String() string
func (*RemoteExecReply) XXX_DiscardUnknown ¶
func (m *RemoteExecReply) XXX_DiscardUnknown()
func (*RemoteExecReply) XXX_Marshal ¶
func (m *RemoteExecReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoteExecReply) XXX_Merge ¶
func (m *RemoteExecReply) XXX_Merge(src proto.Message)
func (*RemoteExecReply) XXX_Size ¶
func (m *RemoteExecReply) XXX_Size() int
func (*RemoteExecReply) XXX_Unmarshal ¶
func (m *RemoteExecReply) XXX_Unmarshal(b []byte) error
type RemoteExecRequest ¶
type RemoteExecRequest struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Control string `protobuf:"bytes,2,opt,name=control,proto3" json:"control,omitempty"` Command string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"` Extra int32 `protobuf:"varint,4,opt,name=extra,proto3" json:"extra,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoteExecRequest) Descriptor ¶
func (*RemoteExecRequest) Descriptor() ([]byte, []int)
func (*RemoteExecRequest) GetCommand ¶
func (m *RemoteExecRequest) GetCommand() string
func (*RemoteExecRequest) GetControl ¶
func (m *RemoteExecRequest) GetControl() string
func (*RemoteExecRequest) GetExtra ¶
func (m *RemoteExecRequest) GetExtra() int32
func (*RemoteExecRequest) GetId ¶
func (m *RemoteExecRequest) GetId() int32
func (*RemoteExecRequest) ProtoMessage ¶
func (*RemoteExecRequest) ProtoMessage()
func (*RemoteExecRequest) Reset ¶
func (m *RemoteExecRequest) Reset()
func (*RemoteExecRequest) String ¶
func (m *RemoteExecRequest) String() string
func (*RemoteExecRequest) XXX_DiscardUnknown ¶
func (m *RemoteExecRequest) XXX_DiscardUnknown()
func (*RemoteExecRequest) XXX_Marshal ¶
func (m *RemoteExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoteExecRequest) XXX_Merge ¶
func (m *RemoteExecRequest) XXX_Merge(src proto.Message)
func (*RemoteExecRequest) XXX_Size ¶
func (m *RemoteExecRequest) XXX_Size() int
func (*RemoteExecRequest) XXX_Unmarshal ¶
func (m *RemoteExecRequest) XXX_Unmarshal(b []byte) error
type RunReply ¶
type RunReply struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunReply) Descriptor ¶
func (*RunReply) ProtoMessage ¶
func (*RunReply) ProtoMessage()
func (*RunReply) XXX_DiscardUnknown ¶
func (m *RunReply) XXX_DiscardUnknown()
func (*RunReply) XXX_Marshal ¶
func (*RunReply) XXX_Unmarshal ¶
type RunRequest ¶
type RunRequest struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` Wait int32 `protobuf:"varint,2,opt,name=wait,proto3" json:"wait,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RunRequest) Descriptor ¶
func (*RunRequest) Descriptor() ([]byte, []int)
func (*RunRequest) GetJob ¶
func (m *RunRequest) GetJob() *Job
func (*RunRequest) GetWait ¶
func (m *RunRequest) GetWait() int32
func (*RunRequest) ProtoMessage ¶
func (*RunRequest) ProtoMessage()
func (*RunRequest) Reset ¶
func (m *RunRequest) Reset()
func (*RunRequest) String ¶
func (m *RunRequest) String() string
func (*RunRequest) XXX_DiscardUnknown ¶
func (m *RunRequest) XXX_DiscardUnknown()
func (*RunRequest) XXX_Marshal ¶
func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunRequest) XXX_Merge ¶
func (m *RunRequest) XXX_Merge(src proto.Message)
func (*RunRequest) XXX_Size ¶
func (m *RunRequest) XXX_Size() int
func (*RunRequest) XXX_Unmarshal ¶
func (m *RunRequest) XXX_Unmarshal(b []byte) error
type UnimplementedJobServiceServer ¶
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedJobServiceServer) Delete ¶
func (*UnimplementedJobServiceServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteReply, error)
func (*UnimplementedJobServiceServer) Invoke ¶
func (*UnimplementedJobServiceServer) Invoke(ctx context.Context, req *InvokeRequest) (*InvokeReply, error)
func (*UnimplementedJobServiceServer) List ¶
func (*UnimplementedJobServiceServer) List(req *ListRequest, srv JobService_ListServer) error
func (*UnimplementedJobServiceServer) Notify ¶
func (*UnimplementedJobServiceServer) Notify(ctx context.Context, req *NotifyRequest) (*NotifyReply, error)
func (*UnimplementedJobServiceServer) RemoteExec ¶
func (*UnimplementedJobServiceServer) RemoteExec(ctx context.Context, req *RemoteExecRequest) (*RemoteExecReply, error)
func (*UnimplementedJobServiceServer) Run ¶
func (*UnimplementedJobServiceServer) Run(req *RunRequest, srv JobService_RunServer) error
Click to show internal directories.
Click to hide internal directories.