pipeline

package
v3.0.0-...-8a51905 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package pipeline is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPipeline        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPipeline          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPipeline = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPipelineServiceHandler 

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

RegisterPipelineServiceHandler registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPipelineServiceHandlerClient 

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

RegisterPipelineServiceHandlerClient registers the http handlers for service PipelineService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PipelineServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PipelineServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PipelineServiceClient" to call the correct interceptors.

func RegisterPipelineServiceHandlerFromEndpoint 

func RegisterPipelineServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPipelineServiceHandlerFromEndpoint is same as RegisterPipelineServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPipelineServiceHandlerServer 

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

RegisterPipelineServiceHandlerServer registers the http handlers for service PipelineService to "mux". UnaryRPC :call PipelineServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPipelineServiceHandlerFromEndpoint instead.

func RegisterPipelineServiceServer 

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

Types

type DeletePipelineRequest 

type DeletePipelineRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DeleteOptions        *v1.DeleteOptions `protobuf:"bytes,3,opt,name=deleteOptions,proto3" json:"deleteOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DeletePipelineRequest) Descriptor 

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

func (*DeletePipelineRequest) GetDeleteOptions 

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

func (*DeletePipelineRequest) GetName 

func (m *DeletePipelineRequest) GetName() string

func (*DeletePipelineRequest) GetNamespace 

func (m *DeletePipelineRequest) GetNamespace() string

func (*DeletePipelineRequest) Marshal 

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

func (*DeletePipelineRequest) MarshalTo 

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

func (*DeletePipelineRequest) MarshalToSizedBuffer 

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

func (*DeletePipelineRequest) ProtoMessage 

func (*DeletePipelineRequest) ProtoMessage()

func (*DeletePipelineRequest) Reset 

func (m *DeletePipelineRequest) Reset()

func (*DeletePipelineRequest) Size 

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

func (*DeletePipelineRequest) String 

func (m *DeletePipelineRequest) String() string

func (*DeletePipelineRequest) Unmarshal 

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

func (*DeletePipelineRequest) XXX_DiscardUnknown 

func (m *DeletePipelineRequest) XXX_DiscardUnknown()

func (*DeletePipelineRequest) XXX_Marshal 

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

func (*DeletePipelineRequest) XXX_Merge 

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

func (*DeletePipelineRequest) XXX_Size 

func (m *DeletePipelineRequest) XXX_Size() int

func (*DeletePipelineRequest) XXX_Unmarshal 

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

type DeletePipelineResponse 

type DeletePipelineResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeletePipelineResponse) Descriptor 

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

func (*DeletePipelineResponse) Marshal 

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

func (*DeletePipelineResponse) MarshalTo 

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

func (*DeletePipelineResponse) MarshalToSizedBuffer 

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

func (*DeletePipelineResponse) ProtoMessage 

func (*DeletePipelineResponse) ProtoMessage()

func (*DeletePipelineResponse) Reset 

func (m *DeletePipelineResponse) Reset()

func (*DeletePipelineResponse) Size 

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

func (*DeletePipelineResponse) String 

func (m *DeletePipelineResponse) String() string

func (*DeletePipelineResponse) Unmarshal 

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

func (*DeletePipelineResponse) XXX_DiscardUnknown 

func (m *DeletePipelineResponse) XXX_DiscardUnknown()

func (*DeletePipelineResponse) XXX_Marshal 

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

func (*DeletePipelineResponse) XXX_Merge 

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

func (*DeletePipelineResponse) XXX_Size 

func (m *DeletePipelineResponse) XXX_Size() int

func (*DeletePipelineResponse) XXX_Unmarshal 

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

type GetPipelineRequest 

type GetPipelineRequest struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions           *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetPipelineRequest) Descriptor 

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

func (*GetPipelineRequest) GetGetOptions 

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

func (*GetPipelineRequest) GetName 

func (m *GetPipelineRequest) GetName() string

func (*GetPipelineRequest) GetNamespace 

func (m *GetPipelineRequest) GetNamespace() string

func (*GetPipelineRequest) Marshal 

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

func (*GetPipelineRequest) MarshalTo 

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

func (*GetPipelineRequest) MarshalToSizedBuffer 

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

func (*GetPipelineRequest) ProtoMessage 

func (*GetPipelineRequest) ProtoMessage()

func (*GetPipelineRequest) Reset 

func (m *GetPipelineRequest) Reset()

func (*GetPipelineRequest) Size 

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

func (*GetPipelineRequest) String 

func (m *GetPipelineRequest) String() string

func (*GetPipelineRequest) Unmarshal 

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

func (*GetPipelineRequest) XXX_DiscardUnknown 

func (m *GetPipelineRequest) XXX_DiscardUnknown()

func (*GetPipelineRequest) XXX_Marshal 

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

func (*GetPipelineRequest) XXX_Merge 

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

func (*GetPipelineRequest) XXX_Size 

func (m *GetPipelineRequest) XXX_Size() int

func (*GetPipelineRequest) XXX_Unmarshal 

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

type ListPipelinesRequest 

type ListPipelinesRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListPipelinesRequest) Descriptor 

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

func (*ListPipelinesRequest) GetListOptions 

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

func (*ListPipelinesRequest) GetNamespace 

func (m *ListPipelinesRequest) GetNamespace() string

func (*ListPipelinesRequest) Marshal 

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

func (*ListPipelinesRequest) MarshalTo 

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

func (*ListPipelinesRequest) MarshalToSizedBuffer 

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

func (*ListPipelinesRequest) ProtoMessage 

func (*ListPipelinesRequest) ProtoMessage()

func (*ListPipelinesRequest) Reset 

func (m *ListPipelinesRequest) Reset()

func (*ListPipelinesRequest) Size 

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

func (*ListPipelinesRequest) String 

func (m *ListPipelinesRequest) String() string

func (*ListPipelinesRequest) Unmarshal 

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

func (*ListPipelinesRequest) XXX_DiscardUnknown 

func (m *ListPipelinesRequest) XXX_DiscardUnknown()

func (*ListPipelinesRequest) XXX_Marshal 

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

func (*ListPipelinesRequest) XXX_Merge 

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

func (*ListPipelinesRequest) XXX_Size 

func (m *ListPipelinesRequest) XXX_Size() int

func (*ListPipelinesRequest) XXX_Unmarshal 

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

type LogEntry 

type LogEntry struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PipelineName         string   `protobuf:"bytes,2,opt,name=pipelineName,proto3" json:"pipelineName,omitempty"`
	StepName             string   `protobuf:"bytes,3,opt,name=stepName,proto3" json:"stepName,omitempty"`
	Time                 *v1.Time `protobuf:"bytes,6,opt,name=time,proto3" json:"time,omitempty"`
	Msg                  string   `protobuf:"bytes,7,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

structured log entry

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetMsg 

func (m *LogEntry) GetMsg() string

func (*LogEntry) GetNamespace 

func (m *LogEntry) GetNamespace() string

func (*LogEntry) GetPipelineName 

func (m *LogEntry) GetPipelineName() string

func (*LogEntry) GetStepName 

func (m *LogEntry) GetStepName() string

func (*LogEntry) GetTime 

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

func (*LogEntry) Marshal 

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

func (*LogEntry) MarshalTo 

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

func (*LogEntry) MarshalToSizedBuffer 

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

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

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

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

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

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type PipelineLogsRequest 

type PipelineLogsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// optional - only return entries for this pipeline
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// optional - only return entries for this step
	StepName string `protobuf:"bytes,3,opt,name=stepName,proto3" json:"stepName,omitempty"`
	// optional - only return entries which match this expresssion
	Grep                 string             `protobuf:"bytes,4,opt,name=grep,proto3" json:"grep,omitempty"`
	PodLogOptions        *v11.PodLogOptions `protobuf:"bytes,5,opt,name=podLogOptions,proto3" json:"podLogOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PipelineLogsRequest) Descriptor 

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

func (*PipelineLogsRequest) GetGrep 

func (m *PipelineLogsRequest) GetGrep() string

func (*PipelineLogsRequest) GetName 

func (m *PipelineLogsRequest) GetName() string

func (*PipelineLogsRequest) GetNamespace 

func (m *PipelineLogsRequest) GetNamespace() string

func (*PipelineLogsRequest) GetPodLogOptions 

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

func (*PipelineLogsRequest) GetStepName 

func (m *PipelineLogsRequest) GetStepName() string

func (*PipelineLogsRequest) Marshal 

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

func (*PipelineLogsRequest) MarshalTo 

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

func (*PipelineLogsRequest) MarshalToSizedBuffer 

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

func (*PipelineLogsRequest) ProtoMessage 

func (*PipelineLogsRequest) ProtoMessage()

func (*PipelineLogsRequest) Reset 

func (m *PipelineLogsRequest) Reset()

func (*PipelineLogsRequest) Size 

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

func (*PipelineLogsRequest) String 

func (m *PipelineLogsRequest) String() string

func (*PipelineLogsRequest) Unmarshal 

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

func (*PipelineLogsRequest) XXX_DiscardUnknown 

func (m *PipelineLogsRequest) XXX_DiscardUnknown()

func (*PipelineLogsRequest) XXX_Marshal 

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

func (*PipelineLogsRequest) XXX_Merge 

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

func (*PipelineLogsRequest) XXX_Size 

func (m *PipelineLogsRequest) XXX_Size() int

func (*PipelineLogsRequest) XXX_Unmarshal 

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

type PipelineServiceClient 

type PipelineServiceClient interface {
	ListPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (*v1alpha1.PipelineList, error)
	WatchPipelines(ctx context.Context, in *ListPipelinesRequest, opts ...grpc.CallOption) (PipelineService_WatchPipelinesClient, error)
	GetPipeline(ctx context.Context, in *GetPipelineRequest, opts ...grpc.CallOption) (*v1alpha1.Pipeline, error)
	RestartPipeline(ctx context.Context, in *RestartPipelineRequest, opts ...grpc.CallOption) (*RestartPipelineResponse, error)
	DeletePipeline(ctx context.Context, in *DeletePipelineRequest, opts ...grpc.CallOption) (*DeletePipelineResponse, error)
	PipelineLogs(ctx context.Context, in *PipelineLogsRequest, opts ...grpc.CallOption) (PipelineService_PipelineLogsClient, error)
	WatchSteps(ctx context.Context, in *WatchStepRequest, opts ...grpc.CallOption) (PipelineService_WatchStepsClient, error)
}

PipelineServiceClient is the client API for PipelineService service.

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

func NewPipelineServiceClient 

func NewPipelineServiceClient(cc *grpc.ClientConn) PipelineServiceClient

type PipelineServiceServer 

type PipelineServiceServer interface {
	ListPipelines(context.Context, *ListPipelinesRequest) (*v1alpha1.PipelineList, error)
	WatchPipelines(*ListPipelinesRequest, PipelineService_WatchPipelinesServer) error
	GetPipeline(context.Context, *GetPipelineRequest) (*v1alpha1.Pipeline, error)
	RestartPipeline(context.Context, *RestartPipelineRequest) (*RestartPipelineResponse, error)
	DeletePipeline(context.Context, *DeletePipelineRequest) (*DeletePipelineResponse, error)
	PipelineLogs(*PipelineLogsRequest, PipelineService_PipelineLogsServer) error
	WatchSteps(*WatchStepRequest, PipelineService_WatchStepsServer) error
}

PipelineServiceServer is the server API for PipelineService service.

type PipelineService_PipelineLogsClient 

type PipelineService_PipelineLogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type PipelineService_PipelineLogsServer 

type PipelineService_PipelineLogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type PipelineService_WatchPipelinesClient 

type PipelineService_WatchPipelinesClient interface {
	Recv() (*PipelineWatchEvent, error)
	grpc.ClientStream
}

type PipelineService_WatchPipelinesServer 

type PipelineService_WatchPipelinesServer interface {
	Send(*PipelineWatchEvent) error
	grpc.ServerStream
}

type PipelineService_WatchStepsClient 

type PipelineService_WatchStepsClient interface {
	Recv() (*StepWatchEvent, error)
	grpc.ClientStream
}

type PipelineService_WatchStepsServer 

type PipelineService_WatchStepsServer interface {
	Send(*StepWatchEvent) error
	grpc.ServerStream
}

type PipelineWatchEvent 

type PipelineWatchEvent struct {
	Type                 string             `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Object               *v1alpha1.Pipeline `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PipelineWatchEvent) Descriptor 

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

func (*PipelineWatchEvent) GetObject 

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

func (*PipelineWatchEvent) GetType 

func (m *PipelineWatchEvent) GetType() string

func (*PipelineWatchEvent) Marshal 

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

func (*PipelineWatchEvent) MarshalTo 

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

func (*PipelineWatchEvent) MarshalToSizedBuffer 

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

func (*PipelineWatchEvent) ProtoMessage 

func (*PipelineWatchEvent) ProtoMessage()

func (*PipelineWatchEvent) Reset 

func (m *PipelineWatchEvent) Reset()

func (*PipelineWatchEvent) Size 

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

func (*PipelineWatchEvent) String 

func (m *PipelineWatchEvent) String() string

func (*PipelineWatchEvent) Unmarshal 

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

func (*PipelineWatchEvent) XXX_DiscardUnknown 

func (m *PipelineWatchEvent) XXX_DiscardUnknown()

func (*PipelineWatchEvent) XXX_Marshal 

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

func (*PipelineWatchEvent) XXX_Merge 

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

func (*PipelineWatchEvent) XXX_Size 

func (m *PipelineWatchEvent) XXX_Size() int

func (*PipelineWatchEvent) XXX_Unmarshal 

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

type RestartPipelineRequest 

type RestartPipelineRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestartPipelineRequest) Descriptor 

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

func (*RestartPipelineRequest) GetName 

func (m *RestartPipelineRequest) GetName() string

func (*RestartPipelineRequest) GetNamespace 

func (m *RestartPipelineRequest) GetNamespace() string

func (*RestartPipelineRequest) Marshal 

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

func (*RestartPipelineRequest) MarshalTo 

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

func (*RestartPipelineRequest) MarshalToSizedBuffer 

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

func (*RestartPipelineRequest) ProtoMessage 

func (*RestartPipelineRequest) ProtoMessage()

func (*RestartPipelineRequest) Reset 

func (m *RestartPipelineRequest) Reset()

func (*RestartPipelineRequest) Size 

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

func (*RestartPipelineRequest) String 

func (m *RestartPipelineRequest) String() string

func (*RestartPipelineRequest) Unmarshal 

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

func (*RestartPipelineRequest) XXX_DiscardUnknown 

func (m *RestartPipelineRequest) XXX_DiscardUnknown()

func (*RestartPipelineRequest) XXX_Marshal 

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

func (*RestartPipelineRequest) XXX_Merge 

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

func (*RestartPipelineRequest) XXX_Size 

func (m *RestartPipelineRequest) XXX_Size() int

func (*RestartPipelineRequest) XXX_Unmarshal 

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

type RestartPipelineResponse 

type RestartPipelineResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestartPipelineResponse) Descriptor 

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

func (*RestartPipelineResponse) Marshal 

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

func (*RestartPipelineResponse) MarshalTo 

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

func (*RestartPipelineResponse) MarshalToSizedBuffer 

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

func (*RestartPipelineResponse) ProtoMessage 

func (*RestartPipelineResponse) ProtoMessage()

func (*RestartPipelineResponse) Reset 

func (m *RestartPipelineResponse) Reset()

func (*RestartPipelineResponse) Size 

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

func (*RestartPipelineResponse) String 

func (m *RestartPipelineResponse) String() string

func (*RestartPipelineResponse) Unmarshal 

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

func (*RestartPipelineResponse) XXX_DiscardUnknown 

func (m *RestartPipelineResponse) XXX_DiscardUnknown()

func (*RestartPipelineResponse) XXX_Marshal 

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

func (*RestartPipelineResponse) XXX_Merge 

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

func (*RestartPipelineResponse) XXX_Size 

func (m *RestartPipelineResponse) XXX_Size() int

func (*RestartPipelineResponse) XXX_Unmarshal 

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

type StepWatchEvent 

type StepWatchEvent struct {
	Type                 string         `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Object               *v1alpha1.Step `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*StepWatchEvent) Descriptor 

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

func (*StepWatchEvent) GetObject 

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

func (*StepWatchEvent) GetType 

func (m *StepWatchEvent) GetType() string

func (*StepWatchEvent) Marshal 

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

func (*StepWatchEvent) MarshalTo 

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

func (*StepWatchEvent) MarshalToSizedBuffer 

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

func (*StepWatchEvent) ProtoMessage 

func (*StepWatchEvent) ProtoMessage()

func (*StepWatchEvent) Reset 

func (m *StepWatchEvent) Reset()

func (*StepWatchEvent) Size 

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

func (*StepWatchEvent) String 

func (m *StepWatchEvent) String() string

func (*StepWatchEvent) Unmarshal 

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

func (*StepWatchEvent) XXX_DiscardUnknown 

func (m *StepWatchEvent) XXX_DiscardUnknown()

func (*StepWatchEvent) XXX_Marshal 

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

func (*StepWatchEvent) XXX_Merge 

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

func (*StepWatchEvent) XXX_Size 

func (m *StepWatchEvent) XXX_Size() int

func (*StepWatchEvent) XXX_Unmarshal 

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

type UnimplementedPipelineServiceServer 

type UnimplementedPipelineServiceServer struct {
}

UnimplementedPipelineServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipelineServiceServer) DeletePipeline 

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

func (*UnimplementedPipelineServiceServer) GetPipeline 

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

func (*UnimplementedPipelineServiceServer) ListPipelines 

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

func (*UnimplementedPipelineServiceServer) PipelineLogs 

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

func (*UnimplementedPipelineServiceServer) RestartPipeline 

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

func (*UnimplementedPipelineServiceServer) WatchPipelines 

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

func (*UnimplementedPipelineServiceServer) WatchSteps 

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

type WatchStepRequest 

type WatchStepRequest struct {
	Namespace            string          `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ListOptions          *v1.ListOptions `protobuf:"bytes,2,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WatchStepRequest) Descriptor 

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

func (*WatchStepRequest) GetListOptions 

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

func (*WatchStepRequest) GetNamespace 

func (m *WatchStepRequest) GetNamespace() string

func (*WatchStepRequest) Marshal 

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

func (*WatchStepRequest) MarshalTo 

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

func (*WatchStepRequest) MarshalToSizedBuffer 

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

func (*WatchStepRequest) ProtoMessage 

func (*WatchStepRequest) ProtoMessage()

func (*WatchStepRequest) Reset 

func (m *WatchStepRequest) Reset()

func (*WatchStepRequest) Size 

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

func (*WatchStepRequest) String 

func (m *WatchStepRequest) String() string

func (*WatchStepRequest) Unmarshal 

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

func (*WatchStepRequest) XXX_DiscardUnknown 

func (m *WatchStepRequest) XXX_DiscardUnknown()

func (*WatchStepRequest) XXX_Marshal 

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

func (*WatchStepRequest) XXX_Merge 

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

func (*WatchStepRequest) XXX_Size 

func (m *WatchStepRequest) XXX_Size() int

func (*WatchStepRequest) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.