pods

Documentation

Index

• func CreateOrUpdatePod(pod *Pod)
• func FindFirstManifestPath() string
• func Pods() *map[string]*Pod
• func RemovePod(name string)
• func RemovePodByManifestPath(manifestPath string)
• type Pod
  • func FindPod(podName string) (*Pod, error)
  • func GetPod(name string) *Pod
  • func LoadPodFromManifest(manifestPath string) (*Pod, error)
  • func (pod *Pod) Actions() map[string]string
  • func (pod *Pod) AddFlight(flightId string, flight *flights.Flight)
  • func (pod *Pod) AddLocalState(newState ...*state.State)
  • func (pod *Pod) CachedCsv() string
  • func (pod *Pod) CachedState() []*state.State
  • func (pod *Pod) DataSources() []*dataspaces.Dataspace
  • func (pod *Pod) Episodes() int
  • func (pod *Pod) Epoch() time.Time
  • func (pod *Pod) FetchNewData() ([]*state.State, error)
  • func (pod *Pod) FieldNames() []string
  • func (pod *Pod) Fields() map[string]float64
  • func (pod *Pod) Flights() *map[string]*flights.Flight
  • func (pod *Pod) GetFlight(flight string) *flights.Flight
  • func (pod *Pod) Granularity() time.Duration
  • func (pod *Pod) Hash() string
  • func (pod *Pod) Interval() time.Duration
  • func (f *Pod) ManifestPath() string
  • func (pod *Pod) Period() time.Duration
  • func (pod *Pod) Rewards() map[string]string
  • func (pod *Pod) State() ([]*state.State, error)
  • func (pod *Pod) TrainingGoal() *string
  • func (pod *Pod) ValidateForTraining() error

Functions

func CreateOrUpdatePod

func CreateOrUpdatePod(pod *Pod)

func FindFirstManifestPath

func FindFirstManifestPath() string

func Pods

func Pods() *map[string]*Pod

func RemovePod

func RemovePod(name string)

func RemovePodByManifestPath

func RemovePodByManifestPath(manifestPath string)

Types

type Pod

type Pod struct {
	spec.PodSpec
	// contains filtered or unexported fields
}

func FindPod

func FindPod(podName string) (*Pod, error)

func GetPod

func GetPod(name string) *Pod

func LoadPodFromManifest

func LoadPodFromManifest(manifestPath string) (*Pod, error)

func (*Pod) Actions

func (pod *Pod) Actions() map[string]string

func (*Pod) AddFlight

func (pod *Pod) AddFlight(flightId string, flight *flights.Flight)

func (*Pod) AddLocalState

func (pod *Pod) AddLocalState(newState ...*state.State)

func (*Pod) CachedCsv

func (pod *Pod) CachedCsv() string

func (*Pod) CachedState

func (pod *Pod) CachedState() []*state.State

func (*Pod) DataSources

func (pod *Pod) DataSources() []*dataspaces.Dataspace

func (*Pod) Episodes

func (pod *Pod) Episodes() int

func (*Pod) Epoch

func (pod *Pod) Epoch() time.Time

func (*Pod) FetchNewData

func (pod *Pod) FetchNewData() ([]*state.State, error)

func (*Pod) FieldNames

func (pod *Pod) FieldNames() []string

func (*Pod) Fields

func (pod *Pod) Fields() map[string]float64

func (*Pod) Flights

func (pod *Pod) Flights() *map[string]*flights.Flight

func (*Pod) GetFlight

func (pod *Pod) GetFlight(flight string) *flights.Flight

func (*Pod) Granularity

func (pod *Pod) Granularity() time.Duration

func (*Pod) Hash

func (pod *Pod) Hash() string

func (*Pod) Interval

func (pod *Pod) Interval() time.Duration

func (*Pod) ManifestPath

func (f *Pod) ManifestPath() string

func (*Pod) Period

func (pod *Pod) Period() time.Duration

func (*Pod) Rewards

func (pod *Pod) Rewards() map[string]string

func (*Pod) State

func (pod *Pod) State() ([]*state.State, error)

func (*Pod) TrainingGoal

func (pod *Pod) TrainingGoal() *string

func (*Pod) ValidateForTraining

func (pod *Pod) ValidateForTraining() error