v1

package
v0.4.670 Latest Latest
Warning

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

Go to latest
Published: Apr 5, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_github_com_metaprov_modelaapi_services_datapipelinerun_v1_datapipelinerun_proto protoreflect.FileDescriptor

Functions

func RegisterDataPipelineRunServiceServer

func RegisterDataPipelineRunServiceServer(s *grpc.Server, srv DataPipelineRunServiceServer)

Types

type AbortDataPipelineRunRequest

type AbortDataPipelineRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*AbortDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use AbortDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*AbortDataPipelineRunRequest) GetName

func (x *AbortDataPipelineRunRequest) GetName() string

func (*AbortDataPipelineRunRequest) GetNamespace

func (x *AbortDataPipelineRunRequest) GetNamespace() string

func (*AbortDataPipelineRunRequest) ProtoMessage

func (*AbortDataPipelineRunRequest) ProtoMessage()

func (*AbortDataPipelineRunRequest) ProtoReflect

func (*AbortDataPipelineRunRequest) Reset

func (x *AbortDataPipelineRunRequest) Reset()

func (*AbortDataPipelineRunRequest) String

func (x *AbortDataPipelineRunRequest) String() string

type AbortDataPipelineRunResponse

type AbortDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*AbortDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use AbortDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*AbortDataPipelineRunResponse) ProtoMessage

func (*AbortDataPipelineRunResponse) ProtoMessage()

func (*AbortDataPipelineRunResponse) ProtoReflect

func (*AbortDataPipelineRunResponse) Reset

func (x *AbortDataPipelineRunResponse) Reset()

func (*AbortDataPipelineRunResponse) String

type CreateDataPipelineRunRequest

type CreateDataPipelineRunRequest struct {
	Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use CreateDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*CreateDataPipelineRunRequest) GetDatapipelinerun added in v0.4.480

func (x *CreateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun

func (*CreateDataPipelineRunRequest) ProtoMessage

func (*CreateDataPipelineRunRequest) ProtoMessage()

func (*CreateDataPipelineRunRequest) ProtoReflect

func (*CreateDataPipelineRunRequest) Reset

func (x *CreateDataPipelineRunRequest) Reset()

func (*CreateDataPipelineRunRequest) String

type CreateDataPipelineRunResponse

type CreateDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*CreateDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use CreateDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*CreateDataPipelineRunResponse) ProtoMessage

func (*CreateDataPipelineRunResponse) ProtoMessage()

func (*CreateDataPipelineRunResponse) ProtoReflect

func (*CreateDataPipelineRunResponse) Reset

func (x *CreateDataPipelineRunResponse) Reset()

func (*CreateDataPipelineRunResponse) String

type DataPipelineRunServiceClient

DataPipelineRunServiceClient is the client API for DataPipelineRunService service.

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

type DeleteDataPipelineRunRequest

type DeleteDataPipelineRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use DeleteDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*DeleteDataPipelineRunRequest) GetName

func (x *DeleteDataPipelineRunRequest) GetName() string

func (*DeleteDataPipelineRunRequest) GetNamespace

func (x *DeleteDataPipelineRunRequest) GetNamespace() string

func (*DeleteDataPipelineRunRequest) ProtoMessage

func (*DeleteDataPipelineRunRequest) ProtoMessage()

func (*DeleteDataPipelineRunRequest) ProtoReflect

func (*DeleteDataPipelineRunRequest) Reset

func (x *DeleteDataPipelineRunRequest) Reset()

func (*DeleteDataPipelineRunRequest) String

type DeleteDataPipelineRunResponse

type DeleteDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use DeleteDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*DeleteDataPipelineRunResponse) ProtoMessage

func (*DeleteDataPipelineRunResponse) ProtoMessage()

func (*DeleteDataPipelineRunResponse) ProtoReflect

func (*DeleteDataPipelineRunResponse) Reset

func (x *DeleteDataPipelineRunResponse) Reset()

func (*DeleteDataPipelineRunResponse) String

type GetDataPipelineRunRequest

type GetDataPipelineRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use GetDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*GetDataPipelineRunRequest) GetName

func (x *GetDataPipelineRunRequest) GetName() string

func (*GetDataPipelineRunRequest) GetNamespace

func (x *GetDataPipelineRunRequest) GetNamespace() string

func (*GetDataPipelineRunRequest) ProtoMessage

func (*GetDataPipelineRunRequest) ProtoMessage()

func (*GetDataPipelineRunRequest) ProtoReflect

func (*GetDataPipelineRunRequest) Reset

func (x *GetDataPipelineRunRequest) Reset()

func (*GetDataPipelineRunRequest) String

func (x *GetDataPipelineRunRequest) String() string

type GetDataPipelineRunResponse

type GetDataPipelineRunResponse struct {
	Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"`
	Yaml            string                    `protobuf:"bytes,2,opt,name=yaml,proto3" json:"yaml,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use GetDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*GetDataPipelineRunResponse) GetDatapipelinerun added in v0.4.480

func (x *GetDataPipelineRunResponse) GetDatapipelinerun() *v1alpha1.DataPipelineRun

func (*GetDataPipelineRunResponse) GetYaml

func (x *GetDataPipelineRunResponse) GetYaml() string

func (*GetDataPipelineRunResponse) ProtoMessage

func (*GetDataPipelineRunResponse) ProtoMessage()

func (*GetDataPipelineRunResponse) ProtoReflect

func (*GetDataPipelineRunResponse) Reset

func (x *GetDataPipelineRunResponse) Reset()

func (*GetDataPipelineRunResponse) String

func (x *GetDataPipelineRunResponse) String() string

type ListDataPipelineRunRequest

type ListDataPipelineRunRequest struct {
	Namespace string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Labels    map[string]string `` /* 153-byte string literal not displayed */
	PageSize  int32             `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string            `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	OrderBy   string            `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use ListDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*ListDataPipelineRunRequest) GetLabels

func (x *ListDataPipelineRunRequest) GetLabels() map[string]string

func (*ListDataPipelineRunRequest) GetNamespace

func (x *ListDataPipelineRunRequest) GetNamespace() string

func (*ListDataPipelineRunRequest) GetOrderBy added in v0.4.414

func (x *ListDataPipelineRunRequest) GetOrderBy() string

func (*ListDataPipelineRunRequest) GetPageSize added in v0.4.414

func (x *ListDataPipelineRunRequest) GetPageSize() int32

func (*ListDataPipelineRunRequest) GetPageToken added in v0.4.414

func (x *ListDataPipelineRunRequest) GetPageToken() string

func (*ListDataPipelineRunRequest) ProtoMessage

func (*ListDataPipelineRunRequest) ProtoMessage()

func (*ListDataPipelineRunRequest) ProtoReflect

func (*ListDataPipelineRunRequest) Reset

func (x *ListDataPipelineRunRequest) Reset()

func (*ListDataPipelineRunRequest) String

func (x *ListDataPipelineRunRequest) String() string

type ListDataPipelineRunResponse

type ListDataPipelineRunResponse struct {
	Datapipelineruns *v1alpha1.DataPipelineRunList `protobuf:"bytes,1,opt,name=datapipelineruns,proto3" json:"datapipelineruns,omitempty"`
	NextPageToken    string                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use ListDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*ListDataPipelineRunResponse) GetDatapipelineruns added in v0.4.480

func (x *ListDataPipelineRunResponse) GetDatapipelineruns() *v1alpha1.DataPipelineRunList

func (*ListDataPipelineRunResponse) GetNextPageToken added in v0.4.472

func (x *ListDataPipelineRunResponse) GetNextPageToken() string

func (*ListDataPipelineRunResponse) ProtoMessage

func (*ListDataPipelineRunResponse) ProtoMessage()

func (*ListDataPipelineRunResponse) ProtoReflect

func (*ListDataPipelineRunResponse) Reset

func (x *ListDataPipelineRunResponse) Reset()

func (*ListDataPipelineRunResponse) String

func (x *ListDataPipelineRunResponse) String() string

type PauseDataPipelineRunRequest

type PauseDataPipelineRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use PauseDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*PauseDataPipelineRunRequest) GetName

func (x *PauseDataPipelineRunRequest) GetName() string

func (*PauseDataPipelineRunRequest) GetNamespace

func (x *PauseDataPipelineRunRequest) GetNamespace() string

func (*PauseDataPipelineRunRequest) ProtoMessage

func (*PauseDataPipelineRunRequest) ProtoMessage()

func (*PauseDataPipelineRunRequest) ProtoReflect

func (*PauseDataPipelineRunRequest) Reset

func (x *PauseDataPipelineRunRequest) Reset()

func (*PauseDataPipelineRunRequest) String

func (x *PauseDataPipelineRunRequest) String() string

type PauseDataPipelineRunResponse

type PauseDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*PauseDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use PauseDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*PauseDataPipelineRunResponse) ProtoMessage

func (*PauseDataPipelineRunResponse) ProtoMessage()

func (*PauseDataPipelineRunResponse) ProtoReflect

func (*PauseDataPipelineRunResponse) Reset

func (x *PauseDataPipelineRunResponse) Reset()

func (*PauseDataPipelineRunResponse) String

type ResumeDataPipelineRunRequest

type ResumeDataPipelineRunRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use ResumeDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*ResumeDataPipelineRunRequest) GetName

func (x *ResumeDataPipelineRunRequest) GetName() string

func (*ResumeDataPipelineRunRequest) GetNamespace

func (x *ResumeDataPipelineRunRequest) GetNamespace() string

func (*ResumeDataPipelineRunRequest) ProtoMessage

func (*ResumeDataPipelineRunRequest) ProtoMessage()

func (*ResumeDataPipelineRunRequest) ProtoReflect

func (*ResumeDataPipelineRunRequest) Reset

func (x *ResumeDataPipelineRunRequest) Reset()

func (*ResumeDataPipelineRunRequest) String

type ResumeDataPipelineRunResponse

type ResumeDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*ResumeDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use ResumeDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*ResumeDataPipelineRunResponse) ProtoMessage

func (*ResumeDataPipelineRunResponse) ProtoMessage()

func (*ResumeDataPipelineRunResponse) ProtoReflect

func (*ResumeDataPipelineRunResponse) Reset

func (x *ResumeDataPipelineRunResponse) Reset()

func (*ResumeDataPipelineRunResponse) String

type UnimplementedDataPipelineRunServiceServer

type UnimplementedDataPipelineRunServiceServer struct {
}

UnimplementedDataPipelineRunServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataPipelineRunServiceServer) AbortDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) CreateDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) DeleteDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) GetDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) ListDataPipelineRuns

func (*UnimplementedDataPipelineRunServiceServer) PauseDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) ResumeDataPipelineRun

func (*UnimplementedDataPipelineRunServiceServer) UpdateDataPipelineRun

type UpdateDataPipelineRunRequest

type UpdateDataPipelineRunRequest struct {
	Datapipelinerun *v1alpha1.DataPipelineRun `protobuf:"bytes,1,opt,name=datapipelinerun,proto3" json:"datapipelinerun,omitempty"`
	FieldMask       *field_mask.FieldMask     `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDataPipelineRunRequest) Descriptor deprecated

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

Deprecated: Use UpdateDataPipelineRunRequest.ProtoReflect.Descriptor instead.

func (*UpdateDataPipelineRunRequest) GetDatapipelinerun added in v0.4.480

func (x *UpdateDataPipelineRunRequest) GetDatapipelinerun() *v1alpha1.DataPipelineRun

func (*UpdateDataPipelineRunRequest) GetFieldMask added in v0.4.422

func (*UpdateDataPipelineRunRequest) ProtoMessage

func (*UpdateDataPipelineRunRequest) ProtoMessage()

func (*UpdateDataPipelineRunRequest) ProtoReflect

func (*UpdateDataPipelineRunRequest) Reset

func (x *UpdateDataPipelineRunRequest) Reset()

func (*UpdateDataPipelineRunRequest) String

type UpdateDataPipelineRunResponse

type UpdateDataPipelineRunResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateDataPipelineRunResponse) Descriptor deprecated

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

Deprecated: Use UpdateDataPipelineRunResponse.ProtoReflect.Descriptor instead.

func (*UpdateDataPipelineRunResponse) ProtoMessage

func (*UpdateDataPipelineRunResponse) ProtoMessage()

func (*UpdateDataPipelineRunResponse) ProtoReflect

func (*UpdateDataPipelineRunResponse) Reset

func (x *UpdateDataPipelineRunResponse) Reset()

func (*UpdateDataPipelineRunResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL