resource

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RawColumnRunningMessage       = "ingesting"
	AggregatorRunningMessage      = "aggregating"
	TransformerRunningMessage     = "transforming"
	TrainingDatasetRunningMessage = "generating"
	ModelRunningMessage           = "training"
)

StatusDataRunning aliases

Variables

View Source 
var (
	VisibleTypes = Types{
		RawColumnType,
		AggregateType,
		TransformedColumnType,
		TrainingDatasetType,
		ModelType,
		APIType,
	}
)

Functions

func APISavedStatusPtrsEqual 

func APISavedStatusPtrsEqual(savedStatus *APISavedStatus, savedStatus2 *APISavedStatus) bool

func DataSavedStatusPtrsEqual 

func DataSavedStatusPtrsEqual(savedStatus *DataSavedStatus, savedStatus2 *DataSavedStatus) bool

func ErrorBeMoreSpecific 

func ErrorBeMoreSpecific(vals ...string) error

func ErrorEmbedInTemplate 

func ErrorEmbedInTemplate() error

func ErrorInvalidType 

func ErrorInvalidType(invalid string) error

func ErrorNameNotFound 

func ErrorNameNotFound(name string) error

func ErrorNameOrTypeNotFound 

func ErrorNameOrTypeNotFound(nameOrType string) error

func ErrorNotFound 

func ErrorNotFound(name string, resourceType Type) error

func ErrorTemplateInTemplate 

func ErrorTemplateInTemplate() error

func ErrorUnknownKind 

func ErrorUnknownKind(name string) error

Types

type APIGroupStatus 

type APIGroupStatus struct {
	APIName      string     `json:"api_name"`
	Start        *time.Time `json:"start"`
	ActiveStatus *APIStatus `json:"active_status"`
	Code         StatusCode `json:"status_code"`
}

func (*APIGroupStatus) GetCode 

func (status *APIGroupStatus) GetCode() StatusCode

func (*APIGroupStatus) Message 

func (status *APIGroupStatus) Message() string

type APISavedStatus 

type APISavedStatus struct {
	BaseSavedStatus
	APIName string `json:"api_name"`
}

func (*APISavedStatus) Copy 

func (savedStatus *APISavedStatus) Copy() *APISavedStatus

func (*APISavedStatus) Equal 

func (savedStatus *APISavedStatus) Equal(savedStatus2 APISavedStatus) bool

type APIStatus 

type APIStatus struct {
	APISavedStatus
	Path              string `json:"path"`
	RequestedReplicas int32  `json:"requested_replicas"`
	ReplicaCounts     `json:"replica_counts"`
	Code              StatusCode `json:"status_code"`
}

func (*APIStatus) GetCode 

func (status *APIStatus) GetCode() StatusCode

func (*APIStatus) Message 

func (status *APIStatus) Message() string

type BaseSavedStatus 

type BaseSavedStatus struct {
	ResourceID   string     `json:"resource_id"`
	ResourceType Type       `json:"resource_type"`
	WorkloadID   string     `json:"workload_id"`
	AppName      string     `json:"app_name"`
	Start        *time.Time `json:"start"`
	End          *time.Time `json:"end"`
}

func (*BaseSavedStatus) Copy 

func (savedStatus *BaseSavedStatus) Copy() *BaseSavedStatus

func (*BaseSavedStatus) Equal 

func (savedStatus *BaseSavedStatus) Equal(savedStatus2 BaseSavedStatus) bool

type DataExitCode 

type DataExitCode string
const (
	ExitCodeDataSucceeded DataExitCode = "succeeded"
	ExitCodeDataFailed    DataExitCode = "failed"
	ExitCodeDataKilled    DataExitCode = "killed"
	ExitCodeDataOOM       DataExitCode = "oom"
)

type DataSavedStatus 

type DataSavedStatus struct {
	BaseSavedStatus
	ExitCode DataExitCode `json:"exit_code"`
}

func (*DataSavedStatus) Copy 

func (savedStatus *DataSavedStatus) Copy() *DataSavedStatus

func (*DataSavedStatus) Equal 

func (savedStatus *DataSavedStatus) Equal(savedStatus2 DataSavedStatus) bool

type DataStatus 

type DataStatus struct {
	DataSavedStatus
	Code StatusCode `json:"status_code"`
}

func (*DataStatus) GetCode 

func (status *DataStatus) GetCode() StatusCode

func (*DataStatus) Message 

func (status *DataStatus) Message() string

type Error 

type Error struct {
	Kind ErrorKind
	// contains filtered or unexported fields
}

func (Error) Error 

func (e Error) Error() string

type ErrorKind 

type ErrorKind int
const (
	ErrUnknown ErrorKind = iota
	ErrUnknownKind
	ErrNotFound
	ErrNameNotFound
	ErrNameOrTypeNotFound
	ErrInvalidType
	ErrTemplateInTemplate
	ErrEmbedInTemplate
	ErrBeMoreSpecific
)

func (ErrorKind) MarshalBinary 

func (t ErrorKind) MarshalBinary() ([]byte, error)

MarshalBinary satisfies BinaryMarshaler

func (ErrorKind) MarshalText 

func (t ErrorKind) MarshalText() ([]byte, error)

MarshalText satisfies TextMarshaler

func (ErrorKind) String 

func (t ErrorKind) String() string

func (*ErrorKind) UnmarshalBinary 

func (t *ErrorKind) UnmarshalBinary(data []byte) error

UnmarshalBinary satisfies BinaryUnmarshaler Needed for msgpack

func (*ErrorKind) UnmarshalText 

func (t *ErrorKind) UnmarshalText(text []byte) error

UnmarshalText satisfies TextUnmarshaler

type ReplicaCounts 

type ReplicaCounts struct {
	ReadyUpdated        int32 `json:"ready_updated"`
	ReadyStaleCompute   int32 `json:"ready_stale_compute"`
	ReadyStaleResource  int32 `json:"ready_stale_resource"`
	FailedUpdated       int32 `json:"failed_updated"`
	FailedStaleCompute  int32 `json:"failed_stale_compute"`
	FailedStaleResource int32 `json:"failed_stale_resource"`
}

func (*ReplicaCounts) TotalReady 

func (replicaCounts *ReplicaCounts) TotalReady() int32

func (*ReplicaCounts) TotalStale 

func (replicaCounts *ReplicaCounts) TotalStale() int32

func (*ReplicaCounts) TotalStaleReady 

func (replicaCounts *ReplicaCounts) TotalStaleReady() int32

type Status 

type Status interface {
	Message() string
	GetCode() StatusCode
}

type StatusCode 

type StatusCode int
const (
	StatusUnknown StatusCode = iota

	// Shared statuses
	StatusPending // Resource is pending other non-ready resources
	StatusPendingCompute
	StatusWaiting // Resource can be created based on resource DAG, but hasn't started yet
	StatusSkipped
	StatusParentFailed
	StatusParentKilled
	StatusKilledOOM

	// Data statuses
	StatusRunning
	StatusSucceeded
	StatusFailed
	StatusKilled

	// API statuses
	StatusUpdating
	StatusReady
	StatusStopping
	StatusStopped
	StatusError

	// Additional API group statuses (i.e. aggregated API status)
	StatusPendingUpdate
	StatusUpdateSkipped
)

func (StatusCode) MarshalBinary 

func (code StatusCode) MarshalBinary() ([]byte, error)

MarshalBinary satisfies BinaryMarshaler

func (StatusCode) MarshalText 

func (code StatusCode) MarshalText() ([]byte, error)

MarshalText satisfies TextMarshaler

func (StatusCode) Message 

func (code StatusCode) Message() string

func (StatusCode) SortBucket 

func (code StatusCode) SortBucket() int

func (StatusCode) String 

func (code StatusCode) String() string

func (*StatusCode) UnmarshalBinary 

func (code *StatusCode) UnmarshalBinary(data []byte) error

UnmarshalBinary satisfies BinaryUnmarshaler Needed for msgpack

func (*StatusCode) UnmarshalText 

func (code *StatusCode) UnmarshalText(text []byte) error

UnmarshalText satisfies TextUnmarshaler

type Type 

type Type int
const (
	UnknownType           Type = iota // 0
	AppType                           // 1
	RawColumnType                     // 2
	TransformedColumnType             // 3
	AggregateType                     // 4
	APIType                           // 5
	ModelType                         // 6
	EnvironmentType                   // 7
	AggregatorType                    // 8
	TransformerType                   // 9
	EstimatorType                     // 10
	TemplateType                      // 11
	EmbedType                         // 12
	TrainingDatasetType               // 13
	ConstantType                      // 14
	PythonPackageType                 // 15
)

func TypeFromKindString 

func TypeFromKindString(s string) Type

func TypeFromString 

func TypeFromString(s string) Type

func VisibleResourceTypeFromPrefix 

func VisibleResourceTypeFromPrefix(prefix string) (Type, error)

func (Type) MarshalBinary 

func (t Type) MarshalBinary() ([]byte, error)

MarshalBinary satisfies BinaryMarshaler

func (Type) MarshalText 

func (t Type) MarshalText() ([]byte, error)

MarshalText satisfies TextMarshaler

func (Type) Plural 

func (t Type) Plural() string

func (Type) String 

func (t Type) String() string

func (*Type) UnmarshalBinary 

func (t *Type) UnmarshalBinary(data []byte) error

UnmarshalBinary satisfies BinaryUnmarshaler Needed for msgpack

func (*Type) UnmarshalText 

func (t *Type) UnmarshalText(text []byte) error

UnmarshalText satisfies TextUnmarshaler

type Types 

type Types []Type

func (Types) Plural 

func (ts Types) Plural() string

func (Types) PluralList 

func (ts Types) PluralList() []string

func (Types) String 

func (ts Types) String() string

func (Types) StringList 

func (ts Types) StringList() []string

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.