Documentation ¶
Index ¶
- Variables
- func RegisterAgentServiceServer(s *grpc.Server, srv AgentServiceServer)
- type AgentInfo
- func (*AgentInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentInfo) GetAddress() string
- func (x *AgentInfo) GetHealthy() bool
- func (x *AgentInfo) GetName() string
- func (x *AgentInfo) GetSecrets() []*AgentSecretInfo
- func (x *AgentInfo) GetSecure() bool
- func (x *AgentInfo) GetServerName() string
- func (x *AgentInfo) GetWorkflows() []*AgentWorkflowInfo
- func (*AgentInfo) ProtoMessage()
- func (x *AgentInfo) ProtoReflect() protoreflect.Message
- func (x *AgentInfo) Reset()
- func (x *AgentInfo) String() string
- type AgentInfoOpts
- type AgentSecretInfo
- func (*AgentSecretInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentSecretInfo) GetName() string
- func (x *AgentSecretInfo) GetType() string
- func (*AgentSecretInfo) ProtoMessage()
- func (x *AgentSecretInfo) ProtoReflect() protoreflect.Message
- func (x *AgentSecretInfo) Reset()
- func (x *AgentSecretInfo) String() string
- type AgentServiceClient
- type AgentServiceServer
- type AgentStatus
- type AgentTriggerInfo
- func (*AgentTriggerInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentTriggerInfo) GetName() string
- func (x *AgentTriggerInfo) GetPipelines() []string
- func (*AgentTriggerInfo) ProtoMessage()
- func (x *AgentTriggerInfo) ProtoReflect() protoreflect.Message
- func (x *AgentTriggerInfo) Reset()
- func (x *AgentTriggerInfo) String() string
- type AgentWorkflowInfo
- func (*AgentWorkflowInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AgentWorkflowInfo) GetName() string
- func (x *AgentWorkflowInfo) GetTriggers() []*AgentTriggerInfo
- func (*AgentWorkflowInfo) ProtoMessage()
- func (x *AgentWorkflowInfo) ProtoReflect() protoreflect.Message
- func (x *AgentWorkflowInfo) Reset()
- func (x *AgentWorkflowInfo) String() string
- type Pipeline
- func (*Pipeline) Descriptor() ([]byte, []int)deprecated
- func (x *Pipeline) GetName() string
- func (x *Pipeline) GetSpec() string
- func (x *Pipeline) GetTriggerName() string
- func (x *Pipeline) GetTriggerSpec() string
- func (x *Pipeline) GetWorkflow() string
- func (*Pipeline) ProtoMessage()
- func (x *Pipeline) ProtoReflect() protoreflect.Message
- func (x *Pipeline) Reset()
- func (x *Pipeline) String() string
- type PipelineInfoOpts
- func (*PipelineInfoOpts) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineInfoOpts) GetName() string
- func (x *PipelineInfoOpts) GetRunID() string
- func (x *PipelineInfoOpts) GetWorkflow() string
- func (*PipelineInfoOpts) ProtoMessage()
- func (x *PipelineInfoOpts) ProtoReflect() protoreflect.Message
- func (x *PipelineInfoOpts) Reset()
- func (x *PipelineInfoOpts) String() string
- type PipelineRunInfo
- func (*PipelineRunInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineRunInfo) GetAgent() string
- func (x *PipelineRunInfo) GetEndTime() int64
- func (x *PipelineRunInfo) GetRunID() string
- func (x *PipelineRunInfo) GetStartTime() int64
- func (x *PipelineRunInfo) GetStatus() string
- func (*PipelineRunInfo) ProtoMessage()
- func (x *PipelineRunInfo) ProtoReflect() protoreflect.Message
- func (x *PipelineRunInfo) Reset()
- func (x *PipelineRunInfo) String() string
- type PipelineRunStatus
- type PipelineStatus
- func (*PipelineStatus) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineStatus) GetExecutor() string
- func (x *PipelineStatus) GetStatus() string
- func (*PipelineStatus) ProtoMessage()
- func (x *PipelineStatus) ProtoReflect() protoreflect.Message
- func (x *PipelineStatus) Reset()
- func (x *PipelineStatus) String() string
- type PipelinesRunInfo
- func (*PipelinesRunInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PipelinesRunInfo) GetErrorMessage() string
- func (x *PipelinesRunInfo) GetName() string
- func (x *PipelinesRunInfo) GetPipelines() []*PipelineRunInfo
- func (*PipelinesRunInfo) ProtoMessage()
- func (x *PipelinesRunInfo) ProtoReflect() protoreflect.Message
- func (x *PipelinesRunInfo) Reset()
- func (x *PipelinesRunInfo) String() string
- type StatusOpts
- type TriggerOpts
- func (*TriggerOpts) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerOpts) GetName() string
- func (x *TriggerOpts) GetPipeline() string
- func (x *TriggerOpts) GetWorkflow() string
- func (*TriggerOpts) ProtoMessage()
- func (x *TriggerOpts) ProtoReflect() protoreflect.Message
- func (x *TriggerOpts) Reset()
- func (x *TriggerOpts) String() string
- type TriggerRunInfo
- func (*TriggerRunInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerRunInfo) GetAgent() string
- func (x *TriggerRunInfo) GetStatus() string
- func (*TriggerRunInfo) ProtoMessage()
- func (x *TriggerRunInfo) ProtoReflect() protoreflect.Message
- func (x *TriggerRunInfo) Reset()
- func (x *TriggerRunInfo) String() string
- type UnimplementedAgentServiceServer
- func (*UnimplementedAgentServiceServer) GetPipelineRunStatus(context.Context, *PipelineInfoOpts) (*PipelineRunStatus, error)
- func (*UnimplementedAgentServiceServer) GetPipelinesRunInfo(context.Context, *PipelineInfoOpts) (*PipelinesRunInfo, error)
- func (*UnimplementedAgentServiceServer) Info(context.Context, *AgentInfoOpts) (*AgentInfo, error)
- func (*UnimplementedAgentServiceServer) InvokeTrigger(context.Context, *TriggerOpts) (*TriggerRunInfo, error)
- func (*UnimplementedAgentServiceServer) RemovePipeline(context.Context, *Pipeline) (*PipelineStatus, error)
- func (*UnimplementedAgentServiceServer) SchedulePipeline(context.Context, *Pipeline) (*PipelineStatus, error)
- func (*UnimplementedAgentServiceServer) Status(context.Context, *StatusOpts) (*AgentStatus, error)
- func (*UnimplementedAgentServiceServer) UpdatePipeline(context.Context, *Pipeline) (*PipelineStatus, error)
Constants ¶
This section is empty.
Variables ¶
var File_agent_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServiceServer ¶
func RegisterAgentServiceServer(s *grpc.Server, srv AgentServiceServer)
Types ¶
type AgentInfo ¶
type AgentInfo struct { // Healthy specifies wheather the agent is healthy or not. Healthy bool `protobuf:"varint,1,opt,name=Healthy,proto3" json:"Healthy,omitempty"` // Name contains the name of the agent. Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` // Address contains the address of the agent. Address string `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"` // Secure shows if the agent is running in secure mode or not. Secure bool `protobuf:"varint,4,opt,name=Secure,proto3" json:"Secure,omitempty"` // ServerName contains the server name of the running agent. ServerName string `protobuf:"bytes,5,opt,name=ServerName,proto3" json:"ServerName,omitempty"` // Workflows contains the information about individual // workflow components scheduled on the agent. // The information for the workflow type is restricted for the scope of the agent // only. // Which means it only contains the triggers and pipelines scheduled on the agent. Workflows []*AgentWorkflowInfo `protobuf:"bytes,6,rep,name=Workflows,proto3" json:"Workflows,omitempty"` // Secrets contains the list of secrets associated with the agent. Secrets []*AgentSecretInfo `protobuf:"bytes,7,rep,name=Secrets,proto3" json:"Secrets,omitempty"` // contains filtered or unexported fields }
func (*AgentInfo) Descriptor
deprecated
func (*AgentInfo) GetAddress ¶
func (*AgentInfo) GetHealthy ¶
func (*AgentInfo) GetSecrets ¶
func (x *AgentInfo) GetSecrets() []*AgentSecretInfo
func (*AgentInfo) GetServerName ¶
func (*AgentInfo) GetWorkflows ¶
func (x *AgentInfo) GetWorkflows() []*AgentWorkflowInfo
func (*AgentInfo) ProtoMessage ¶
func (*AgentInfo) ProtoMessage()
func (*AgentInfo) ProtoReflect ¶
func (x *AgentInfo) ProtoReflect() protoreflect.Message
type AgentInfoOpts ¶
type AgentInfoOpts struct {
// contains filtered or unexported fields
}
func (*AgentInfoOpts) Descriptor
deprecated
func (*AgentInfoOpts) Descriptor() ([]byte, []int)
Deprecated: Use AgentInfoOpts.ProtoReflect.Descriptor instead.
func (*AgentInfoOpts) ProtoMessage ¶
func (*AgentInfoOpts) ProtoMessage()
func (*AgentInfoOpts) ProtoReflect ¶
func (x *AgentInfoOpts) ProtoReflect() protoreflect.Message
func (*AgentInfoOpts) Reset ¶
func (x *AgentInfoOpts) Reset()
func (*AgentInfoOpts) String ¶
func (x *AgentInfoOpts) String() string
type AgentSecretInfo ¶
type AgentSecretInfo struct { // Name contains the name of the secret. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` // Type contains the type of the secret associated. Type string `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type,omitempty"` // contains filtered or unexported fields }
func (*AgentSecretInfo) Descriptor
deprecated
func (*AgentSecretInfo) Descriptor() ([]byte, []int)
Deprecated: Use AgentSecretInfo.ProtoReflect.Descriptor instead.
func (*AgentSecretInfo) GetName ¶
func (x *AgentSecretInfo) GetName() string
func (*AgentSecretInfo) GetType ¶
func (x *AgentSecretInfo) GetType() string
func (*AgentSecretInfo) ProtoMessage ¶
func (*AgentSecretInfo) ProtoMessage()
func (*AgentSecretInfo) ProtoReflect ¶
func (x *AgentSecretInfo) ProtoReflect() protoreflect.Message
func (*AgentSecretInfo) Reset ¶
func (x *AgentSecretInfo) Reset()
func (*AgentSecretInfo) String ¶
func (x *AgentSecretInfo) String() string
type AgentServiceClient ¶
type AgentServiceClient interface { // Status returns the status of the agent service running. Status(ctx context.Context, in *StatusOpts, opts ...grpc.CallOption) (*AgentStatus, error) // UpdatePipeline is the RPC to update a pipeline on to the agent UpdatePipeline(ctx context.Context, in *Pipeline, opts ...grpc.CallOption) (*PipelineStatus, error) // SchedulePipeline is the RPC to schedule a pipeline on to the agent SchedulePipeline(ctx context.Context, in *Pipeline, opts ...grpc.CallOption) (*PipelineStatus, error) // RemovePipeline is the RPC to remove a pipeline from the agent. RemovePipeline(ctx context.Context, in *Pipeline, opts ...grpc.CallOption) (*PipelineStatus, error) // Info returns the information about the agent. Info(ctx context.Context, in *AgentInfoOpts, opts ...grpc.CallOption) (*AgentInfo, error) // GetPipelinesRunInfo returns the list of run info for the requested pipeline. GetPipelinesRunInfo(ctx context.Context, in *PipelineInfoOpts, opts ...grpc.CallOption) (*PipelinesRunInfo, error) // GetPipelineRunStatus returns the info about a particular pipeline run. GetPipelineRunStatus(ctx context.Context, in *PipelineInfoOpts, opts ...grpc.CallOption) (*PipelineRunStatus, error) // InvokeTrigger invokes a particular trigger InvokeTrigger(ctx context.Context, in *TriggerOpts, opts ...grpc.CallOption) (*TriggerRunInfo, error) }
AgentServiceClient is the client API for AgentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
type AgentServiceServer ¶
type AgentServiceServer interface { // Status returns the status of the agent service running. Status(context.Context, *StatusOpts) (*AgentStatus, error) // UpdatePipeline is the RPC to update a pipeline on to the agent UpdatePipeline(context.Context, *Pipeline) (*PipelineStatus, error) // SchedulePipeline is the RPC to schedule a pipeline on to the agent SchedulePipeline(context.Context, *Pipeline) (*PipelineStatus, error) // RemovePipeline is the RPC to remove a pipeline from the agent. RemovePipeline(context.Context, *Pipeline) (*PipelineStatus, error) // Info returns the information about the agent. Info(context.Context, *AgentInfoOpts) (*AgentInfo, error) // GetPipelinesRunInfo returns the list of run info for the requested pipeline. GetPipelinesRunInfo(context.Context, *PipelineInfoOpts) (*PipelinesRunInfo, error) // GetPipelineRunStatus returns the info about a particular pipeline run. GetPipelineRunStatus(context.Context, *PipelineInfoOpts) (*PipelineRunStatus, error) // InvokeTrigger invokes a particular trigger InvokeTrigger(context.Context, *TriggerOpts) (*TriggerRunInfo, error) }
AgentServiceServer is the server API for AgentService service.
type AgentStatus ¶
type AgentStatus struct { // Healthy is a boolean value which specifies the health status of the agent. Healthy bool `protobuf:"varint,1,opt,name=Healthy,proto3" json:"Healthy,omitempty"` // contains filtered or unexported fields }
func (*AgentStatus) Descriptor
deprecated
func (*AgentStatus) Descriptor() ([]byte, []int)
Deprecated: Use AgentStatus.ProtoReflect.Descriptor instead.
func (*AgentStatus) GetHealthy ¶
func (x *AgentStatus) GetHealthy() bool
func (*AgentStatus) ProtoMessage ¶
func (*AgentStatus) ProtoMessage()
func (*AgentStatus) ProtoReflect ¶
func (x *AgentStatus) ProtoReflect() protoreflect.Message
func (*AgentStatus) Reset ¶
func (x *AgentStatus) Reset()
func (*AgentStatus) String ¶
func (x *AgentStatus) String() string
type AgentTriggerInfo ¶
type AgentTriggerInfo struct { // Name contains the name of the trigger. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` // Pipelines contains the name of the pipelines. Pipelines []string `protobuf:"bytes,2,rep,name=Pipelines,proto3" json:"Pipelines,omitempty"` // contains filtered or unexported fields }
func (*AgentTriggerInfo) Descriptor
deprecated
func (*AgentTriggerInfo) Descriptor() ([]byte, []int)
Deprecated: Use AgentTriggerInfo.ProtoReflect.Descriptor instead.
func (*AgentTriggerInfo) GetName ¶
func (x *AgentTriggerInfo) GetName() string
func (*AgentTriggerInfo) GetPipelines ¶
func (x *AgentTriggerInfo) GetPipelines() []string
func (*AgentTriggerInfo) ProtoMessage ¶
func (*AgentTriggerInfo) ProtoMessage()
func (*AgentTriggerInfo) ProtoReflect ¶
func (x *AgentTriggerInfo) ProtoReflect() protoreflect.Message
func (*AgentTriggerInfo) Reset ¶
func (x *AgentTriggerInfo) Reset()
func (*AgentTriggerInfo) String ¶
func (x *AgentTriggerInfo) String() string
type AgentWorkflowInfo ¶
type AgentWorkflowInfo struct { // Name contains the name of the workflow. Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Triggers []*AgentTriggerInfo `protobuf:"bytes,2,rep,name=Triggers,proto3" json:"Triggers,omitempty"` // contains filtered or unexported fields }
func (*AgentWorkflowInfo) Descriptor
deprecated
func (*AgentWorkflowInfo) Descriptor() ([]byte, []int)
Deprecated: Use AgentWorkflowInfo.ProtoReflect.Descriptor instead.
func (*AgentWorkflowInfo) GetName ¶
func (x *AgentWorkflowInfo) GetName() string
func (*AgentWorkflowInfo) GetTriggers ¶
func (x *AgentWorkflowInfo) GetTriggers() []*AgentTriggerInfo
func (*AgentWorkflowInfo) ProtoMessage ¶
func (*AgentWorkflowInfo) ProtoMessage()
func (*AgentWorkflowInfo) ProtoReflect ¶
func (x *AgentWorkflowInfo) ProtoReflect() protoreflect.Message
func (*AgentWorkflowInfo) Reset ¶
func (x *AgentWorkflowInfo) Reset()
func (*AgentWorkflowInfo) String ¶
func (x *AgentWorkflowInfo) String() string
type Pipeline ¶
type Pipeline struct { // spec contains the actual spec of the pipeline. Each pipeline // is evaluated at the agent only. The work of the apiserver // is to schedule pipelines corresponding to a workflow on a number // of worker agents. Spec string `protobuf:"bytes,1,opt,name=Spec,proto3" json:"Spec,omitempty"` // Name contains the name of the pipeline as configured in // the workflow spec. Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` // Workflow contains the name of the workflow the pipeline is configured for Workflow string `protobuf:"bytes,3,opt,name=Workflow,proto3" json:"Workflow,omitempty"` // Name contains the name of the trigger as configured in // the workflow spec. TriggerName string `protobuf:"bytes,4,opt,name=TriggerName,proto3" json:"TriggerName,omitempty"` // spec contains the actual spec of the trigger. TriggerSpec string `protobuf:"bytes,5,opt,name=TriggerSpec,proto3" json:"TriggerSpec,omitempty"` // contains filtered or unexported fields }
func (*Pipeline) Descriptor
deprecated
func (*Pipeline) GetTriggerName ¶
func (*Pipeline) GetTriggerSpec ¶
func (*Pipeline) GetWorkflow ¶
func (*Pipeline) ProtoMessage ¶
func (*Pipeline) ProtoMessage()
func (*Pipeline) ProtoReflect ¶
func (x *Pipeline) ProtoReflect() protoreflect.Message
type PipelineInfoOpts ¶
type PipelineInfoOpts struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Workflow string `protobuf:"bytes,2,opt,name=Workflow,proto3" json:"Workflow,omitempty"` RunID string `protobuf:"bytes,3,opt,name=RunID,proto3" json:"RunID,omitempty"` // contains filtered or unexported fields }
func (*PipelineInfoOpts) Descriptor
deprecated
func (*PipelineInfoOpts) Descriptor() ([]byte, []int)
Deprecated: Use PipelineInfoOpts.ProtoReflect.Descriptor instead.
func (*PipelineInfoOpts) GetName ¶
func (x *PipelineInfoOpts) GetName() string
func (*PipelineInfoOpts) GetRunID ¶
func (x *PipelineInfoOpts) GetRunID() string
func (*PipelineInfoOpts) GetWorkflow ¶
func (x *PipelineInfoOpts) GetWorkflow() string
func (*PipelineInfoOpts) ProtoMessage ¶
func (*PipelineInfoOpts) ProtoMessage()
func (*PipelineInfoOpts) ProtoReflect ¶
func (x *PipelineInfoOpts) ProtoReflect() protoreflect.Message
func (*PipelineInfoOpts) Reset ¶
func (x *PipelineInfoOpts) Reset()
func (*PipelineInfoOpts) String ¶
func (x *PipelineInfoOpts) String() string
type PipelineRunInfo ¶
type PipelineRunInfo struct { RunID string `protobuf:"bytes,1,opt,name=RunID,proto3" json:"RunID,omitempty"` Agent string `protobuf:"bytes,2,opt,name=Agent,proto3" json:"Agent,omitempty"` Status string `protobuf:"bytes,3,opt,name=Status,proto3" json:"Status,omitempty"` StartTime int64 `protobuf:"varint,4,opt,name=StartTime,proto3" json:"StartTime,omitempty"` EndTime int64 `protobuf:"varint,5,opt,name=EndTime,proto3" json:"EndTime,omitempty"` // contains filtered or unexported fields }
func (*PipelineRunInfo) Descriptor
deprecated
func (*PipelineRunInfo) Descriptor() ([]byte, []int)
Deprecated: Use PipelineRunInfo.ProtoReflect.Descriptor instead.
func (*PipelineRunInfo) GetAgent ¶
func (x *PipelineRunInfo) GetAgent() string
func (*PipelineRunInfo) GetEndTime ¶
func (x *PipelineRunInfo) GetEndTime() int64
func (*PipelineRunInfo) GetRunID ¶
func (x *PipelineRunInfo) GetRunID() string
func (*PipelineRunInfo) GetStartTime ¶
func (x *PipelineRunInfo) GetStartTime() int64
func (*PipelineRunInfo) GetStatus ¶
func (x *PipelineRunInfo) GetStatus() string
func (*PipelineRunInfo) ProtoMessage ¶
func (*PipelineRunInfo) ProtoMessage()
func (*PipelineRunInfo) ProtoReflect ¶
func (x *PipelineRunInfo) ProtoReflect() protoreflect.Message
func (*PipelineRunInfo) Reset ¶
func (x *PipelineRunInfo) Reset()
func (*PipelineRunInfo) String ¶
func (x *PipelineRunInfo) String() string
type PipelineRunStatus ¶
type PipelineRunStatus struct { Spec string `protobuf:"bytes,2,opt,name=Spec,proto3" json:"Spec,omitempty"` // contains filtered or unexported fields }
func (*PipelineRunStatus) Descriptor
deprecated
func (*PipelineRunStatus) Descriptor() ([]byte, []int)
Deprecated: Use PipelineRunStatus.ProtoReflect.Descriptor instead.
func (*PipelineRunStatus) GetSpec ¶
func (x *PipelineRunStatus) GetSpec() string
func (*PipelineRunStatus) ProtoMessage ¶
func (*PipelineRunStatus) ProtoMessage()
func (*PipelineRunStatus) ProtoReflect ¶
func (x *PipelineRunStatus) ProtoReflect() protoreflect.Message
func (*PipelineRunStatus) Reset ¶
func (x *PipelineRunStatus) Reset()
func (*PipelineRunStatus) String ¶
func (x *PipelineRunStatus) String() string
type PipelineStatus ¶
type PipelineStatus struct { // Executor contains the name of the agent which ran the pipeline. Executor string `protobuf:"bytes,1,opt,name=Executor,proto3" json:"Executor,omitempty"` // status contains the current status of the pipeline. // It can be one of the preconfigured statuses for a pipeline. Status string `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"` // contains filtered or unexported fields }
func (*PipelineStatus) Descriptor
deprecated
func (*PipelineStatus) Descriptor() ([]byte, []int)
Deprecated: Use PipelineStatus.ProtoReflect.Descriptor instead.
func (*PipelineStatus) GetExecutor ¶
func (x *PipelineStatus) GetExecutor() string
func (*PipelineStatus) GetStatus ¶
func (x *PipelineStatus) GetStatus() string
func (*PipelineStatus) ProtoMessage ¶
func (*PipelineStatus) ProtoMessage()
func (*PipelineStatus) ProtoReflect ¶
func (x *PipelineStatus) ProtoReflect() protoreflect.Message
func (*PipelineStatus) Reset ¶
func (x *PipelineStatus) Reset()
func (*PipelineStatus) String ¶
func (x *PipelineStatus) String() string
type PipelinesRunInfo ¶
type PipelinesRunInfo struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` ErrorMessage string `protobuf:"bytes,2,opt,name=ErrorMessage,proto3" json:"ErrorMessage,omitempty"` Pipelines []*PipelineRunInfo `protobuf:"bytes,3,rep,name=Pipelines,proto3" json:"Pipelines,omitempty"` // contains filtered or unexported fields }
func (*PipelinesRunInfo) Descriptor
deprecated
func (*PipelinesRunInfo) Descriptor() ([]byte, []int)
Deprecated: Use PipelinesRunInfo.ProtoReflect.Descriptor instead.
func (*PipelinesRunInfo) GetErrorMessage ¶
func (x *PipelinesRunInfo) GetErrorMessage() string
func (*PipelinesRunInfo) GetName ¶
func (x *PipelinesRunInfo) GetName() string
func (*PipelinesRunInfo) GetPipelines ¶
func (x *PipelinesRunInfo) GetPipelines() []*PipelineRunInfo
func (*PipelinesRunInfo) ProtoMessage ¶
func (*PipelinesRunInfo) ProtoMessage()
func (*PipelinesRunInfo) ProtoReflect ¶
func (x *PipelinesRunInfo) ProtoReflect() protoreflect.Message
func (*PipelinesRunInfo) Reset ¶
func (x *PipelinesRunInfo) Reset()
func (*PipelinesRunInfo) String ¶
func (x *PipelinesRunInfo) String() string
type StatusOpts ¶
type StatusOpts struct { // Verbose specify if the status information returned should be verbose or not. Verbose bool `protobuf:"varint,1,opt,name=Verbose,proto3" json:"Verbose,omitempty"` // contains filtered or unexported fields }
func (*StatusOpts) Descriptor
deprecated
func (*StatusOpts) Descriptor() ([]byte, []int)
Deprecated: Use StatusOpts.ProtoReflect.Descriptor instead.
func (*StatusOpts) GetVerbose ¶
func (x *StatusOpts) GetVerbose() bool
func (*StatusOpts) ProtoMessage ¶
func (*StatusOpts) ProtoMessage()
func (*StatusOpts) ProtoReflect ¶
func (x *StatusOpts) ProtoReflect() protoreflect.Message
func (*StatusOpts) Reset ¶
func (x *StatusOpts) Reset()
func (*StatusOpts) String ¶
func (x *StatusOpts) String() string
type TriggerOpts ¶
type TriggerOpts struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Workflow string `protobuf:"bytes,2,opt,name=Workflow,proto3" json:"Workflow,omitempty"` Pipeline string `protobuf:"bytes,3,opt,name=Pipeline,proto3" json:"Pipeline,omitempty"` // contains filtered or unexported fields }
func (*TriggerOpts) Descriptor
deprecated
func (*TriggerOpts) Descriptor() ([]byte, []int)
Deprecated: Use TriggerOpts.ProtoReflect.Descriptor instead.
func (*TriggerOpts) GetName ¶
func (x *TriggerOpts) GetName() string
func (*TriggerOpts) GetPipeline ¶
func (x *TriggerOpts) GetPipeline() string
func (*TriggerOpts) GetWorkflow ¶
func (x *TriggerOpts) GetWorkflow() string
func (*TriggerOpts) ProtoMessage ¶
func (*TriggerOpts) ProtoMessage()
func (*TriggerOpts) ProtoReflect ¶
func (x *TriggerOpts) ProtoReflect() protoreflect.Message
func (*TriggerOpts) Reset ¶
func (x *TriggerOpts) Reset()
func (*TriggerOpts) String ¶
func (x *TriggerOpts) String() string
type TriggerRunInfo ¶
type TriggerRunInfo struct { Agent string `protobuf:"bytes,1,opt,name=Agent,proto3" json:"Agent,omitempty"` Status string `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"` // contains filtered or unexported fields }
func (*TriggerRunInfo) Descriptor
deprecated
func (*TriggerRunInfo) Descriptor() ([]byte, []int)
Deprecated: Use TriggerRunInfo.ProtoReflect.Descriptor instead.
func (*TriggerRunInfo) GetAgent ¶
func (x *TriggerRunInfo) GetAgent() string
func (*TriggerRunInfo) GetStatus ¶
func (x *TriggerRunInfo) GetStatus() string
func (*TriggerRunInfo) ProtoMessage ¶
func (*TriggerRunInfo) ProtoMessage()
func (*TriggerRunInfo) ProtoReflect ¶
func (x *TriggerRunInfo) ProtoReflect() protoreflect.Message
func (*TriggerRunInfo) Reset ¶
func (x *TriggerRunInfo) Reset()
func (*TriggerRunInfo) String ¶
func (x *TriggerRunInfo) String() string
type UnimplementedAgentServiceServer ¶
type UnimplementedAgentServiceServer struct { }
UnimplementedAgentServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAgentServiceServer) GetPipelineRunStatus ¶
func (*UnimplementedAgentServiceServer) GetPipelineRunStatus(context.Context, *PipelineInfoOpts) (*PipelineRunStatus, error)
func (*UnimplementedAgentServiceServer) GetPipelinesRunInfo ¶
func (*UnimplementedAgentServiceServer) GetPipelinesRunInfo(context.Context, *PipelineInfoOpts) (*PipelinesRunInfo, error)
func (*UnimplementedAgentServiceServer) Info ¶
func (*UnimplementedAgentServiceServer) Info(context.Context, *AgentInfoOpts) (*AgentInfo, error)
func (*UnimplementedAgentServiceServer) InvokeTrigger ¶
func (*UnimplementedAgentServiceServer) InvokeTrigger(context.Context, *TriggerOpts) (*TriggerRunInfo, error)
func (*UnimplementedAgentServiceServer) RemovePipeline ¶
func (*UnimplementedAgentServiceServer) RemovePipeline(context.Context, *Pipeline) (*PipelineStatus, error)
func (*UnimplementedAgentServiceServer) SchedulePipeline ¶
func (*UnimplementedAgentServiceServer) SchedulePipeline(context.Context, *Pipeline) (*PipelineStatus, error)
func (*UnimplementedAgentServiceServer) Status ¶
func (*UnimplementedAgentServiceServer) Status(context.Context, *StatusOpts) (*AgentStatus, error)
func (*UnimplementedAgentServiceServer) UpdatePipeline ¶
func (*UnimplementedAgentServiceServer) UpdatePipeline(context.Context, *Pipeline) (*PipelineStatus, error)