resource

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2019 License: Apache-2.0 Imports: 6 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 ErrorEmbedInTemplate added in v0.2.0 

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 added in v0.2.0 

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"
)

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 added in v0.2.0 

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

func (Error) Error added in v0.2.0 

func (e Error) Error() string

type ErrorKind 

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

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

	// Data statuses
	StatusDataRunning
	StatusDataSucceeded
	StatusDataFailed
	StatusDataKilled

	// API statuses
	StatusAPIUpdating
	StatusAPIReady
	StatusAPIStopping
	StatusAPIStopped
	StatusAPIError

	// Additional API group statuses (i.e. aggregated API status)
	StatusAPIGroupPendingUpdate
	StatusAPIGroupParentFailed
	StatusAPIGroupParentKilled
	StatusAPIGroupUpdateSkipped
)

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                   // 8
	AggregatorType                    // 9
	TransformerType                   // 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.