jobs

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jun 4, 2021 License: Apache-2.0, Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*Event) GetCallbackId

func (m *Event) GetCallbackId() int32

func (*Event) GetEcho

func (m *Event) GetEcho() string

func (*Event) GetJobId

func (m *Event) GetJobId() int32

func (*Event) GetSucceed

func (m *Event) GetSucceed() bool

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

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

func (*Event) XXX_Merge

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

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

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

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) Descriptor() ([]byte, []int)

func (*Job) GetCommand

func (m *Job) GetCommand() string

func (*Job) GetControl

func (m *Job) GetControl() string

func (*Job) GetEchos

func (m *Job) GetEchos() int32

func (*Job) GetExtra

func (m *Job) GetExtra() int32

func (*Job) GetHooks

func (m *Job) GetHooks() string

func (*Job) GetId

func (m *Job) GetId() int32

func (*Job) GetStatus

func (m *Job) GetStatus() string

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) Reset

func (m *Job) Reset()

func (*Job) String

func (m *Job) String() string

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 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

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) Descriptor() ([]byte, []int)

func (*RunReply) GetJob

func (m *RunReply) GetJob() *Job

func (*RunReply) ProtoMessage

func (*RunReply) ProtoMessage()

func (*RunReply) Reset

func (m *RunReply) Reset()

func (*RunReply) String

func (m *RunReply) String() string

func (*RunReply) XXX_DiscardUnknown

func (m *RunReply) XXX_DiscardUnknown()

func (*RunReply) XXX_Marshal

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

func (*RunReply) XXX_Merge

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

func (*RunReply) XXX_Size

func (m *RunReply) XXX_Size() int

func (*RunReply) XXX_Unmarshal

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

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 Status

type Status int32
const (
	Status_INIT    Status = 0
	Status_CREATED Status = 1
	Status_RUNNING Status = 2
	Status_DONE    Status = 3
	Status_FAILED  Status = 4
	Status_ABORTED Status = 5
)

func (Status) EnumDescriptor

func (Status) EnumDescriptor() ([]byte, []int)

func (Status) String

func (x Status) String() string

type UnimplementedJobServiceServer

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobServiceServer) Delete

func (*UnimplementedJobServiceServer) Invoke

func (*UnimplementedJobServiceServer) List

func (*UnimplementedJobServiceServer) Notify

func (*UnimplementedJobServiceServer) RemoteExec

func (*UnimplementedJobServiceServer) Run

Jump to

Keyboard shortcuts

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