Versions in this module Expand all Collapse all v4 v4.0.2 Jan 5, 2025 v4.0.1 Dec 22, 2024 v4.0.0 Oct 27, 2024 Changes in this version + var Agent_ServiceDesc = grpc.ServiceDesc + var DkronPro_ServiceDesc = grpc.ServiceDesc + var Dkron_ServiceDesc = grpc.ServiceDesc + var Executor_ServiceDesc = grpc.ServiceDesc + var File_dkron_proto protoreflect.FileDescriptor + var File_executor_proto protoreflect.FileDescriptor + var File_pro_proto protoreflect.FileDescriptor + var StatusHelper_ServiceDesc = grpc.ServiceDesc + var TokenType_name = map[int32]string + var TokenType_value = map[string]int32 + func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer) + func RegisterDkronProServer(s grpc.ServiceRegistrar, srv DkronProServer) + func RegisterDkronServer(s grpc.ServiceRegistrar, srv DkronServer) + func RegisterExecutorServer(s grpc.ServiceRegistrar, srv ExecutorServer) + func RegisterStatusHelperServer(s grpc.ServiceRegistrar, srv StatusHelperServer) + type ACLPolicyDeleteRequest struct + Name string + func (*ACLPolicyDeleteRequest) Descriptor() ([]byte, []int) + func (*ACLPolicyDeleteRequest) ProtoMessage() + func (x *ACLPolicyDeleteRequest) GetName() string + func (x *ACLPolicyDeleteRequest) ProtoReflect() protoreflect.Message + func (x *ACLPolicyDeleteRequest) Reset() + func (x *ACLPolicyDeleteRequest) String() string + type ACLPolicyDeleteResponse struct + Success bool + func (*ACLPolicyDeleteResponse) Descriptor() ([]byte, []int) + func (*ACLPolicyDeleteResponse) ProtoMessage() + func (x *ACLPolicyDeleteResponse) GetSuccess() bool + func (x *ACLPolicyDeleteResponse) ProtoReflect() protoreflect.Message + func (x *ACLPolicyDeleteResponse) Reset() + func (x *ACLPolicyDeleteResponse) String() string + type ACLPolicyInfoRequest struct + Name string + func (*ACLPolicyInfoRequest) Descriptor() ([]byte, []int) + func (*ACLPolicyInfoRequest) ProtoMessage() + func (x *ACLPolicyInfoRequest) GetName() string + func (x *ACLPolicyInfoRequest) ProtoReflect() protoreflect.Message + func (x *ACLPolicyInfoRequest) Reset() + func (x *ACLPolicyInfoRequest) String() string + type ACLPolicyInfoResponse struct + Policy *Policy + func (*ACLPolicyInfoResponse) Descriptor() ([]byte, []int) + func (*ACLPolicyInfoResponse) ProtoMessage() + func (x *ACLPolicyInfoResponse) GetPolicy() *Policy + func (x *ACLPolicyInfoResponse) ProtoReflect() protoreflect.Message + func (x *ACLPolicyInfoResponse) Reset() + func (x *ACLPolicyInfoResponse) String() string + type ACLPolicyListResponse struct + Policies []*Policy + func (*ACLPolicyListResponse) Descriptor() ([]byte, []int) + func (*ACLPolicyListResponse) ProtoMessage() + func (x *ACLPolicyListResponse) GetPolicies() []*Policy + func (x *ACLPolicyListResponse) ProtoReflect() protoreflect.Message + func (x *ACLPolicyListResponse) Reset() + func (x *ACLPolicyListResponse) String() string + type ACLPolicyUpsertRequest struct + Policy *Policy + func (*ACLPolicyUpsertRequest) Descriptor() ([]byte, []int) + func (*ACLPolicyUpsertRequest) ProtoMessage() + func (x *ACLPolicyUpsertRequest) GetPolicy() *Policy + func (x *ACLPolicyUpsertRequest) ProtoReflect() protoreflect.Message + func (x *ACLPolicyUpsertRequest) Reset() + func (x *ACLPolicyUpsertRequest) String() string + type ACLPolicyUpsertResponse struct + Success bool + func (*ACLPolicyUpsertResponse) Descriptor() ([]byte, []int) + func (*ACLPolicyUpsertResponse) ProtoMessage() + func (x *ACLPolicyUpsertResponse) GetSuccess() bool + func (x *ACLPolicyUpsertResponse) ProtoReflect() protoreflect.Message + func (x *ACLPolicyUpsertResponse) Reset() + func (x *ACLPolicyUpsertResponse) String() string + type ACLTokenDeleteRequest struct + Accessor string + func (*ACLTokenDeleteRequest) Descriptor() ([]byte, []int) + func (*ACLTokenDeleteRequest) ProtoMessage() + func (x *ACLTokenDeleteRequest) GetAccessor() string + func (x *ACLTokenDeleteRequest) ProtoReflect() protoreflect.Message + func (x *ACLTokenDeleteRequest) Reset() + func (x *ACLTokenDeleteRequest) String() string + type ACLTokenDeleteResponse struct + Success bool + func (*ACLTokenDeleteResponse) Descriptor() ([]byte, []int) + func (*ACLTokenDeleteResponse) ProtoMessage() + func (x *ACLTokenDeleteResponse) GetSuccess() bool + func (x *ACLTokenDeleteResponse) ProtoReflect() protoreflect.Message + func (x *ACLTokenDeleteResponse) Reset() + func (x *ACLTokenDeleteResponse) String() string + type ACLTokenInfoRequest struct + Accessor string + func (*ACLTokenInfoRequest) Descriptor() ([]byte, []int) + func (*ACLTokenInfoRequest) ProtoMessage() + func (x *ACLTokenInfoRequest) GetAccessor() string + func (x *ACLTokenInfoRequest) ProtoReflect() protoreflect.Message + func (x *ACLTokenInfoRequest) Reset() + func (x *ACLTokenInfoRequest) String() string + type ACLTokenInfoResponse struct + Token *Token + func (*ACLTokenInfoResponse) Descriptor() ([]byte, []int) + func (*ACLTokenInfoResponse) ProtoMessage() + func (x *ACLTokenInfoResponse) GetToken() *Token + func (x *ACLTokenInfoResponse) ProtoReflect() protoreflect.Message + func (x *ACLTokenInfoResponse) Reset() + func (x *ACLTokenInfoResponse) String() string + type ACLTokenListResponse struct + Tokens []*Token + func (*ACLTokenListResponse) Descriptor() ([]byte, []int) + func (*ACLTokenListResponse) ProtoMessage() + func (x *ACLTokenListResponse) GetTokens() []*Token + func (x *ACLTokenListResponse) ProtoReflect() protoreflect.Message + func (x *ACLTokenListResponse) Reset() + func (x *ACLTokenListResponse) String() string + type ACLTokenUpsertRequest struct + Token *Token + func (*ACLTokenUpsertRequest) Descriptor() ([]byte, []int) + func (*ACLTokenUpsertRequest) ProtoMessage() + func (x *ACLTokenUpsertRequest) GetToken() *Token + func (x *ACLTokenUpsertRequest) ProtoReflect() protoreflect.Message + func (x *ACLTokenUpsertRequest) Reset() + func (x *ACLTokenUpsertRequest) String() string + type ACLTokenUpsertResponse struct + Success bool + func (*ACLTokenUpsertResponse) Descriptor() ([]byte, []int) + func (*ACLTokenUpsertResponse) ProtoMessage() + func (x *ACLTokenUpsertResponse) GetSuccess() bool + func (x *ACLTokenUpsertResponse) ProtoReflect() protoreflect.Message + func (x *ACLTokenUpsertResponse) Reset() + func (x *ACLTokenUpsertResponse) String() string + type AgentClient interface + AgentRun func(ctx context.Context, in *AgentRunRequest, opts ...grpc.CallOption) (Agent_AgentRunClient, error) + func NewAgentClient(cc grpc.ClientConnInterface) AgentClient + type AgentRunRequest struct + Execution *Execution + Job *Job + func (*AgentRunRequest) Descriptor() ([]byte, []int) + func (*AgentRunRequest) ProtoMessage() + func (x *AgentRunRequest) GetExecution() *Execution + func (x *AgentRunRequest) GetJob() *Job + func (x *AgentRunRequest) ProtoReflect() protoreflect.Message + func (x *AgentRunRequest) Reset() + func (x *AgentRunRequest) String() string + type AgentRunResponse struct + From string + Payload []byte + func (*AgentRunResponse) Descriptor() ([]byte, []int) + func (*AgentRunResponse) ProtoMessage() + func (x *AgentRunResponse) GetFrom() string + func (x *AgentRunResponse) GetPayload() []byte + func (x *AgentRunResponse) ProtoReflect() protoreflect.Message + func (x *AgentRunResponse) Reset() + func (x *AgentRunResponse) String() string + type AgentRunStream struct + Execution *Execution + func (*AgentRunStream) Descriptor() ([]byte, []int) + func (*AgentRunStream) ProtoMessage() + func (x *AgentRunStream) GetExecution() *Execution + func (x *AgentRunStream) ProtoReflect() protoreflect.Message + func (x *AgentRunStream) Reset() + func (x *AgentRunStream) String() string + type AgentServer interface + AgentRun func(*AgentRunRequest, Agent_AgentRunServer) error + type Agent_AgentRunClient interface + Recv func() (*AgentRunStream, error) + type Agent_AgentRunServer interface + Send func(*AgentRunStream) error + type DeleteJobRequest struct + JobName string + func (*DeleteJobRequest) Descriptor() ([]byte, []int) + func (*DeleteJobRequest) ProtoMessage() + func (x *DeleteJobRequest) GetJobName() string + func (x *DeleteJobRequest) ProtoReflect() protoreflect.Message + func (x *DeleteJobRequest) Reset() + func (x *DeleteJobRequest) String() string + type DeleteJobResponse struct + Job *Job + func (*DeleteJobResponse) Descriptor() ([]byte, []int) + func (*DeleteJobResponse) ProtoMessage() + func (x *DeleteJobResponse) GetJob() *Job + func (x *DeleteJobResponse) ProtoReflect() protoreflect.Message + func (x *DeleteJobResponse) Reset() + func (x *DeleteJobResponse) String() string + type DkronClient interface + DeleteJob func(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*DeleteJobResponse, error) + ExecutionDone func(ctx context.Context, in *ExecutionDoneRequest, opts ...grpc.CallOption) (*ExecutionDoneResponse, error) + GetActiveExecutions func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetActiveExecutionsResponse, error) + GetJob func(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) + Leave func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error) + RaftGetConfiguration func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*RaftGetConfigurationResponse, error) + RaftRemovePeerByID func(ctx context.Context, in *RaftRemovePeerByIDRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + RunJob func(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*RunJobResponse, error) + SetExecution func(ctx context.Context, in *Execution, opts ...grpc.CallOption) (*emptypb.Empty, error) + SetJob func(ctx context.Context, in *SetJobRequest, opts ...grpc.CallOption) (*SetJobResponse, error) + ToggleJob func(ctx context.Context, in *ToggleJobRequest, opts ...grpc.CallOption) (*ToggleJobResponse, error) + func NewDkronClient(cc grpc.ClientConnInterface) DkronClient + type DkronProClient interface + ACLPolicyDelete func(ctx context.Context, in *ACLPolicyDeleteRequest, opts ...grpc.CallOption) (*ACLPolicyDeleteResponse, error) + ACLPolicyInfo func(ctx context.Context, in *ACLPolicyInfoRequest, opts ...grpc.CallOption) (*ACLPolicyInfoResponse, error) + ACLPolicyList func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ACLPolicyListResponse, error) + ACLPolicyUpsert func(ctx context.Context, in *ACLPolicyUpsertRequest, opts ...grpc.CallOption) (*ACLPolicyUpsertResponse, error) + ACLTokenDelete func(ctx context.Context, in *ACLTokenDeleteRequest, opts ...grpc.CallOption) (*ACLTokenDeleteResponse, error) + ACLTokenInfo func(ctx context.Context, in *ACLTokenInfoRequest, opts ...grpc.CallOption) (*ACLTokenInfoResponse, error) + ACLTokenList func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ACLTokenListResponse, error) + ACLTokenUpsert func(ctx context.Context, in *ACLTokenUpsertRequest, opts ...grpc.CallOption) (*ACLTokenUpsertResponse, error) + func NewDkronProClient(cc grpc.ClientConnInterface) DkronProClient + type DkronProServer interface + ACLPolicyDelete func(context.Context, *ACLPolicyDeleteRequest) (*ACLPolicyDeleteResponse, error) + ACLPolicyInfo func(context.Context, *ACLPolicyInfoRequest) (*ACLPolicyInfoResponse, error) + ACLPolicyList func(context.Context, *emptypb.Empty) (*ACLPolicyListResponse, error) + ACLPolicyUpsert func(context.Context, *ACLPolicyUpsertRequest) (*ACLPolicyUpsertResponse, error) + ACLTokenDelete func(context.Context, *ACLTokenDeleteRequest) (*ACLTokenDeleteResponse, error) + ACLTokenInfo func(context.Context, *ACLTokenInfoRequest) (*ACLTokenInfoResponse, error) + ACLTokenList func(context.Context, *emptypb.Empty) (*ACLTokenListResponse, error) + ACLTokenUpsert func(context.Context, *ACLTokenUpsertRequest) (*ACLTokenUpsertResponse, error) + type DkronServer interface + DeleteJob func(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error) + ExecutionDone func(context.Context, *ExecutionDoneRequest) (*ExecutionDoneResponse, error) + GetActiveExecutions func(context.Context, *emptypb.Empty) (*GetActiveExecutionsResponse, error) + GetJob func(context.Context, *GetJobRequest) (*GetJobResponse, error) + Leave func(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + RaftGetConfiguration func(context.Context, *emptypb.Empty) (*RaftGetConfigurationResponse, error) + RaftRemovePeerByID func(context.Context, *RaftRemovePeerByIDRequest) (*emptypb.Empty, error) + RunJob func(context.Context, *RunJobRequest) (*RunJobResponse, error) + SetExecution func(context.Context, *Execution) (*emptypb.Empty, error) + SetJob func(context.Context, *SetJobRequest) (*SetJobResponse, error) + ToggleJob func(context.Context, *ToggleJobRequest) (*ToggleJobResponse, error) + type ExecuteRequest struct + Config map[string]string + JobName string + StatusServer uint32 + func (*ExecuteRequest) Descriptor() ([]byte, []int) + func (*ExecuteRequest) ProtoMessage() + func (x *ExecuteRequest) GetConfig() map[string]string + func (x *ExecuteRequest) GetJobName() string + func (x *ExecuteRequest) GetStatusServer() uint32 + func (x *ExecuteRequest) ProtoReflect() protoreflect.Message + func (x *ExecuteRequest) Reset() + func (x *ExecuteRequest) String() string + type ExecuteResponse struct + Error string + Output []byte + func (*ExecuteResponse) Descriptor() ([]byte, []int) + func (*ExecuteResponse) ProtoMessage() + func (x *ExecuteResponse) GetError() string + func (x *ExecuteResponse) GetOutput() []byte + func (x *ExecuteResponse) ProtoReflect() protoreflect.Message + func (x *ExecuteResponse) Reset() + func (x *ExecuteResponse) String() string + type Execution struct + Attempt uint32 + FinishedAt *timestamppb.Timestamp + Group int64 + JobName string + NodeName string + Output []byte + StartedAt *timestamppb.Timestamp + Success bool + func (*Execution) Descriptor() ([]byte, []int) + func (*Execution) ProtoMessage() + func (e *Execution) Key() string + func (x *Execution) GetAttempt() uint32 + func (x *Execution) GetFinishedAt() *timestamppb.Timestamp + func (x *Execution) GetGroup() int64 + func (x *Execution) GetJobName() string + func (x *Execution) GetNodeName() string + func (x *Execution) GetOutput() []byte + func (x *Execution) GetStartedAt() *timestamppb.Timestamp + func (x *Execution) GetSuccess() bool + func (x *Execution) ProtoReflect() protoreflect.Message + func (x *Execution) Reset() + func (x *Execution) String() string + type ExecutionDoneRequest struct + Execution *Execution + func (*ExecutionDoneRequest) Descriptor() ([]byte, []int) + func (*ExecutionDoneRequest) ProtoMessage() + func (x *ExecutionDoneRequest) GetExecution() *Execution + func (x *ExecutionDoneRequest) ProtoReflect() protoreflect.Message + func (x *ExecutionDoneRequest) Reset() + func (x *ExecutionDoneRequest) String() string + type ExecutionDoneResponse struct + From string + Payload []byte + func (*ExecutionDoneResponse) Descriptor() ([]byte, []int) + func (*ExecutionDoneResponse) ProtoMessage() + func (x *ExecutionDoneResponse) GetFrom() string + func (x *ExecutionDoneResponse) GetPayload() []byte + func (x *ExecutionDoneResponse) ProtoReflect() protoreflect.Message + func (x *ExecutionDoneResponse) Reset() + func (x *ExecutionDoneResponse) String() string + type ExecutorClient interface + Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) + func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient + type ExecutorServer interface + Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + type GetActiveExecutionsResponse struct + Executions []*Execution + func (*GetActiveExecutionsResponse) Descriptor() ([]byte, []int) + func (*GetActiveExecutionsResponse) ProtoMessage() + func (x *GetActiveExecutionsResponse) GetExecutions() []*Execution + func (x *GetActiveExecutionsResponse) ProtoReflect() protoreflect.Message + func (x *GetActiveExecutionsResponse) Reset() + func (x *GetActiveExecutionsResponse) String() string + type GetJobRequest struct + JobName string + func (*GetJobRequest) Descriptor() ([]byte, []int) + func (*GetJobRequest) ProtoMessage() + func (x *GetJobRequest) GetJobName() string + func (x *GetJobRequest) ProtoReflect() protoreflect.Message + func (x *GetJobRequest) Reset() + func (x *GetJobRequest) String() string + type GetJobResponse struct + Job *Job + func (*GetJobResponse) Descriptor() ([]byte, []int) + func (*GetJobResponse) ProtoMessage() + func (x *GetJobResponse) GetJob() *Job + func (x *GetJobResponse) ProtoReflect() protoreflect.Message + func (x *GetJobResponse) Reset() + func (x *GetJobResponse) String() string + type Job struct + Concurrency string + DependentJobs []string + Disabled bool + Displayname string + Ephemeral bool + ErrorCount int32 + Executor string + ExecutorConfig map[string]string + ExpiresAt *Job_NullableTime + LastError *Job_NullableTime + LastSuccess *Job_NullableTime + Metadata map[string]string + Name string + Next *timestamppb.Timestamp + Owner string + OwnerEmail string + ParentJob string + Processors map[string]*PluginConfig + Retries uint32 + Schedule string + Status string + SuccessCount int32 + Tags map[string]string + Timezone string + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (x *Job) GetConcurrency() string + func (x *Job) GetDependentJobs() []string + func (x *Job) GetDisabled() bool + func (x *Job) GetDisplayname() string + func (x *Job) GetEphemeral() bool + func (x *Job) GetErrorCount() int32 + func (x *Job) GetExecutor() string + func (x *Job) GetExecutorConfig() map[string]string + func (x *Job) GetExpiresAt() *Job_NullableTime + func (x *Job) GetLastError() *Job_NullableTime + func (x *Job) GetLastSuccess() *Job_NullableTime + func (x *Job) GetMetadata() map[string]string + func (x *Job) GetName() string + func (x *Job) GetNext() *timestamppb.Timestamp + func (x *Job) GetOwner() string + func (x *Job) GetOwnerEmail() string + func (x *Job) GetParentJob() string + func (x *Job) GetProcessors() map[string]*PluginConfig + func (x *Job) GetRetries() uint32 + func (x *Job) GetSchedule() string + func (x *Job) GetStatus() string + func (x *Job) GetSuccessCount() int32 + func (x *Job) GetTags() map[string]string + func (x *Job) GetTimezone() string + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type Job_NullableTime struct + HasValue bool + Time *timestamppb.Timestamp + func (*Job_NullableTime) Descriptor() ([]byte, []int) + func (*Job_NullableTime) ProtoMessage() + func (x *Job_NullableTime) GetHasValue() bool + func (x *Job_NullableTime) GetTime() *timestamppb.Timestamp + func (x *Job_NullableTime) ProtoReflect() protoreflect.Message + func (x *Job_NullableTime) Reset() + func (x *Job_NullableTime) String() string + type Member struct + Id string + StatusText string + type PluginConfig struct + Config map[string]string + func (*PluginConfig) Descriptor() ([]byte, []int) + func (*PluginConfig) ProtoMessage() + func (x *PluginConfig) GetConfig() map[string]string + func (x *PluginConfig) ProtoReflect() protoreflect.Message + func (x *PluginConfig) Reset() + func (x *PluginConfig) String() string + type Policy struct + Name string + Rules string + func (*Policy) Descriptor() ([]byte, []int) + func (*Policy) ProtoMessage() + func (x *Policy) GetName() string + func (x *Policy) GetRules() string + func (x *Policy) ProtoReflect() protoreflect.Message + func (x *Policy) Reset() + func (x *Policy) String() string + type RaftGetConfigurationResponse struct + Index uint64 + Servers []*RaftServer + func (*RaftGetConfigurationResponse) Descriptor() ([]byte, []int) + func (*RaftGetConfigurationResponse) ProtoMessage() + func (x *RaftGetConfigurationResponse) GetIndex() uint64 + func (x *RaftGetConfigurationResponse) GetServers() []*RaftServer + func (x *RaftGetConfigurationResponse) ProtoReflect() protoreflect.Message + func (x *RaftGetConfigurationResponse) Reset() + func (x *RaftGetConfigurationResponse) String() string + type RaftRemovePeerByIDRequest struct + Id string + func (*RaftRemovePeerByIDRequest) Descriptor() ([]byte, []int) + func (*RaftRemovePeerByIDRequest) ProtoMessage() + func (x *RaftRemovePeerByIDRequest) GetId() string + func (x *RaftRemovePeerByIDRequest) ProtoReflect() protoreflect.Message + func (x *RaftRemovePeerByIDRequest) Reset() + func (x *RaftRemovePeerByIDRequest) String() string + type RaftServer struct + Address string + Id string + Leader bool + Node string + RaftProtocol string + Voter bool + func (*RaftServer) Descriptor() ([]byte, []int) + func (*RaftServer) ProtoMessage() + func (x *RaftServer) GetAddress() string + func (x *RaftServer) GetId() string + func (x *RaftServer) GetLeader() bool + func (x *RaftServer) GetNode() string + func (x *RaftServer) GetRaftProtocol() string + func (x *RaftServer) GetVoter() bool + func (x *RaftServer) ProtoReflect() protoreflect.Message + func (x *RaftServer) Reset() + func (x *RaftServer) String() string + type RunJobRequest struct + JobName string + func (*RunJobRequest) Descriptor() ([]byte, []int) + func (*RunJobRequest) ProtoMessage() + func (x *RunJobRequest) GetJobName() string + func (x *RunJobRequest) ProtoReflect() protoreflect.Message + func (x *RunJobRequest) Reset() + func (x *RunJobRequest) String() string + type RunJobResponse struct + Job *Job + func (*RunJobResponse) Descriptor() ([]byte, []int) + func (*RunJobResponse) ProtoMessage() + func (x *RunJobResponse) GetJob() *Job + func (x *RunJobResponse) ProtoReflect() protoreflect.Message + func (x *RunJobResponse) Reset() + func (x *RunJobResponse) String() string + type SetJobRequest struct + Job *Job + func (*SetJobRequest) Descriptor() ([]byte, []int) + func (*SetJobRequest) ProtoMessage() + func (x *SetJobRequest) GetJob() *Job + func (x *SetJobRequest) ProtoReflect() protoreflect.Message + func (x *SetJobRequest) Reset() + func (x *SetJobRequest) String() string + type SetJobResponse struct + Job *Job + func (*SetJobResponse) Descriptor() ([]byte, []int) + func (*SetJobResponse) ProtoMessage() + func (x *SetJobResponse) GetJob() *Job + func (x *SetJobResponse) ProtoReflect() protoreflect.Message + func (x *SetJobResponse) Reset() + func (x *SetJobResponse) String() string + type StatusHelperClient interface + Update func(ctx context.Context, in *StatusUpdateRequest, opts ...grpc.CallOption) (*StatusUpdateResponse, error) + func NewStatusHelperClient(cc grpc.ClientConnInterface) StatusHelperClient + type StatusHelperServer interface + Update func(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, error) + type StatusUpdateRequest struct + Error bool + Output []byte + func (*StatusUpdateRequest) Descriptor() ([]byte, []int) + func (*StatusUpdateRequest) ProtoMessage() + func (x *StatusUpdateRequest) GetError() bool + func (x *StatusUpdateRequest) GetOutput() []byte + func (x *StatusUpdateRequest) ProtoReflect() protoreflect.Message + func (x *StatusUpdateRequest) Reset() + func (x *StatusUpdateRequest) String() string + type StatusUpdateResponse struct + R int64 + func (*StatusUpdateResponse) Descriptor() ([]byte, []int) + func (*StatusUpdateResponse) ProtoMessage() + func (x *StatusUpdateResponse) GetR() int64 + func (x *StatusUpdateResponse) ProtoReflect() protoreflect.Message + func (x *StatusUpdateResponse) Reset() + func (x *StatusUpdateResponse) String() string + type ToggleJobRequest struct + JobName string + func (*ToggleJobRequest) Descriptor() ([]byte, []int) + func (*ToggleJobRequest) ProtoMessage() + func (x *ToggleJobRequest) GetJobName() string + func (x *ToggleJobRequest) ProtoReflect() protoreflect.Message + func (x *ToggleJobRequest) Reset() + func (x *ToggleJobRequest) String() string + type ToggleJobResponse struct + Job *Job + func (*ToggleJobResponse) Descriptor() ([]byte, []int) + func (*ToggleJobResponse) ProtoMessage() + func (x *ToggleJobResponse) GetJob() *Job + func (x *ToggleJobResponse) ProtoReflect() protoreflect.Message + func (x *ToggleJobResponse) Reset() + func (x *ToggleJobResponse) String() string + type Token struct + Accessor string + CreateTime *timestamppb.Timestamp + ExpireTime *timestamppb.Timestamp + Name string + Policies []string + Secret string + Type TokenType + func (*Token) Descriptor() ([]byte, []int) + func (*Token) ProtoMessage() + func (x *Token) GetAccessor() string + func (x *Token) GetCreateTime() *timestamppb.Timestamp + func (x *Token) GetExpireTime() *timestamppb.Timestamp + func (x *Token) GetName() string + func (x *Token) GetPolicies() []string + func (x *Token) GetSecret() string + func (x *Token) GetType() TokenType + func (x *Token) ProtoReflect() protoreflect.Message + func (x *Token) Reset() + func (x *Token) String() string + type TokenType int32 + const TokenType_client + const TokenType_management + func (TokenType) Descriptor() protoreflect.EnumDescriptor + func (TokenType) EnumDescriptor() ([]byte, []int) + func (TokenType) Type() protoreflect.EnumType + func (x TokenType) Enum() *TokenType + func (x TokenType) Number() protoreflect.EnumNumber + func (x TokenType) String() string + type UnimplementedAgentServer struct + func (UnimplementedAgentServer) AgentRun(*AgentRunRequest, Agent_AgentRunServer) error + type UnimplementedDkronProServer struct + func (UnimplementedDkronProServer) ACLPolicyDelete(context.Context, *ACLPolicyDeleteRequest) (*ACLPolicyDeleteResponse, error) + func (UnimplementedDkronProServer) ACLPolicyInfo(context.Context, *ACLPolicyInfoRequest) (*ACLPolicyInfoResponse, error) + func (UnimplementedDkronProServer) ACLPolicyList(context.Context, *emptypb.Empty) (*ACLPolicyListResponse, error) + func (UnimplementedDkronProServer) ACLPolicyUpsert(context.Context, *ACLPolicyUpsertRequest) (*ACLPolicyUpsertResponse, error) + func (UnimplementedDkronProServer) ACLTokenDelete(context.Context, *ACLTokenDeleteRequest) (*ACLTokenDeleteResponse, error) + func (UnimplementedDkronProServer) ACLTokenInfo(context.Context, *ACLTokenInfoRequest) (*ACLTokenInfoResponse, error) + func (UnimplementedDkronProServer) ACLTokenList(context.Context, *emptypb.Empty) (*ACLTokenListResponse, error) + func (UnimplementedDkronProServer) ACLTokenUpsert(context.Context, *ACLTokenUpsertRequest) (*ACLTokenUpsertResponse, error) + type UnimplementedDkronServer struct + func (UnimplementedDkronServer) DeleteJob(context.Context, *DeleteJobRequest) (*DeleteJobResponse, error) + func (UnimplementedDkronServer) ExecutionDone(context.Context, *ExecutionDoneRequest) (*ExecutionDoneResponse, error) + func (UnimplementedDkronServer) GetActiveExecutions(context.Context, *emptypb.Empty) (*GetActiveExecutionsResponse, error) + func (UnimplementedDkronServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) + func (UnimplementedDkronServer) Leave(context.Context, *emptypb.Empty) (*emptypb.Empty, error) + func (UnimplementedDkronServer) RaftGetConfiguration(context.Context, *emptypb.Empty) (*RaftGetConfigurationResponse, error) + func (UnimplementedDkronServer) RaftRemovePeerByID(context.Context, *RaftRemovePeerByIDRequest) (*emptypb.Empty, error) + func (UnimplementedDkronServer) RunJob(context.Context, *RunJobRequest) (*RunJobResponse, error) + func (UnimplementedDkronServer) SetExecution(context.Context, *Execution) (*emptypb.Empty, error) + func (UnimplementedDkronServer) SetJob(context.Context, *SetJobRequest) (*SetJobResponse, error) + func (UnimplementedDkronServer) ToggleJob(context.Context, *ToggleJobRequest) (*ToggleJobResponse, error) + type UnimplementedExecutorServer struct + func (UnimplementedExecutorServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + type UnimplementedStatusHelperServer struct + func (UnimplementedStatusHelperServer) Update(context.Context, *StatusUpdateRequest) (*StatusUpdateResponse, error) + type UnsafeAgentServer interface + type UnsafeDkronProServer interface + type UnsafeDkronServer interface + type UnsafeExecutorServer interface + type UnsafeStatusHelperServer interface v4.0.0-rc3 Oct 6, 2024 v4.0.0-rc2 Oct 6, 2024 v4.0.0-rc1 Sep 16, 2024 v4.0.0-beta6 Jun 30, 2024 v4.0.0-beta5 Feb 25, 2024
Go to main page