v2_5_0

Documentation

Index

• Constants
• Variables
• func Migrate(state migrations.State) migrations.State
• type CommitInfo
  • func (*CommitInfo) Descriptor() ([]byte, []int)
  • func (x *CommitInfo) GetChildCommits() []*pfs.Commit
  • func (x *CommitInfo) GetCommit() *pfs.Commit
  • func (x *CommitInfo) GetDescription() string
  • func (x *CommitInfo) GetDetails() *pfs.CommitInfo_Details
  • func (x *CommitInfo) GetDirectProvenance() []*pfs.Branch
  • func (x *CommitInfo) GetError() string
  • func (x *CommitInfo) GetFinished() *timestamppb.Timestamp
  • func (x *CommitInfo) GetFinishing() *timestamppb.Timestamp
  • func (x *CommitInfo) GetOrigin() *pfs.CommitOrigin
  • func (x *CommitInfo) GetParentCommit() *pfs.Commit
  • func (x *CommitInfo) GetSizeBytesUpperBound() int64
  • func (x *CommitInfo) GetStarted() *timestamppb.Timestamp
  • func (x *CommitInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*CommitInfo) ProtoMessage()
  • func (x *CommitInfo) ProtoReflect() protoreflect.Message
  • func (x *CommitInfo) Reset()
  • func (x *CommitInfo) String() string
• type ErrExists
  • func (err ErrExists) Error() string
  • func (err ErrExists) Is(other error) bool
• type ErrNotFound
  • func (err ErrNotFound) Error() string
  • func (err ErrNotFound) Is(other error) bool

Constants

const DefaultPrefix string = "pachyderm/1.7.0"

Variables

var File_internal_clusterstate_v2_5_0_commit_info_proto protoreflect.FileDescriptor

Functions

func Migrate

func Migrate(state migrations.State) migrations.State

Types

type CommitInfo

type CommitInfo struct {
	Commit *pfs.Commit       `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
	Origin *pfs.CommitOrigin `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// description is a user-provided script describing this commit
	Description         string                  `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	ParentCommit        *pfs.Commit             `protobuf:"bytes,4,opt,name=parent_commit,json=parentCommit,proto3" json:"parent_commit,omitempty"`
	ChildCommits        []*pfs.Commit           `protobuf:"bytes,5,rep,name=child_commits,json=childCommits,proto3" json:"child_commits,omitempty"`
	Started             *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=started,proto3" json:"started,omitempty"`
	Finishing           *timestamppb.Timestamp  `protobuf:"bytes,7,opt,name=finishing,proto3" json:"finishing,omitempty"`
	Finished            *timestamppb.Timestamp  `protobuf:"bytes,8,opt,name=finished,proto3" json:"finished,omitempty"`
	DirectProvenance    []*pfs.Branch           `protobuf:"bytes,9,rep,name=direct_provenance,json=directProvenance,proto3" json:"direct_provenance,omitempty"`
	Error               string                  `protobuf:"bytes,10,opt,name=error,proto3" json:"error,omitempty"`
	SizeBytesUpperBound int64                   `protobuf:"varint,11,opt,name=size_bytes_upper_bound,json=sizeBytesUpperBound,proto3" json:"size_bytes_upper_bound,omitempty"`
	Details             *pfs.CommitInfo_Details `protobuf:"bytes,12,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

CommitInfo is the main data structure representing a commit in etcd

func (*CommitInfo) Descriptor

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

Deprecated: Use CommitInfo.ProtoReflect.Descriptor instead.

func (*CommitInfo) GetChildCommits

func (x *CommitInfo) GetChildCommits() []*pfs.Commit

func (*CommitInfo) GetCommit

func (x *CommitInfo) GetCommit() *pfs.Commit

func (*CommitInfo) GetDescription

func (x *CommitInfo) GetDescription() string

func (*CommitInfo) GetDetails

func (x *CommitInfo) GetDetails() *pfs.CommitInfo_Details

func (*CommitInfo) GetDirectProvenance

func (x *CommitInfo) GetDirectProvenance() []*pfs.Branch

func (*CommitInfo) GetError

func (x *CommitInfo) GetError() string

func (*CommitInfo) GetFinished

func (x *CommitInfo) GetFinished() *timestamppb.Timestamp

func (*CommitInfo) GetFinishing

func (x *CommitInfo) GetFinishing() *timestamppb.Timestamp

func (*CommitInfo) GetOrigin

func (x *CommitInfo) GetOrigin() *pfs.CommitOrigin

func (*CommitInfo) GetParentCommit

func (x *CommitInfo) GetParentCommit() *pfs.Commit

func (*CommitInfo) GetSizeBytesUpperBound

func (x *CommitInfo) GetSizeBytesUpperBound() int64

func (*CommitInfo) GetStarted

func (x *CommitInfo) GetStarted() *timestamppb.Timestamp

func (*CommitInfo) MarshalLogObject

func (x *CommitInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*CommitInfo) ProtoMessage

func (*CommitInfo) ProtoMessage()

func (*CommitInfo) ProtoReflect

func (x *CommitInfo) ProtoReflect() protoreflect.Message

func (*CommitInfo) Reset

func (x *CommitInfo) Reset()

func (*CommitInfo) String

func (x *CommitInfo) String() string

type ErrExists

type ErrExists struct {
	Type string
	Key  string
	// contains filtered or unexported fields
}

ErrExists indicates that a key was found to exist when it was expected not to.

func (ErrExists) Error

func (err ErrExists) Error() string

func (ErrExists) Is

func (err ErrExists) Is(other error) bool

type ErrNotFound

type ErrNotFound struct {
	Type string
	Key  string
	// contains filtered or unexported fields
}

ErrNotFound indicates that a key was not found when it was expected to exist.

func (ErrNotFound) Error

func (err ErrNotFound) Error() string

func (ErrNotFound) Is

func (err ErrNotFound) Is(other error) bool