types

package
v3.0.8 Latest Latest
Warning

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

 Go to latest Published: Nov 20, 2020 License: LGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAgentServer 

func RegisterAgentServer(s *grpc.Server, srv AgentServer)

func RegisterDkronServer 

func RegisterDkronServer(s *grpc.Server, srv DkronServer)

func RegisterExecutorServer 

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

func RegisterStatusHelperServer 

func RegisterStatusHelperServer(s *grpc.Server, srv StatusHelperServer)

Types

type AgentClient 

type AgentClient interface {
	AgentRun(ctx context.Context, in *AgentRunRequest, opts ...grpc.CallOption) (Agent_AgentRunClient, error)
}

AgentClient is the client API for Agent service.

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

func NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentRunRequest 

type AgentRunRequest struct {
	Job                  *Job       `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Execution            *Execution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*AgentRunRequest) Descriptor 

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

func (*AgentRunRequest) GetExecution 

func (m *AgentRunRequest) GetExecution() *Execution

func (*AgentRunRequest) GetJob 

func (m *AgentRunRequest) GetJob() *Job

func (*AgentRunRequest) ProtoMessage 

func (*AgentRunRequest) ProtoMessage()

func (*AgentRunRequest) Reset 

func (m *AgentRunRequest) Reset()

func (*AgentRunRequest) String 

func (m *AgentRunRequest) String() string

func (*AgentRunRequest) XXX_DiscardUnknown 

func (m *AgentRunRequest) XXX_DiscardUnknown()

func (*AgentRunRequest) XXX_Marshal 

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

func (*AgentRunRequest) XXX_Merge 

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

func (*AgentRunRequest) XXX_Size 

func (m *AgentRunRequest) XXX_Size() int

func (*AgentRunRequest) XXX_Unmarshal 

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

type AgentRunResponse 

type AgentRunResponse struct {
	From                 string   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AgentRunResponse) Descriptor 

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

func (*AgentRunResponse) GetFrom 

func (m *AgentRunResponse) GetFrom() string

func (*AgentRunResponse) GetPayload 

func (m *AgentRunResponse) GetPayload() []byte

func (*AgentRunResponse) ProtoMessage 

func (*AgentRunResponse) ProtoMessage()

func (*AgentRunResponse) Reset 

func (m *AgentRunResponse) Reset()

func (*AgentRunResponse) String 

func (m *AgentRunResponse) String() string

func (*AgentRunResponse) XXX_DiscardUnknown 

func (m *AgentRunResponse) XXX_DiscardUnknown()

func (*AgentRunResponse) XXX_Marshal 

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

func (*AgentRunResponse) XXX_Merge 

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

func (*AgentRunResponse) XXX_Size 

func (m *AgentRunResponse) XXX_Size() int

func (*AgentRunResponse) XXX_Unmarshal 

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

type AgentRunStream 

type AgentRunStream struct {
	Execution            *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*AgentRunStream) Descriptor 

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

func (*AgentRunStream) GetExecution 

func (m *AgentRunStream) GetExecution() *Execution

func (*AgentRunStream) ProtoMessage 

func (*AgentRunStream) ProtoMessage()

func (*AgentRunStream) Reset 

func (m *AgentRunStream) Reset()

func (*AgentRunStream) String 

func (m *AgentRunStream) String() string

func (*AgentRunStream) XXX_DiscardUnknown 

func (m *AgentRunStream) XXX_DiscardUnknown()

func (*AgentRunStream) XXX_Marshal 

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

func (*AgentRunStream) XXX_Merge 

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

func (*AgentRunStream) XXX_Size 

func (m *AgentRunStream) XXX_Size() int

func (*AgentRunStream) XXX_Unmarshal 

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

type AgentServer 

type AgentServer interface {
	AgentRun(*AgentRunRequest, Agent_AgentRunServer) error
}

AgentServer is the server API for Agent service.

type Agent_AgentRunClient 

type Agent_AgentRunClient interface {
	Recv() (*AgentRunStream, error)
	grpc.ClientStream
}

type Agent_AgentRunServer 

type Agent_AgentRunServer interface {
	Send(*AgentRunStream) error
	grpc.ServerStream
}

type DeleteJobRequest 

type DeleteJobRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteJobRequest) Descriptor 

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

func (*DeleteJobRequest) GetJobName 

func (m *DeleteJobRequest) GetJobName() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) Reset 

func (m *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (m *DeleteJobRequest) String() string

func (*DeleteJobRequest) XXX_DiscardUnknown 

func (m *DeleteJobRequest) XXX_DiscardUnknown()

func (*DeleteJobRequest) XXX_Marshal 

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

func (*DeleteJobRequest) XXX_Merge 

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

func (*DeleteJobRequest) XXX_Size 

func (m *DeleteJobRequest) XXX_Size() int

func (*DeleteJobRequest) XXX_Unmarshal 

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

type DeleteJobResponse 

type DeleteJobResponse 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 (*DeleteJobResponse) Descriptor 

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

func (*DeleteJobResponse) GetJob 

func (m *DeleteJobResponse) GetJob() *Job

func (*DeleteJobResponse) ProtoMessage 

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) Reset 

func (m *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String 

func (m *DeleteJobResponse) String() string

func (*DeleteJobResponse) XXX_DiscardUnknown 

func (m *DeleteJobResponse) XXX_DiscardUnknown()

func (*DeleteJobResponse) XXX_Marshal 

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

func (*DeleteJobResponse) XXX_Merge 

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

func (*DeleteJobResponse) XXX_Size 

func (m *DeleteJobResponse) XXX_Size() int

func (*DeleteJobResponse) XXX_Unmarshal 

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

type DkronClient 

type DkronClient interface {
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	ExecutionDone(ctx context.Context, in *ExecutionDoneRequest, opts ...grpc.CallOption) (*ExecutionDoneResponse, error)
	Leave(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	SetJob(ctx context.Context, in *SetJobRequest, opts ...grpc.CallOption) (*SetJobResponse, error)
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error)
	RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error)
	ToggleJob(ctx context.Context, in *ToggleJobRequest, opts ...grpc.CallOption) (*ToggleJobResponse, error)
	RaftGetConfiguration(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*RaftGetConfigurationResponse, error)
	RaftRemovePeerByID(ctx context.Context, in *RaftRemovePeerByIDRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetActiveExecutions(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetActiveExecutionsResponse, error)
	SetExecution(ctx context.Context, in *Execution, opts ...grpc.CallOption) (*empty.Empty, error)
}

DkronClient is the client API for Dkron service.

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

func NewDkronClient 

func NewDkronClient(cc grpc.ClientConnInterface) DkronClient

type DkronServer 

type DkronServer interface {
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	ExecutionDone(context.Context, *ExecutionDoneRequest) (*ExecutionDoneResponse, error)
	Leave(context.Context, *empty.Empty) (*empty.Empty, error)
	SetJob(context.Context, *SetJobRequest) (*SetJobResponse, error)
	DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error)
	RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error)
	ToggleJob(context.Context, *ToggleJobRequest) (*ToggleJobResponse, error)
	RaftGetConfiguration(context.Context, *empty.Empty) (*RaftGetConfigurationResponse, error)
	RaftRemovePeerByID(context.Context, *RaftRemovePeerByIDRequest) (*empty.Empty, error)
	GetActiveExecutions(context.Context, *empty.Empty) (*GetActiveExecutionsResponse, error)
	SetExecution(context.Context, *Execution) (*empty.Empty, error)
}

DkronServer is the server API for Dkron service.

type ExecuteRequest 

type ExecuteRequest struct {
	JobName              string            `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Config               map[string]string `` /* 153-byte string literal not displayed */
	StatusServer         uint32            `protobuf:"varint,3,opt,name=status_server,json=statusServer,proto3" json:"status_server,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExecuteRequest) Descriptor 

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

func (*ExecuteRequest) GetConfig 

func (m *ExecuteRequest) GetConfig() map[string]string

func (*ExecuteRequest) GetJobName 

func (m *ExecuteRequest) GetJobName() string

func (*ExecuteRequest) GetStatusServer 

func (m *ExecuteRequest) GetStatusServer() uint32

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) Reset 

func (m *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (m *ExecuteRequest) String() string

func (*ExecuteRequest) XXX_DiscardUnknown 

func (m *ExecuteRequest) XXX_DiscardUnknown()

func (*ExecuteRequest) XXX_Marshal 

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

func (*ExecuteRequest) XXX_Merge 

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

func (*ExecuteRequest) XXX_Size 

func (m *ExecuteRequest) XXX_Size() int

func (*ExecuteRequest) XXX_Unmarshal 

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

type ExecuteResponse 

type ExecuteResponse struct {
	Output               []byte   `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecuteResponse) Descriptor 

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

func (*ExecuteResponse) GetError 

func (m *ExecuteResponse) GetError() string

func (*ExecuteResponse) GetOutput 

func (m *ExecuteResponse) GetOutput() []byte

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) Reset 

func (m *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (m *ExecuteResponse) String() string

func (*ExecuteResponse) XXX_DiscardUnknown 

func (m *ExecuteResponse) XXX_DiscardUnknown()

func (*ExecuteResponse) XXX_Marshal 

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

func (*ExecuteResponse) XXX_Merge 

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

func (*ExecuteResponse) XXX_Size 

func (m *ExecuteResponse) XXX_Size() int

func (*ExecuteResponse) XXX_Unmarshal 

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

type Execution 

type Execution struct {
	JobName              string               `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Success              bool                 `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Output               []byte               `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	NodeName             string               `protobuf:"bytes,4,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	Group                int64                `protobuf:"varint,5,opt,name=group,proto3" json:"group,omitempty"`
	Attempt              uint32               `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	StartedAt            *timestamp.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt           *timestamp.Timestamp `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Execution) Descriptor 

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

func (*Execution) GetAttempt 

func (m *Execution) GetAttempt() uint32

func (*Execution) GetFinishedAt 

func (m *Execution) GetFinishedAt() *timestamp.Timestamp

func (*Execution) GetGroup 

func (m *Execution) GetGroup() int64

func (*Execution) GetJobName 

func (m *Execution) GetJobName() string

func (*Execution) GetNodeName 

func (m *Execution) GetNodeName() string

func (*Execution) GetOutput 

func (m *Execution) GetOutput() []byte

func (*Execution) GetStartedAt 

func (m *Execution) GetStartedAt() *timestamp.Timestamp

func (*Execution) GetSuccess 

func (m *Execution) GetSuccess() bool

func (*Execution) Key 

func (e *Execution) Key() string

Key computes the execution key

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) Reset 

func (m *Execution) Reset()

func (*Execution) String 

func (m *Execution) String() string

func (*Execution) XXX_DiscardUnknown 

func (m *Execution) XXX_DiscardUnknown()

func (*Execution) XXX_Marshal 

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

func (*Execution) XXX_Merge 

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

func (*Execution) XXX_Size 

func (m *Execution) XXX_Size() int

func (*Execution) XXX_Unmarshal 

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

type ExecutionDoneRequest 

type ExecutionDoneRequest struct {
	Execution            *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ExecutionDoneRequest) Descriptor 

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

func (*ExecutionDoneRequest) GetExecution 

func (m *ExecutionDoneRequest) GetExecution() *Execution

func (*ExecutionDoneRequest) ProtoMessage 

func (*ExecutionDoneRequest) ProtoMessage()

func (*ExecutionDoneRequest) Reset 

func (m *ExecutionDoneRequest) Reset()

func (*ExecutionDoneRequest) String 

func (m *ExecutionDoneRequest) String() string

func (*ExecutionDoneRequest) XXX_DiscardUnknown 

func (m *ExecutionDoneRequest) XXX_DiscardUnknown()

func (*ExecutionDoneRequest) XXX_Marshal 

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

func (*ExecutionDoneRequest) XXX_Merge 

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

func (*ExecutionDoneRequest) XXX_Size 

func (m *ExecutionDoneRequest) XXX_Size() int

func (*ExecutionDoneRequest) XXX_Unmarshal 

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

type ExecutionDoneResponse 

type ExecutionDoneResponse struct {
	From                 string   `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecutionDoneResponse) Descriptor 

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

func (*ExecutionDoneResponse) GetFrom 

func (m *ExecutionDoneResponse) GetFrom() string

func (*ExecutionDoneResponse) GetPayload 

func (m *ExecutionDoneResponse) GetPayload() []byte

func (*ExecutionDoneResponse) ProtoMessage 

func (*ExecutionDoneResponse) ProtoMessage()

func (*ExecutionDoneResponse) Reset 

func (m *ExecutionDoneResponse) Reset()

func (*ExecutionDoneResponse) String 

func (m *ExecutionDoneResponse) String() string

func (*ExecutionDoneResponse) XXX_DiscardUnknown 

func (m *ExecutionDoneResponse) XXX_DiscardUnknown()

func (*ExecutionDoneResponse) XXX_Marshal 

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

func (*ExecutionDoneResponse) XXX_Merge 

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

func (*ExecutionDoneResponse) XXX_Size 

func (m *ExecutionDoneResponse) XXX_Size() int

func (*ExecutionDoneResponse) XXX_Unmarshal 

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

type ExecutorClient 

type ExecutorClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

ExecutorClient is the client API for Executor service.

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

func NewExecutorClient 

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
}

ExecutorServer is the server API for Executor service.

type GetActiveExecutionsResponse 

type GetActiveExecutionsResponse struct {
	Executions           []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetActiveExecutionsResponse) Descriptor 

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

func (*GetActiveExecutionsResponse) GetExecutions 

func (m *GetActiveExecutionsResponse) GetExecutions() []*Execution

func (*GetActiveExecutionsResponse) ProtoMessage 

func (*GetActiveExecutionsResponse) ProtoMessage()

func (*GetActiveExecutionsResponse) Reset 

func (m *GetActiveExecutionsResponse) Reset()

func (*GetActiveExecutionsResponse) String 

func (m *GetActiveExecutionsResponse) String() string

func (*GetActiveExecutionsResponse) XXX_DiscardUnknown 

func (m *GetActiveExecutionsResponse) XXX_DiscardUnknown()

func (*GetActiveExecutionsResponse) XXX_Marshal 

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

func (*GetActiveExecutionsResponse) XXX_Merge 

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

func (*GetActiveExecutionsResponse) XXX_Size 

func (m *GetActiveExecutionsResponse) XXX_Size() int

func (*GetActiveExecutionsResponse) XXX_Unmarshal 

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

type GetJobRequest 

type GetJobRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetJobRequest) Descriptor 

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

func (*GetJobRequest) GetJobName 

func (m *GetJobRequest) GetJobName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (m *GetJobRequest) String() string

func (*GetJobRequest) XXX_DiscardUnknown 

func (m *GetJobRequest) XXX_DiscardUnknown()

func (*GetJobRequest) XXX_Marshal 

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

func (*GetJobRequest) XXX_Merge 

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

func (*GetJobRequest) XXX_Size 

func (m *GetJobRequest) XXX_Size() int

func (*GetJobRequest) XXX_Unmarshal 

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

type GetJobResponse 

type GetJobResponse 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 (*GetJobResponse) Descriptor 

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

func (*GetJobResponse) GetJob 

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset 

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (m *GetJobResponse) String() string

func (*GetJobResponse) XXX_DiscardUnknown 

func (m *GetJobResponse) XXX_DiscardUnknown()

func (*GetJobResponse) XXX_Marshal 

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

func (*GetJobResponse) XXX_Merge 

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

func (*GetJobResponse) XXX_Size 

func (m *GetJobResponse) XXX_Size() int

func (*GetJobResponse) XXX_Unmarshal 

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

type Job 

type Job struct {
	Name                 string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Timezone             string                   `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"`
	Schedule             string                   `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Owner                string                   `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	OwnerEmail           string                   `protobuf:"bytes,8,opt,name=owner_email,json=ownerEmail,proto3" json:"owner_email,omitempty"`
	SuccessCount         int32                    `protobuf:"varint,9,opt,name=success_count,json=successCount,proto3" json:"success_count,omitempty"`
	ErrorCount           int32                    `protobuf:"varint,10,opt,name=error_count,json=errorCount,proto3" json:"error_count,omitempty"`
	Disabled             bool                     `protobuf:"varint,11,opt,name=disabled,proto3" json:"disabled,omitempty"`
	Tags                 map[string]string        `` /* 150-byte string literal not displayed */
	Retries              uint32                   `protobuf:"varint,13,opt,name=retries,proto3" json:"retries,omitempty"`
	DependentJobs        []string                 `protobuf:"bytes,14,rep,name=dependent_jobs,json=dependentJobs,proto3" json:"dependent_jobs,omitempty"`
	ParentJob            string                   `protobuf:"bytes,15,opt,name=parent_job,json=parentJob,proto3" json:"parent_job,omitempty"`
	Concurrency          string                   `protobuf:"bytes,16,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	Executor             string                   `protobuf:"bytes,17,opt,name=executor,proto3" json:"executor,omitempty"`
	ExecutorConfig       map[string]string        `` /* 192-byte string literal not displayed */
	Status               string                   `protobuf:"bytes,19,opt,name=status,proto3" json:"status,omitempty"`
	Metadata             map[string]string        `` /* 158-byte string literal not displayed */
	LastSuccess          *Job_NullableTime        `protobuf:"bytes,25,opt,name=last_success,json=lastSuccess,proto3" json:"last_success,omitempty"`
	LastError            *Job_NullableTime        `protobuf:"bytes,26,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	Next                 *timestamp.Timestamp     `protobuf:"bytes,23,opt,name=next,proto3" json:"next,omitempty"`
	Displayname          string                   `protobuf:"bytes,24,opt,name=displayname,proto3" json:"displayname,omitempty"`
	Processors           map[string]*PluginConfig `` /* 162-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Job) Descriptor 

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

func (*Job) GetConcurrency 

func (m *Job) GetConcurrency() string

func (*Job) GetDependentJobs 

func (m *Job) GetDependentJobs() []string

func (*Job) GetDisabled 

func (m *Job) GetDisabled() bool

func (*Job) GetDisplayname 

func (m *Job) GetDisplayname() string

func (*Job) GetErrorCount 

func (m *Job) GetErrorCount() int32

func (*Job) GetExecutor 

func (m *Job) GetExecutor() string

func (*Job) GetExecutorConfig 

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

func (*Job) GetLastError 

func (m *Job) GetLastError() *Job_NullableTime

func (*Job) GetLastSuccess 

func (m *Job) GetLastSuccess() *Job_NullableTime

func (*Job) GetMetadata 

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

func (*Job) GetName 

func (m *Job) GetName() string

func (*Job) GetNext 

func (m *Job) GetNext() *timestamp.Timestamp

func (*Job) GetOwner 

func (m *Job) GetOwner() string

func (*Job) GetOwnerEmail 

func (m *Job) GetOwnerEmail() string

func (*Job) GetParentJob 

func (m *Job) GetParentJob() string

func (*Job) GetProcessors 

func (m *Job) GetProcessors() map[string]*PluginConfig

func (*Job) GetRetries 

func (m *Job) GetRetries() uint32

func (*Job) GetSchedule 

func (m *Job) GetSchedule() string

func (*Job) GetStatus 

func (m *Job) GetStatus() string

func (*Job) GetSuccessCount 

func (m *Job) GetSuccessCount() int32

func (*Job) GetTags 

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

func (*Job) GetTimezone 

func (m *Job) GetTimezone() 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 Job_NullableTime 

type Job_NullableTime struct {
	HasValue             bool                 `protobuf:"varint,1,opt,name=has_value,json=hasValue,proto3" json:"has_value,omitempty"`
	Time                 *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Job_NullableTime) Descriptor 

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

func (*Job_NullableTime) GetHasValue 

func (m *Job_NullableTime) GetHasValue() bool

func (*Job_NullableTime) GetTime 

func (m *Job_NullableTime) GetTime() *timestamp.Timestamp

func (*Job_NullableTime) ProtoMessage 

func (*Job_NullableTime) ProtoMessage()

func (*Job_NullableTime) Reset 

func (m *Job_NullableTime) Reset()

func (*Job_NullableTime) String 

func (m *Job_NullableTime) String() string

func (*Job_NullableTime) XXX_DiscardUnknown 

func (m *Job_NullableTime) XXX_DiscardUnknown()

func (*Job_NullableTime) XXX_Marshal 

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

func (*Job_NullableTime) XXX_Merge 

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

func (*Job_NullableTime) XXX_Size 

func (m *Job_NullableTime) XXX_Size() int

func (*Job_NullableTime) XXX_Unmarshal 

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

type PluginConfig 

type PluginConfig struct {
	Config               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PluginConfig) Descriptor 

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

func (*PluginConfig) GetConfig 

func (m *PluginConfig) GetConfig() map[string]string

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) Reset 

func (m *PluginConfig) Reset()

func (*PluginConfig) String 

func (m *PluginConfig) String() string

func (*PluginConfig) XXX_DiscardUnknown 

func (m *PluginConfig) XXX_DiscardUnknown()

func (*PluginConfig) XXX_Marshal 

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

func (*PluginConfig) XXX_Merge 

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

func (*PluginConfig) XXX_Size 

func (m *PluginConfig) XXX_Size() int

func (*PluginConfig) XXX_Unmarshal 

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

type RaftGetConfigurationResponse 

type RaftGetConfigurationResponse struct {
	Servers              []*RaftServer `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	Index                uint64        `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RaftGetConfigurationResponse) Descriptor 

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

func (*RaftGetConfigurationResponse) GetIndex 

func (m *RaftGetConfigurationResponse) GetIndex() uint64

func (*RaftGetConfigurationResponse) GetServers 

func (m *RaftGetConfigurationResponse) GetServers() []*RaftServer

func (*RaftGetConfigurationResponse) ProtoMessage 

func (*RaftGetConfigurationResponse) ProtoMessage()

func (*RaftGetConfigurationResponse) Reset 

func (m *RaftGetConfigurationResponse) Reset()

func (*RaftGetConfigurationResponse) String 

func (m *RaftGetConfigurationResponse) String() string

func (*RaftGetConfigurationResponse) XXX_DiscardUnknown 

func (m *RaftGetConfigurationResponse) XXX_DiscardUnknown()

func (*RaftGetConfigurationResponse) XXX_Marshal 

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

func (*RaftGetConfigurationResponse) XXX_Merge 

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

func (*RaftGetConfigurationResponse) XXX_Size 

func (m *RaftGetConfigurationResponse) XXX_Size() int

func (*RaftGetConfigurationResponse) XXX_Unmarshal 

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

type RaftRemovePeerByIDRequest 

type RaftRemovePeerByIDRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftRemovePeerByIDRequest) Descriptor 

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

func (*RaftRemovePeerByIDRequest) GetId 

func (m *RaftRemovePeerByIDRequest) GetId() string

func (*RaftRemovePeerByIDRequest) ProtoMessage 

func (*RaftRemovePeerByIDRequest) ProtoMessage()

func (*RaftRemovePeerByIDRequest) Reset 

func (m *RaftRemovePeerByIDRequest) Reset()

func (*RaftRemovePeerByIDRequest) String 

func (m *RaftRemovePeerByIDRequest) String() string

func (*RaftRemovePeerByIDRequest) XXX_DiscardUnknown 

func (m *RaftRemovePeerByIDRequest) XXX_DiscardUnknown()

func (*RaftRemovePeerByIDRequest) XXX_Marshal 

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

func (*RaftRemovePeerByIDRequest) XXX_Merge 

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

func (*RaftRemovePeerByIDRequest) XXX_Size 

func (m *RaftRemovePeerByIDRequest) XXX_Size() int

func (*RaftRemovePeerByIDRequest) XXX_Unmarshal 

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

type RaftServer 

type RaftServer struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Node                 string   `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Address              string   `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Leader               bool     `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"`
	Voter                bool     `protobuf:"varint,5,opt,name=voter,proto3" json:"voter,omitempty"`
	RaftProtocol         string   `protobuf:"bytes,6,opt,name=raft_protocol,json=raftProtocol,proto3" json:"raft_protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftServer) Descriptor 

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

func (*RaftServer) GetAddress 

func (m *RaftServer) GetAddress() string

func (*RaftServer) GetId 

func (m *RaftServer) GetId() string

func (*RaftServer) GetLeader 

func (m *RaftServer) GetLeader() bool

func (*RaftServer) GetNode 

func (m *RaftServer) GetNode() string

func (*RaftServer) GetRaftProtocol 

func (m *RaftServer) GetRaftProtocol() string

func (*RaftServer) GetVoter 

func (m *RaftServer) GetVoter() bool

func (*RaftServer) ProtoMessage 

func (*RaftServer) ProtoMessage()

func (*RaftServer) Reset 

func (m *RaftServer) Reset()

func (*RaftServer) String 

func (m *RaftServer) String() string

func (*RaftServer) XXX_DiscardUnknown 

func (m *RaftServer) XXX_DiscardUnknown()

func (*RaftServer) XXX_Marshal 

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

func (*RaftServer) XXX_Merge 

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

func (*RaftServer) XXX_Size 

func (m *RaftServer) XXX_Size() int

func (*RaftServer) XXX_Unmarshal 

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

type RunJobRequest 

type RunJobRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunJobRequest) Descriptor 

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

func (*RunJobRequest) GetJobName 

func (m *RunJobRequest) GetJobName() string

func (*RunJobRequest) ProtoMessage 

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) Reset 

func (m *RunJobRequest) Reset()

func (*RunJobRequest) String 

func (m *RunJobRequest) String() string

func (*RunJobRequest) XXX_DiscardUnknown 

func (m *RunJobRequest) XXX_DiscardUnknown()

func (*RunJobRequest) XXX_Marshal 

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

func (*RunJobRequest) XXX_Merge 

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

func (*RunJobRequest) XXX_Size 

func (m *RunJobRequest) XXX_Size() int

func (*RunJobRequest) XXX_Unmarshal 

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

type RunJobResponse 

type RunJobResponse 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 (*RunJobResponse) Descriptor 

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

func (*RunJobResponse) GetJob 

func (m *RunJobResponse) GetJob() *Job

func (*RunJobResponse) ProtoMessage 

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) Reset 

func (m *RunJobResponse) Reset()

func (*RunJobResponse) String 

func (m *RunJobResponse) String() string

func (*RunJobResponse) XXX_DiscardUnknown 

func (m *RunJobResponse) XXX_DiscardUnknown()

func (*RunJobResponse) XXX_Marshal 

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

func (*RunJobResponse) XXX_Merge 

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

func (*RunJobResponse) XXX_Size 

func (m *RunJobResponse) XXX_Size() int

func (*RunJobResponse) XXX_Unmarshal 

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

type SetJobRequest 

type SetJobRequest 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 (*SetJobRequest) Descriptor 

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

func (*SetJobRequest) GetJob 

func (m *SetJobRequest) GetJob() *Job

func (*SetJobRequest) ProtoMessage 

func (*SetJobRequest) ProtoMessage()

func (*SetJobRequest) Reset 

func (m *SetJobRequest) Reset()

func (*SetJobRequest) String 

func (m *SetJobRequest) String() string

func (*SetJobRequest) XXX_DiscardUnknown 

func (m *SetJobRequest) XXX_DiscardUnknown()

func (*SetJobRequest) XXX_Marshal 

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

func (*SetJobRequest) XXX_Merge 

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

func (*SetJobRequest) XXX_Size 

func (m *SetJobRequest) XXX_Size() int

func (*SetJobRequest) XXX_Unmarshal 

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

type SetJobResponse 

type SetJobResponse 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 (*SetJobResponse) Descriptor 

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

func (*SetJobResponse) GetJob 

func (m *SetJobResponse) GetJob() *Job

func (*SetJobResponse) ProtoMessage 

func (*SetJobResponse) ProtoMessage()

func (*SetJobResponse) Reset 

func (m *SetJobResponse) Reset()

func (*SetJobResponse) String 

func (m *SetJobResponse) String() string

func (*SetJobResponse) XXX_DiscardUnknown 

func (m *SetJobResponse) XXX_DiscardUnknown()

func (*SetJobResponse) XXX_Marshal 

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

func (*SetJobResponse) XXX_Merge 

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

func (*SetJobResponse) XXX_Size 

func (m *SetJobResponse) XXX_Size() int

func (*SetJobResponse) XXX_Unmarshal 

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

type StatusHelperClient 

type StatusHelperClient interface {
	Update(ctx context.Context, in *StatusUpdateRequest, opts ...grpc.CallOption) (*StatusUpdateResponse, error)
}

StatusHelperClient is the client API for StatusHelper service.

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

func NewStatusHelperClient 

func NewStatusHelperClient(cc grpc.ClientConnInterface) StatusHelperClient

type StatusHelperServer 

type StatusHelperServer interface {
	Update(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, error)
}

StatusHelperServer is the server API for StatusHelper service.

type StatusUpdateRequest 

type StatusUpdateRequest struct {
	Output               []byte   `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Error                bool     `protobuf:"varint,3,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusUpdateRequest) Descriptor 

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

func (*StatusUpdateRequest) GetError 

func (m *StatusUpdateRequest) GetError() bool

func (*StatusUpdateRequest) GetOutput 

func (m *StatusUpdateRequest) GetOutput() []byte

func (*StatusUpdateRequest) ProtoMessage 

func (*StatusUpdateRequest) ProtoMessage()

func (*StatusUpdateRequest) Reset 

func (m *StatusUpdateRequest) Reset()

func (*StatusUpdateRequest) String 

func (m *StatusUpdateRequest) String() string

func (*StatusUpdateRequest) XXX_DiscardUnknown 

func (m *StatusUpdateRequest) XXX_DiscardUnknown()

func (*StatusUpdateRequest) XXX_Marshal 

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

func (*StatusUpdateRequest) XXX_Merge 

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

func (*StatusUpdateRequest) XXX_Size 

func (m *StatusUpdateRequest) XXX_Size() int

func (*StatusUpdateRequest) XXX_Unmarshal 

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

type StatusUpdateResponse 

type StatusUpdateResponse struct {
	R                    int64    `protobuf:"varint,1,opt,name=r,proto3" json:"r,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusUpdateResponse) Descriptor 

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

func (*StatusUpdateResponse) GetR 

func (m *StatusUpdateResponse) GetR() int64

func (*StatusUpdateResponse) ProtoMessage 

func (*StatusUpdateResponse) ProtoMessage()

func (*StatusUpdateResponse) Reset 

func (m *StatusUpdateResponse) Reset()

func (*StatusUpdateResponse) String 

func (m *StatusUpdateResponse) String() string

func (*StatusUpdateResponse) XXX_DiscardUnknown 

func (m *StatusUpdateResponse) XXX_DiscardUnknown()

func (*StatusUpdateResponse) XXX_Marshal 

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

func (*StatusUpdateResponse) XXX_Merge 

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

func (*StatusUpdateResponse) XXX_Size 

func (m *StatusUpdateResponse) XXX_Size() int

func (*StatusUpdateResponse) XXX_Unmarshal 

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

type ToggleJobRequest 

type ToggleJobRequest struct {
	JobName              string   `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ToggleJobRequest) Descriptor 

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

func (*ToggleJobRequest) GetJobName 

func (m *ToggleJobRequest) GetJobName() string

func (*ToggleJobRequest) ProtoMessage 

func (*ToggleJobRequest) ProtoMessage()

func (*ToggleJobRequest) Reset 

func (m *ToggleJobRequest) Reset()

func (*ToggleJobRequest) String 

func (m *ToggleJobRequest) String() string

func (*ToggleJobRequest) XXX_DiscardUnknown 

func (m *ToggleJobRequest) XXX_DiscardUnknown()

func (*ToggleJobRequest) XXX_Marshal 

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

func (*ToggleJobRequest) XXX_Merge 

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

func (*ToggleJobRequest) XXX_Size 

func (m *ToggleJobRequest) XXX_Size() int

func (*ToggleJobRequest) XXX_Unmarshal 

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

type ToggleJobResponse 

type ToggleJobResponse 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 (*ToggleJobResponse) Descriptor 

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

func (*ToggleJobResponse) GetJob 

func (m *ToggleJobResponse) GetJob() *Job

func (*ToggleJobResponse) ProtoMessage 

func (*ToggleJobResponse) ProtoMessage()

func (*ToggleJobResponse) Reset 

func (m *ToggleJobResponse) Reset()

func (*ToggleJobResponse) String 

func (m *ToggleJobResponse) String() string

func (*ToggleJobResponse) XXX_DiscardUnknown 

func (m *ToggleJobResponse) XXX_DiscardUnknown()

func (*ToggleJobResponse) XXX_Marshal 

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

func (*ToggleJobResponse) XXX_Merge 

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

func (*ToggleJobResponse) XXX_Size 

func (m *ToggleJobResponse) XXX_Size() int

func (*ToggleJobResponse) XXX_Unmarshal 

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

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer can be embedded to have forward compatible implementations.

func (*UnimplementedAgentServer) AgentRun 

func (*UnimplementedAgentServer) AgentRun(req *AgentRunRequest, srv Agent_AgentRunServer) error

type UnimplementedDkronServer 

type UnimplementedDkronServer struct {
}

UnimplementedDkronServer can be embedded to have forward compatible implementations.

func (*UnimplementedDkronServer) DeleteJob 

func (*UnimplementedDkronServer) DeleteJob(ctx context.Context, req *DeleteJobRequest) (*DeleteJobResponse, error)

func (*UnimplementedDkronServer) ExecutionDone 

func (*UnimplementedDkronServer) ExecutionDone(ctx context.Context, req *ExecutionDoneRequest) (*ExecutionDoneResponse, error)

func (*UnimplementedDkronServer) GetActiveExecutions 

func (*UnimplementedDkronServer) GetActiveExecutions(ctx context.Context, req *empty.Empty) (*GetActiveExecutionsResponse, error)

func (*UnimplementedDkronServer) GetJob 

func (*UnimplementedDkronServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)

func (*UnimplementedDkronServer) Leave 

func (*UnimplementedDkronServer) Leave(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

func (*UnimplementedDkronServer) RaftGetConfiguration 

func (*UnimplementedDkronServer) RaftGetConfiguration(ctx context.Context, req *empty.Empty) (*RaftGetConfigurationResponse, error)

func (*UnimplementedDkronServer) RaftRemovePeerByID 

func (*UnimplementedDkronServer) RaftRemovePeerByID(ctx context.Context, req *RaftRemovePeerByIDRequest) (*empty.Empty, error)

func (*UnimplementedDkronServer) RunJob 

func (*UnimplementedDkronServer) RunJob(ctx context.Context, req *RunJobRequest) (*RunJobResponse, error)

func (*UnimplementedDkronServer) SetExecution 

func (*UnimplementedDkronServer) SetExecution(ctx context.Context, req *Execution) (*empty.Empty, error)

func (*UnimplementedDkronServer) SetJob 

func (*UnimplementedDkronServer) SetJob(ctx context.Context, req *SetJobRequest) (*SetJobResponse, error)

func (*UnimplementedDkronServer) ToggleJob 

func (*UnimplementedDkronServer) ToggleJob(ctx context.Context, req *ToggleJobRequest) (*ToggleJobResponse, error)

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) Execute 

func (*UnimplementedExecutorServer) Execute(ctx context.Context, req *ExecuteRequest) (*ExecuteResponse, error)

type UnimplementedStatusHelperServer 

type UnimplementedStatusHelperServer struct {
}

UnimplementedStatusHelperServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatusHelperServer) Update 

func (*UnimplementedStatusHelperServer) Update(ctx context.Context, req *StatusUpdateRequest) (*StatusUpdateResponse, error)

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.