types

package
v3.2.7 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2023 License: LGPL-3.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_dkron_proto protoreflect.FileDescriptor
View Source 
var File_executor_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

func RegisterDkronServer 

func RegisterDkronServer(s grpc.ServiceRegistrar, srv DkronServer)

func RegisterExecutorServer 

func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer)

func RegisterStatusHelperServer 

func RegisterStatusHelperServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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"`
	// contains filtered or unexported fields
}

func (*AgentRunRequest) Descriptor deprecated 

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

Deprecated: Use AgentRunRequest.ProtoReflect.Descriptor instead.

func (*AgentRunRequest) GetExecution 

func (x *AgentRunRequest) GetExecution() *Execution

func (*AgentRunRequest) GetJob 

func (x *AgentRunRequest) GetJob() *Job

func (*AgentRunRequest) ProtoMessage 

func (*AgentRunRequest) ProtoMessage()

func (*AgentRunRequest) ProtoReflect added in v3.1.0 

func (x *AgentRunRequest) ProtoReflect() protoreflect.Message

func (*AgentRunRequest) Reset 

func (x *AgentRunRequest) Reset()

func (*AgentRunRequest) String 

func (x *AgentRunRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*AgentRunResponse) Descriptor deprecated 

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

Deprecated: Use AgentRunResponse.ProtoReflect.Descriptor instead.

func (*AgentRunResponse) GetFrom 

func (x *AgentRunResponse) GetFrom() string

func (*AgentRunResponse) GetPayload 

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

func (*AgentRunResponse) ProtoMessage 

func (*AgentRunResponse) ProtoMessage()

func (*AgentRunResponse) ProtoReflect added in v3.1.0 

func (x *AgentRunResponse) ProtoReflect() protoreflect.Message

func (*AgentRunResponse) Reset 

func (x *AgentRunResponse) Reset()

func (*AgentRunResponse) String 

func (x *AgentRunResponse) String() string

type AgentRunStream 

type AgentRunStream struct {
	Execution *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentRunStream) Descriptor deprecated 

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

Deprecated: Use AgentRunStream.ProtoReflect.Descriptor instead.

func (*AgentRunStream) GetExecution 

func (x *AgentRunStream) GetExecution() *Execution

func (*AgentRunStream) ProtoMessage 

func (*AgentRunStream) ProtoMessage()

func (*AgentRunStream) ProtoReflect added in v3.1.0 

func (x *AgentRunStream) ProtoReflect() protoreflect.Message

func (*AgentRunStream) Reset 

func (x *AgentRunStream) Reset()

func (*AgentRunStream) String 

func (x *AgentRunStream) String() string

type AgentServer 

type AgentServer interface {
	AgentRun(*AgentRunRequest, Agent_AgentRunServer) error
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*DeleteJobRequest) Descriptor deprecated 

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetJobName 

func (x *DeleteJobRequest) GetJobName() string

func (*DeleteJobRequest) ProtoMessage 

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect added in v3.1.0 

func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message

func (*DeleteJobRequest) Reset 

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String 

func (x *DeleteJobRequest) String() string

type DeleteJobResponse 

type DeleteJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteJobResponse) Descriptor deprecated 

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

Deprecated: Use DeleteJobResponse.ProtoReflect.Descriptor instead.

func (*DeleteJobResponse) GetJob 

func (x *DeleteJobResponse) GetJob() *Job

func (*DeleteJobResponse) ProtoMessage 

func (*DeleteJobResponse) ProtoMessage()

func (*DeleteJobResponse) ProtoReflect added in v3.1.0 

func (x *DeleteJobResponse) ProtoReflect() protoreflect.Message

func (*DeleteJobResponse) Reset 

func (x *DeleteJobResponse) Reset()

func (*DeleteJobResponse) String 

func (x *DeleteJobResponse) String() string

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 *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.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 *emptypb.Empty, opts ...grpc.CallOption) (*RaftGetConfigurationResponse, error)
	RaftRemovePeerByID(ctx context.Context, in *RaftRemovePeerByIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	GetActiveExecutions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetActiveExecutionsResponse, error)
	SetExecution(ctx context.Context, in *Execution, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DkronClient is the client API for Dkron service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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, *emptypb.Empty) (*emptypb.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, *emptypb.Empty) (*RaftGetConfigurationResponse, error)
	RaftRemovePeerByID(context.Context, *RaftRemovePeerByIDRequest) (*emptypb.Empty, error)
	GetActiveExecutions(context.Context, *emptypb.Empty) (*GetActiveExecutionsResponse, error)
	SetExecution(context.Context, *Execution) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DkronServer is the server API for Dkron service. All implementations must embed UnimplementedDkronServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetConfig 

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

func (*ExecuteRequest) GetJobName 

func (x *ExecuteRequest) GetJobName() string

func (*ExecuteRequest) GetStatusServer 

func (x *ExecuteRequest) GetStatusServer() uint32

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect added in v3.1.0 

func (x *ExecuteRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetError 

func (x *ExecuteResponse) GetError() string

func (*ExecuteResponse) GetOutput 

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

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect added in v3.1.0 

func (x *ExecuteResponse) ProtoReflect() protoreflect.Message

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

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  *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Execution) Descriptor deprecated 

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetAttempt 

func (x *Execution) GetAttempt() uint32

func (*Execution) GetFinishedAt 

func (x *Execution) GetFinishedAt() *timestamppb.Timestamp

func (*Execution) GetGroup 

func (x *Execution) GetGroup() int64

func (*Execution) GetJobName 

func (x *Execution) GetJobName() string

func (*Execution) GetNodeName 

func (x *Execution) GetNodeName() string

func (*Execution) GetOutput 

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

func (*Execution) GetStartedAt 

func (x *Execution) GetStartedAt() *timestamppb.Timestamp

func (*Execution) GetSuccess 

func (x *Execution) GetSuccess() bool

func (*Execution) Key 

func (e *Execution) Key() string

Key computes the execution key

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect added in v3.1.0 

func (x *Execution) ProtoReflect() protoreflect.Message

func (*Execution) Reset 

func (x *Execution) Reset()

func (*Execution) String 

func (x *Execution) String() string

type ExecutionDoneRequest 

type ExecutionDoneRequest struct {
	Execution *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionDoneRequest) Descriptor deprecated 

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

Deprecated: Use ExecutionDoneRequest.ProtoReflect.Descriptor instead.

func (*ExecutionDoneRequest) GetExecution 

func (x *ExecutionDoneRequest) GetExecution() *Execution

func (*ExecutionDoneRequest) ProtoMessage 

func (*ExecutionDoneRequest) ProtoMessage()

func (*ExecutionDoneRequest) ProtoReflect added in v3.1.0 

func (x *ExecutionDoneRequest) ProtoReflect() protoreflect.Message

func (*ExecutionDoneRequest) Reset 

func (x *ExecutionDoneRequest) Reset()

func (*ExecutionDoneRequest) String 

func (x *ExecutionDoneRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ExecutionDoneResponse) Descriptor deprecated 

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

Deprecated: Use ExecutionDoneResponse.ProtoReflect.Descriptor instead.

func (*ExecutionDoneResponse) GetFrom 

func (x *ExecutionDoneResponse) GetFrom() string

func (*ExecutionDoneResponse) GetPayload 

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

func (*ExecutionDoneResponse) ProtoMessage 

func (*ExecutionDoneResponse) ProtoMessage()

func (*ExecutionDoneResponse) ProtoReflect added in v3.1.0 

func (x *ExecutionDoneResponse) ProtoReflect() protoreflect.Message

func (*ExecutionDoneResponse) Reset 

func (x *ExecutionDoneResponse) Reset()

func (*ExecutionDoneResponse) String 

func (x *ExecutionDoneResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewExecutorClient 

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// contains filtered or unexported methods
}

ExecutorServer is the server API for Executor service. All implementations must embed UnimplementedExecutorServer for forward compatibility

type GetActiveExecutionsResponse 

type GetActiveExecutionsResponse struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActiveExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use GetActiveExecutionsResponse.ProtoReflect.Descriptor instead.

func (*GetActiveExecutionsResponse) GetExecutions 

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

func (*GetActiveExecutionsResponse) ProtoMessage 

func (*GetActiveExecutionsResponse) ProtoMessage()

func (*GetActiveExecutionsResponse) ProtoReflect added in v3.1.0 

func (x *GetActiveExecutionsResponse) ProtoReflect() protoreflect.Message

func (*GetActiveExecutionsResponse) Reset 

func (x *GetActiveExecutionsResponse) Reset()

func (*GetActiveExecutionsResponse) String 

func (x *GetActiveExecutionsResponse) String() string

type GetJobRequest 

type GetJobRequest struct {
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobName 

func (x *GetJobRequest) GetJobName() string

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect added in v3.1.0 

func (x *GetJobRequest) ProtoReflect() protoreflect.Message

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect added in v3.1.0 

func (x *GetJobResponse) ProtoReflect() protoreflect.Message

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

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           *timestamppb.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 */
	Ephemeral      bool                     `protobuf:"varint,28,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	ExpiresAt      *Job_NullableTime        `protobuf:"bytes,29,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetConcurrency 

func (x *Job) GetConcurrency() string

func (*Job) GetDependentJobs 

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

func (*Job) GetDisabled 

func (x *Job) GetDisabled() bool

func (*Job) GetDisplayname 

func (x *Job) GetDisplayname() string

func (*Job) GetEphemeral added in v3.1.7 

func (x *Job) GetEphemeral() bool

func (*Job) GetErrorCount 

func (x *Job) GetErrorCount() int32

func (*Job) GetExecutor 

func (x *Job) GetExecutor() string

func (*Job) GetExecutorConfig 

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

func (*Job) GetExpiresAt added in v3.1.7 

func (x *Job) GetExpiresAt() *Job_NullableTime

func (*Job) GetLastError 

func (x *Job) GetLastError() *Job_NullableTime

func (*Job) GetLastSuccess 

func (x *Job) GetLastSuccess() *Job_NullableTime

func (*Job) GetMetadata 

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

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetNext 

func (x *Job) GetNext() *timestamppb.Timestamp

func (*Job) GetOwner 

func (x *Job) GetOwner() string

func (*Job) GetOwnerEmail 

func (x *Job) GetOwnerEmail() string

func (*Job) GetParentJob 

func (x *Job) GetParentJob() string

func (*Job) GetProcessors 

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

func (*Job) GetRetries 

func (x *Job) GetRetries() uint32

func (*Job) GetSchedule 

func (x *Job) GetSchedule() string

func (*Job) GetStatus 

func (x *Job) GetStatus() string

func (*Job) GetSuccessCount 

func (x *Job) GetSuccessCount() int32

func (*Job) GetTags 

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

func (*Job) GetTimezone 

func (x *Job) GetTimezone() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect added in v3.1.0 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type Job_NullableTime 

type Job_NullableTime struct {
	HasValue bool                   `protobuf:"varint,1,opt,name=has_value,json=hasValue,proto3" json:"has_value,omitempty"`
	Time     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*Job_NullableTime) Descriptor deprecated 

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

Deprecated: Use Job_NullableTime.ProtoReflect.Descriptor instead.

func (*Job_NullableTime) GetHasValue 

func (x *Job_NullableTime) GetHasValue() bool

func (*Job_NullableTime) GetTime 

func (x *Job_NullableTime) GetTime() *timestamppb.Timestamp

func (*Job_NullableTime) ProtoMessage 

func (*Job_NullableTime) ProtoMessage()

func (*Job_NullableTime) ProtoReflect added in v3.1.0 

func (x *Job_NullableTime) ProtoReflect() protoreflect.Message

func (*Job_NullableTime) Reset 

func (x *Job_NullableTime) Reset()

func (*Job_NullableTime) String 

func (x *Job_NullableTime) String() string

type PluginConfig 

type PluginConfig struct {
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PluginConfig) Descriptor deprecated 

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

Deprecated: Use PluginConfig.ProtoReflect.Descriptor instead.

func (*PluginConfig) GetConfig 

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

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) ProtoReflect added in v3.1.0 

func (x *PluginConfig) ProtoReflect() protoreflect.Message

func (*PluginConfig) Reset 

func (x *PluginConfig) Reset()

func (*PluginConfig) String 

func (x *PluginConfig) String() string

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"`
	// contains filtered or unexported fields
}

func (*RaftGetConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use RaftGetConfigurationResponse.ProtoReflect.Descriptor instead.

func (*RaftGetConfigurationResponse) GetIndex 

func (x *RaftGetConfigurationResponse) GetIndex() uint64

func (*RaftGetConfigurationResponse) GetServers 

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

func (*RaftGetConfigurationResponse) ProtoMessage 

func (*RaftGetConfigurationResponse) ProtoMessage()

func (*RaftGetConfigurationResponse) ProtoReflect added in v3.1.0 

func (x *RaftGetConfigurationResponse) ProtoReflect() protoreflect.Message

func (*RaftGetConfigurationResponse) Reset 

func (x *RaftGetConfigurationResponse) Reset()

func (*RaftGetConfigurationResponse) String 

func (x *RaftGetConfigurationResponse) String() string

type RaftRemovePeerByIDRequest 

type RaftRemovePeerByIDRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftRemovePeerByIDRequest) Descriptor deprecated 

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

Deprecated: Use RaftRemovePeerByIDRequest.ProtoReflect.Descriptor instead.

func (*RaftRemovePeerByIDRequest) GetId 

func (x *RaftRemovePeerByIDRequest) GetId() string

func (*RaftRemovePeerByIDRequest) ProtoMessage 

func (*RaftRemovePeerByIDRequest) ProtoMessage()

func (*RaftRemovePeerByIDRequest) ProtoReflect added in v3.1.0 

func (x *RaftRemovePeerByIDRequest) ProtoReflect() protoreflect.Message

func (*RaftRemovePeerByIDRequest) Reset 

func (x *RaftRemovePeerByIDRequest) Reset()

func (*RaftRemovePeerByIDRequest) String 

func (x *RaftRemovePeerByIDRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*RaftServer) Descriptor deprecated 

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

Deprecated: Use RaftServer.ProtoReflect.Descriptor instead.

func (*RaftServer) GetAddress 

func (x *RaftServer) GetAddress() string

func (*RaftServer) GetId 

func (x *RaftServer) GetId() string

func (*RaftServer) GetLeader 

func (x *RaftServer) GetLeader() bool

func (*RaftServer) GetNode 

func (x *RaftServer) GetNode() string

func (*RaftServer) GetRaftProtocol 

func (x *RaftServer) GetRaftProtocol() string

func (*RaftServer) GetVoter 

func (x *RaftServer) GetVoter() bool

func (*RaftServer) ProtoMessage 

func (*RaftServer) ProtoMessage()

func (*RaftServer) ProtoReflect added in v3.1.0 

func (x *RaftServer) ProtoReflect() protoreflect.Message

func (*RaftServer) Reset 

func (x *RaftServer) Reset()

func (*RaftServer) String 

func (x *RaftServer) String() string

type RunJobRequest 

type RunJobRequest struct {
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*RunJobRequest) Descriptor deprecated 

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

Deprecated: Use RunJobRequest.ProtoReflect.Descriptor instead.

func (*RunJobRequest) GetJobName 

func (x *RunJobRequest) GetJobName() string

func (*RunJobRequest) ProtoMessage 

func (*RunJobRequest) ProtoMessage()

func (*RunJobRequest) ProtoReflect added in v3.1.0 

func (x *RunJobRequest) ProtoReflect() protoreflect.Message

func (*RunJobRequest) Reset 

func (x *RunJobRequest) Reset()

func (*RunJobRequest) String 

func (x *RunJobRequest) String() string

type RunJobResponse 

type RunJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*RunJobResponse) Descriptor deprecated 

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

Deprecated: Use RunJobResponse.ProtoReflect.Descriptor instead.

func (*RunJobResponse) GetJob 

func (x *RunJobResponse) GetJob() *Job

func (*RunJobResponse) ProtoMessage 

func (*RunJobResponse) ProtoMessage()

func (*RunJobResponse) ProtoReflect added in v3.1.0 

func (x *RunJobResponse) ProtoReflect() protoreflect.Message

func (*RunJobResponse) Reset 

func (x *RunJobResponse) Reset()

func (*RunJobResponse) String 

func (x *RunJobResponse) String() string

type SetJobRequest 

type SetJobRequest struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*SetJobRequest) Descriptor deprecated 

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

Deprecated: Use SetJobRequest.ProtoReflect.Descriptor instead.

func (*SetJobRequest) GetJob 

func (x *SetJobRequest) GetJob() *Job

func (*SetJobRequest) ProtoMessage 

func (*SetJobRequest) ProtoMessage()

func (*SetJobRequest) ProtoReflect added in v3.1.0 

func (x *SetJobRequest) ProtoReflect() protoreflect.Message

func (*SetJobRequest) Reset 

func (x *SetJobRequest) Reset()

func (*SetJobRequest) String 

func (x *SetJobRequest) String() string

type SetJobResponse 

type SetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*SetJobResponse) Descriptor deprecated 

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

Deprecated: Use SetJobResponse.ProtoReflect.Descriptor instead.

func (*SetJobResponse) GetJob 

func (x *SetJobResponse) GetJob() *Job

func (*SetJobResponse) ProtoMessage 

func (*SetJobResponse) ProtoMessage()

func (*SetJobResponse) ProtoReflect added in v3.1.0 

func (x *SetJobResponse) ProtoReflect() protoreflect.Message

func (*SetJobResponse) Reset 

func (x *SetJobResponse) Reset()

func (*SetJobResponse) String 

func (x *SetJobResponse) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStatusHelperClient 

func NewStatusHelperClient(cc grpc.ClientConnInterface) StatusHelperClient

type StatusHelperServer 

type StatusHelperServer interface {
	Update(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, error)
	// contains filtered or unexported methods
}

StatusHelperServer is the server API for StatusHelper service. All implementations must embed UnimplementedStatusHelperServer for forward compatibility

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"`
	// contains filtered or unexported fields
}

func (*StatusUpdateRequest) Descriptor deprecated 

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

Deprecated: Use StatusUpdateRequest.ProtoReflect.Descriptor instead.

func (*StatusUpdateRequest) GetError 

func (x *StatusUpdateRequest) GetError() bool

func (*StatusUpdateRequest) GetOutput 

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

func (*StatusUpdateRequest) ProtoMessage 

func (*StatusUpdateRequest) ProtoMessage()

func (*StatusUpdateRequest) ProtoReflect added in v3.1.0 

func (x *StatusUpdateRequest) ProtoReflect() protoreflect.Message

func (*StatusUpdateRequest) Reset 

func (x *StatusUpdateRequest) Reset()

func (*StatusUpdateRequest) String 

func (x *StatusUpdateRequest) String() string

type StatusUpdateResponse 

type StatusUpdateResponse struct {
	R int64 `protobuf:"varint,1,opt,name=r,proto3" json:"r,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusUpdateResponse) Descriptor deprecated 

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

Deprecated: Use StatusUpdateResponse.ProtoReflect.Descriptor instead.

func (*StatusUpdateResponse) GetR 

func (x *StatusUpdateResponse) GetR() int64

func (*StatusUpdateResponse) ProtoMessage 

func (*StatusUpdateResponse) ProtoMessage()

func (*StatusUpdateResponse) ProtoReflect added in v3.1.0 

func (x *StatusUpdateResponse) ProtoReflect() protoreflect.Message

func (*StatusUpdateResponse) Reset 

func (x *StatusUpdateResponse) Reset()

func (*StatusUpdateResponse) String 

func (x *StatusUpdateResponse) String() string

type ToggleJobRequest 

type ToggleJobRequest struct {
	JobName string `protobuf:"bytes,1,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleJobRequest) Descriptor deprecated 

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

Deprecated: Use ToggleJobRequest.ProtoReflect.Descriptor instead.

func (*ToggleJobRequest) GetJobName 

func (x *ToggleJobRequest) GetJobName() string

func (*ToggleJobRequest) ProtoMessage 

func (*ToggleJobRequest) ProtoMessage()

func (*ToggleJobRequest) ProtoReflect added in v3.1.0 

func (x *ToggleJobRequest) ProtoReflect() protoreflect.Message

func (*ToggleJobRequest) Reset 

func (x *ToggleJobRequest) Reset()

func (*ToggleJobRequest) String 

func (x *ToggleJobRequest) String() string

type ToggleJobResponse 

type ToggleJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*ToggleJobResponse) Descriptor deprecated 

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

Deprecated: Use ToggleJobResponse.ProtoReflect.Descriptor instead.

func (*ToggleJobResponse) GetJob 

func (x *ToggleJobResponse) GetJob() *Job

func (*ToggleJobResponse) ProtoMessage 

func (*ToggleJobResponse) ProtoMessage()

func (*ToggleJobResponse) ProtoReflect added in v3.1.0 

func (x *ToggleJobResponse) ProtoReflect() protoreflect.Message

func (*ToggleJobResponse) Reset 

func (x *ToggleJobResponse) Reset()

func (*ToggleJobResponse) String 

func (x *ToggleJobResponse) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) AgentRun 

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

type UnimplementedDkronServer 

type UnimplementedDkronServer struct {
}

UnimplementedDkronServer must be embedded to have forward compatible implementations.

func (UnimplementedDkronServer) DeleteJob 

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

func (UnimplementedDkronServer) ExecutionDone 

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

func (UnimplementedDkronServer) GetActiveExecutions 

func (UnimplementedDkronServer) GetActiveExecutions(context.Context, *emptypb.Empty) (*GetActiveExecutionsResponse, error)

func (UnimplementedDkronServer) GetJob 

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

func (UnimplementedDkronServer) Leave 

func (UnimplementedDkronServer) Leave(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (UnimplementedDkronServer) RaftGetConfiguration 

func (UnimplementedDkronServer) RaftGetConfiguration(context.Context, *emptypb.Empty) (*RaftGetConfigurationResponse, error)

func (UnimplementedDkronServer) RaftRemovePeerByID 

func (UnimplementedDkronServer) RaftRemovePeerByID(context.Context, *RaftRemovePeerByIDRequest) (*emptypb.Empty, error)

func (UnimplementedDkronServer) RunJob 

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

func (UnimplementedDkronServer) SetExecution 

func (UnimplementedDkronServer) SetExecution(context.Context, *Execution) (*emptypb.Empty, error)

func (UnimplementedDkronServer) SetJob 

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

func (UnimplementedDkronServer) ToggleJob 

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

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServer) Execute 

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

type UnimplementedStatusHelperServer 

type UnimplementedStatusHelperServer struct {
}

UnimplementedStatusHelperServer must be embedded to have forward compatible implementations.

func (UnimplementedStatusHelperServer) Update 

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

type UnsafeAgentServer added in v3.1.0 

type UnsafeAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.

type UnsafeDkronServer added in v3.1.0 

type UnsafeDkronServer interface {
	// contains filtered or unexported methods
}

UnsafeDkronServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DkronServer will result in compilation errors.

type UnsafeExecutorServer added in v3.1.0 

type UnsafeExecutorServer interface {
	// contains filtered or unexported methods
}

UnsafeExecutorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExecutorServer will result in compilation errors.

type UnsafeStatusHelperServer added in v3.1.0 

type UnsafeStatusHelperServer interface {
	// contains filtered or unexported methods
}

UnsafeStatusHelperServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StatusHelperServer will result in compilation errors.

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.