Versions in this module Expand all Collapse all v1 v1.0.0 Jun 4, 2021 Changes in this version + var Status_name = map[int32]string + var Status_value = map[string]int32 + func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer) + type DeleteReply struct + Deleted int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteReply) Descriptor() ([]byte, []int) + func (*DeleteReply) ProtoMessage() + func (m *DeleteReply) GetDeleted() int64 + 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 struct + Callback bool + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetCallback() bool + func (m *DeleteRequest) GetJob() *Job + 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 struct + CallbackId int32 + Echo string + JobId int32 + Succeed bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetCallbackId() int32 + func (m *Event) GetEcho() string + func (m *Event) GetJobId() int32 + func (m *Event) GetSucceed() bool + 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 struct + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InvokeReply) Descriptor() ([]byte, []int) + func (*InvokeReply) ProtoMessage() + func (m *InvokeReply) GetJob() *Job + 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 struct + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*InvokeRequest) Descriptor() ([]byte, []int) + func (*InvokeRequest) ProtoMessage() + func (m *InvokeRequest) GetJob() *Job + 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 struct + Command string + Control string + Echos int32 + Extra int32 + Hooks string + Id int32 + Status string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + 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 (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 interface + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteReply, error) + Invoke func(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeReply, error) + List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (JobService_ListClient, error) + Notify func(ctx context.Context, in *NotifyRequest, opts ...grpc.CallOption) (*NotifyReply, error) + RemoteExec func(ctx context.Context, in *RemoteExecRequest, opts ...grpc.CallOption) (*RemoteExecReply, error) + Run func(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (JobService_RunClient, error) + func NewJobServiceClient(cc *grpc.ClientConn) JobServiceClient + type JobServiceServer interface + Delete func(context.Context, *DeleteRequest) (*DeleteReply, error) + Invoke func(context.Context, *InvokeRequest) (*InvokeReply, error) + List func(*ListRequest, JobService_ListServer) error + Notify func(context.Context, *NotifyRequest) (*NotifyReply, error) + RemoteExec func(context.Context, *RemoteExecRequest) (*RemoteExecReply, error) + Run func(*RunRequest, JobService_RunServer) error + type JobService_ListClient interface + Recv func() (*Job, error) + type JobService_ListServer interface + Send func(*Job) error + type JobService_RunClient interface + Recv func() (*Event, error) + type JobService_RunServer interface + Send func(*Event) error + type ListRequest struct + Callback bool + Job *Job + Unscoped bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) GetCallback() bool + func (m *ListRequest) GetJob() *Job + func (m *ListRequest) GetUnscoped() bool + 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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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 struct + Event *Event + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NotifyRequest) Descriptor() ([]byte, []int) + func (*NotifyRequest) ProtoMessage() + func (m *NotifyRequest) GetEvent() *Event + 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 struct + Status string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoteExecReply) Descriptor() ([]byte, []int) + func (*RemoteExecReply) ProtoMessage() + func (m *RemoteExecReply) GetStatus() string + 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 struct + Command string + Control string + Extra int32 + Id int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoteExecRequest) Descriptor() ([]byte, []int) + func (*RemoteExecRequest) ProtoMessage() + func (m *RemoteExecRequest) GetCommand() string + func (m *RemoteExecRequest) GetControl() string + func (m *RemoteExecRequest) GetExtra() int32 + func (m *RemoteExecRequest) GetId() int32 + 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 struct + Job *Job + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunReply) Descriptor() ([]byte, []int) + func (*RunReply) ProtoMessage() + func (m *RunReply) GetJob() *Job + 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 struct + Job *Job + Wait int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RunRequest) Descriptor() ([]byte, []int) + func (*RunRequest) ProtoMessage() + func (m *RunRequest) GetJob() *Job + func (m *RunRequest) GetWait() int32 + 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 int32 + const Status_ABORTED + const Status_CREATED + const Status_DONE + const Status_FAILED + const Status_INIT + const Status_RUNNING + func (Status) EnumDescriptor() ([]byte, []int) + func (x Status) String() string + type UnimplementedJobServiceServer struct + 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
Go to main page