pipeline

Oct 6, 2021

Changes in this version

+ var ErrIntOverflowPipeline = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthPipeline = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupPipeline = fmt.Errorf("proto: unexpected end of group")

+ func RegisterPipelineServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterPipelineServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PipelineServiceClient) error

+ func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterPipelineServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PipelineServiceServer) error

+ func RegisterPipelineServiceServer(s *grpc.Server, srv PipelineServiceServer)

+ type DeletePipelineRequest struct

+ DeleteOptions *v1.DeleteOptions

+ Name string

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletePipelineRequest) Descriptor() ([]byte, []int)

+ func (*DeletePipelineRequest) ProtoMessage()

+ func (m *DeletePipelineRequest) GetDeleteOptions() *v1.DeleteOptions

+ func (m *DeletePipelineRequest) GetName() string

+ func (m *DeletePipelineRequest) GetNamespace() string

+ func (m *DeletePipelineRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeletePipelineRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeletePipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeletePipelineRequest) Reset()

+ func (m *DeletePipelineRequest) Size() (n int)

+ func (m *DeletePipelineRequest) String() string

+ func (m *DeletePipelineRequest) Unmarshal(dAtA []byte) error

+ func (m *DeletePipelineRequest) XXX_DiscardUnknown()

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

+ func (m *DeletePipelineRequest) XXX_Merge(src proto.Message)

+ func (m *DeletePipelineRequest) XXX_Size() int

+ func (m *DeletePipelineRequest) XXX_Unmarshal(b []byte) error

+ type DeletePipelineResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletePipelineResponse) Descriptor() ([]byte, []int)

+ func (*DeletePipelineResponse) ProtoMessage()

+ func (m *DeletePipelineResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeletePipelineResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeletePipelineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DeletePipelineResponse) Reset()

+ func (m *DeletePipelineResponse) Size() (n int)

+ func (m *DeletePipelineResponse) String() string

+ func (m *DeletePipelineResponse) Unmarshal(dAtA []byte) error

+ func (m *DeletePipelineResponse) XXX_DiscardUnknown()

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

+ func (m *DeletePipelineResponse) XXX_Merge(src proto.Message)

+ func (m *DeletePipelineResponse) XXX_Size() int

+ func (m *DeletePipelineResponse) XXX_Unmarshal(b []byte) error

+ type GetPipelineRequest struct

+ GetOptions *v1.GetOptions

+ Name string

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetPipelineRequest) Descriptor() ([]byte, []int)

+ func (*GetPipelineRequest) ProtoMessage()

+ func (m *GetPipelineRequest) GetGetOptions() *v1.GetOptions

+ func (m *GetPipelineRequest) GetName() string

+ func (m *GetPipelineRequest) GetNamespace() string

+ func (m *GetPipelineRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetPipelineRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GetPipelineRequest) Reset()

+ func (m *GetPipelineRequest) Size() (n int)

+ func (m *GetPipelineRequest) String() string

+ func (m *GetPipelineRequest) Unmarshal(dAtA []byte) error

+ func (m *GetPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *GetPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *GetPipelineRequest) XXX_Size() int

+ func (m *GetPipelineRequest) XXX_Unmarshal(b []byte) error

+ type ListPipelinesRequest struct

+ ListOptions *v1.ListOptions

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListPipelinesRequest) Descriptor() ([]byte, []int)

+ func (*ListPipelinesRequest) ProtoMessage()

+ func (m *ListPipelinesRequest) GetListOptions() *v1.ListOptions

+ func (m *ListPipelinesRequest) GetNamespace() string

+ func (m *ListPipelinesRequest) Marshal() (dAtA []byte, err error)

+ func (m *ListPipelinesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ListPipelinesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ListPipelinesRequest) Reset()

+ func (m *ListPipelinesRequest) Size() (n int)

+ func (m *ListPipelinesRequest) String() string

+ func (m *ListPipelinesRequest) Unmarshal(dAtA []byte) error

+ func (m *ListPipelinesRequest) XXX_DiscardUnknown()

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

+ func (m *ListPipelinesRequest) XXX_Merge(src proto.Message)

+ func (m *ListPipelinesRequest) XXX_Size() int

+ func (m *ListPipelinesRequest) XXX_Unmarshal(b []byte) error

+ type LogEntry struct

+ Msg string

+ Namespace string

+ PipelineName string

+ StepName string

+ Time *v1.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogEntry) Descriptor() ([]byte, []int)

+ func (*LogEntry) ProtoMessage()

+ func (m *LogEntry) GetMsg() string

+ func (m *LogEntry) GetNamespace() string

+ func (m *LogEntry) GetPipelineName() string

+ func (m *LogEntry) GetStepName() string

+ func (m *LogEntry) GetTime() *v1.Time

+ func (m *LogEntry) Marshal() (dAtA []byte, err error)

+ func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

+ func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *LogEntry) Reset()

+ func (m *LogEntry) Size() (n int)

+ func (m *LogEntry) String() string

+ func (m *LogEntry) Unmarshal(dAtA []byte) error

+ func (m *LogEntry) XXX_DiscardUnknown()

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

+ func (m *LogEntry) XXX_Merge(src proto.Message)

+ func (m *LogEntry) XXX_Size() int

+ func (m *LogEntry) XXX_Unmarshal(b []byte) error

+ type PipelineLogsRequest struct

+ Grep string

+ Name string

+ Namespace string

+ PodLogOptions *v11.PodLogOptions

+ StepName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PipelineLogsRequest) Descriptor() ([]byte, []int)

+ func (*PipelineLogsRequest) ProtoMessage()

+ func (m *PipelineLogsRequest) GetGrep() string

+ func (m *PipelineLogsRequest) GetName() string

+ func (m *PipelineLogsRequest) GetNamespace() string

+ func (m *PipelineLogsRequest) GetPodLogOptions() *v11.PodLogOptions

+ func (m *PipelineLogsRequest) GetStepName() string

+ func (m *PipelineLogsRequest) Marshal() (dAtA []byte, err error)

+ func (m *PipelineLogsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PipelineLogsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PipelineLogsRequest) Reset()

+ func (m *PipelineLogsRequest) Size() (n int)

+ func (m *PipelineLogsRequest) String() string

+ func (m *PipelineLogsRequest) Unmarshal(dAtA []byte) error

+ func (m *PipelineLogsRequest) XXX_DiscardUnknown()

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

+ func (m *PipelineLogsRequest) XXX_Merge(src proto.Message)

+ func (m *PipelineLogsRequest) XXX_Size() int

+ func (m *PipelineLogsRequest) XXX_Unmarshal(b []byte) error

+ type PipelineServiceClient interface

+ DeletePipeline func(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error)

+ GetPipeline func(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*v1alpha1.Pipeline, error)

+ ListPipelines func(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*v1alpha1.PipelineList, error)

+ PipelineLogs func(ctx context.Context, in *PipelineLogsRequest, opts ...grpc.CallOption) (PipelineService_PipelineLogsClient, error)

+ RestartPipeline func(ctx context.Context, in *RestartPipelineRequest, opts ...grpc.CallOption) (*RestartPipelineResponse, error)

+ WatchPipelines func(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (PipelineService_WatchPipelinesClient, error)

+ WatchSteps func(ctx context.Context, in *WatchStepRequest, opts ...grpc.CallOption) (PipelineService_WatchStepsClient, error)

+ func NewPipelineServiceClient(cc *grpc.ClientConn) PipelineServiceClient

+ type PipelineServiceServer interface

+ DeletePipeline func(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)

+ GetPipeline func(context.Context, *GetPipelineRequest) (*v1alpha1.Pipeline, error)

+ ListPipelines func(context.Context, *ListPipelinesRequest) (*v1alpha1.PipelineList, error)

+ PipelineLogs func(*PipelineLogsRequest, PipelineService_PipelineLogsServer) error

+ RestartPipeline func(context.Context, *RestartPipelineRequest) (*RestartPipelineResponse, error)

+ WatchPipelines func(*ListPipelinesRequest, PipelineService_WatchPipelinesServer) error

+ WatchSteps func(*WatchStepRequest, PipelineService_WatchStepsServer) error

+ type PipelineService_PipelineLogsClient interface

+ Recv func() (*LogEntry, error)

+ type PipelineService_PipelineLogsServer interface

+ Send func(*LogEntry) error

+ type PipelineService_WatchPipelinesClient interface

+ Recv func() (*PipelineWatchEvent, error)

+ type PipelineService_WatchPipelinesServer interface

+ Send func(*PipelineWatchEvent) error

+ type PipelineService_WatchStepsClient interface

+ Recv func() (*StepWatchEvent, error)

+ type PipelineService_WatchStepsServer interface

+ Send func(*StepWatchEvent) error

+ type PipelineWatchEvent struct

+ Object *v1alpha1.Pipeline

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PipelineWatchEvent) Descriptor() ([]byte, []int)

+ func (*PipelineWatchEvent) ProtoMessage()

+ func (m *PipelineWatchEvent) GetObject() *v1alpha1.Pipeline

+ func (m *PipelineWatchEvent) GetType() string

+ func (m *PipelineWatchEvent) Marshal() (dAtA []byte, err error)

+ func (m *PipelineWatchEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *PipelineWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PipelineWatchEvent) Reset()

+ func (m *PipelineWatchEvent) Size() (n int)

+ func (m *PipelineWatchEvent) String() string

+ func (m *PipelineWatchEvent) Unmarshal(dAtA []byte) error

+ func (m *PipelineWatchEvent) XXX_DiscardUnknown()

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

+ func (m *PipelineWatchEvent) XXX_Merge(src proto.Message)

+ func (m *PipelineWatchEvent) XXX_Size() int

+ func (m *PipelineWatchEvent) XXX_Unmarshal(b []byte) error

+ type RestartPipelineRequest struct

+ Name string

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RestartPipelineRequest) Descriptor() ([]byte, []int)

+ func (*RestartPipelineRequest) ProtoMessage()

+ func (m *RestartPipelineRequest) GetName() string

+ func (m *RestartPipelineRequest) GetNamespace() string

+ func (m *RestartPipelineRequest) Marshal() (dAtA []byte, err error)

+ func (m *RestartPipelineRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RestartPipelineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RestartPipelineRequest) Reset()

+ func (m *RestartPipelineRequest) Size() (n int)

+ func (m *RestartPipelineRequest) String() string

+ func (m *RestartPipelineRequest) Unmarshal(dAtA []byte) error

+ func (m *RestartPipelineRequest) XXX_DiscardUnknown()

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

+ func (m *RestartPipelineRequest) XXX_Merge(src proto.Message)

+ func (m *RestartPipelineRequest) XXX_Size() int

+ func (m *RestartPipelineRequest) XXX_Unmarshal(b []byte) error

+ type RestartPipelineResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RestartPipelineResponse) Descriptor() ([]byte, []int)

+ func (*RestartPipelineResponse) ProtoMessage()

+ func (m *RestartPipelineResponse) Marshal() (dAtA []byte, err error)

+ func (m *RestartPipelineResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *RestartPipelineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RestartPipelineResponse) Reset()

+ func (m *RestartPipelineResponse) Size() (n int)

+ func (m *RestartPipelineResponse) String() string

+ func (m *RestartPipelineResponse) Unmarshal(dAtA []byte) error

+ func (m *RestartPipelineResponse) XXX_DiscardUnknown()

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

+ func (m *RestartPipelineResponse) XXX_Merge(src proto.Message)

+ func (m *RestartPipelineResponse) XXX_Size() int

+ func (m *RestartPipelineResponse) XXX_Unmarshal(b []byte) error

+ type StepWatchEvent struct

+ Object *v1alpha1.Step

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StepWatchEvent) Descriptor() ([]byte, []int)

+ func (*StepWatchEvent) ProtoMessage()

+ func (m *StepWatchEvent) GetObject() *v1alpha1.Step

+ func (m *StepWatchEvent) GetType() string

+ func (m *StepWatchEvent) Marshal() (dAtA []byte, err error)

+ func (m *StepWatchEvent) MarshalTo(dAtA []byte) (int, error)

+ func (m *StepWatchEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StepWatchEvent) Reset()

+ func (m *StepWatchEvent) Size() (n int)

+ func (m *StepWatchEvent) String() string

+ func (m *StepWatchEvent) Unmarshal(dAtA []byte) error

+ func (m *StepWatchEvent) XXX_DiscardUnknown()

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

+ func (m *StepWatchEvent) XXX_Merge(src proto.Message)

+ func (m *StepWatchEvent) XXX_Size() int

+ func (m *StepWatchEvent) XXX_Unmarshal(b []byte) error

+ type UnimplementedPipelineServiceServer struct

+ func (*UnimplementedPipelineServiceServer) DeletePipeline(ctx context.Context, req *DeletePipelineRequest) (*DeletePipelineResponse, error)

+ func (*UnimplementedPipelineServiceServer) GetPipeline(ctx context.Context, req *GetPipelineRequest) (*v1alpha1.Pipeline, error)

+ func (*UnimplementedPipelineServiceServer) ListPipelines(ctx context.Context, req *ListPipelinesRequest) (*v1alpha1.PipelineList, error)

+ func (*UnimplementedPipelineServiceServer) PipelineLogs(req *PipelineLogsRequest, srv PipelineService_PipelineLogsServer) error

+ func (*UnimplementedPipelineServiceServer) RestartPipeline(ctx context.Context, req *RestartPipelineRequest) (*RestartPipelineResponse, error)

+ func (*UnimplementedPipelineServiceServer) WatchPipelines(req *ListPipelinesRequest, srv PipelineService_WatchPipelinesServer) error

+ func (*UnimplementedPipelineServiceServer) WatchSteps(req *WatchStepRequest, srv PipelineService_WatchStepsServer) error

+ type WatchStepRequest struct

+ ListOptions *v1.ListOptions

+ Namespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WatchStepRequest) Descriptor() ([]byte, []int)

+ func (*WatchStepRequest) ProtoMessage()

+ func (m *WatchStepRequest) GetListOptions() *v1.ListOptions

+ func (m *WatchStepRequest) GetNamespace() string

+ func (m *WatchStepRequest) Marshal() (dAtA []byte, err error)

+ func (m *WatchStepRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *WatchStepRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchStepRequest) Reset()

+ func (m *WatchStepRequest) Size() (n int)

+ func (m *WatchStepRequest) String() string

+ func (m *WatchStepRequest) Unmarshal(dAtA []byte) error

+ func (m *WatchStepRequest) XXX_DiscardUnknown()

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

+ func (m *WatchStepRequest) XXX_Merge(src proto.Message)

+ func (m *WatchStepRequest) XXX_Size() int

+ func (m *WatchStepRequest) XXX_Unmarshal(b []byte) error