apis

Documentation

Index

• Constants
• type Apis
  • func NewUserApis(ctx context.Context, userId, userToken string, manager *supbmanager.Manager) (*Apis, error)
  • func (r *Apis) BindingResourcesToCluster(slaveGuid, masterGuid string) error
  • func (r *Apis) DeleteImage(image string) error
  • func (r *Apis) DeleteRunningStrategy(guid string) error
  • func (r *Apis) DeleteRunningStrategyOnAgentFromRPC(guid string) error
  • func (r *Apis) GetApplicationManager() *manager_applications.AppliationManager
  • func (r *Apis) GetBindingsManager() *manager_bindings.BindingsManager
  • func (r *Apis) GetClustersManager() *manager_clusters.ClustersManager
  • func (r *Apis) GetDocker() docker.Controller
  • func (r *Apis) GetElk() elk.Recorder
  • func (r *Apis) GetNervous() supbnervous.Controller
  • func (r *Apis) GetOption() *options.Options
  • func (r *Apis) GetResourcesManager() *sponge_resources.ResourcesManager
  • func (r *Apis) GetResourcesWatcher() clientv3.WatchChan
  • func (r *Apis) GetStrategyManager() *manager_strategies.StrategiesManager
  • func (r *Apis) ListImages() ([]string, error)
  • func (r *Apis) LoadImage(image string) error
  • func (r *Apis) RunStaticStrategy(name string) error
  • func (r *Apis) RunStaticStrategyOnAgentFromRPC(name string) error
  • func (r *Apis) StopRunningStrategy(guid string) error
  • func (r *Apis) UploadImage(image string) error

Constants

const (
	RPCTryTime     = 100
	RPCTryInterval = 500
)

Types

type Apis

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

func NewUserApis

func NewUserApis(ctx context.Context, userId, userToken string, manager *supbmanager.Manager) (*Apis, error)

func (*Apis) BindingResourcesToCluster

func (r *Apis) BindingResourcesToCluster(slaveGuid, masterGuid string) error

func (*Apis) DeleteImage

func (r *Apis) DeleteImage(image string) error

func (*Apis) DeleteRunningStrategy

func (r *Apis) DeleteRunningStrategy(guid string) error

DeleteRunningStrategy todo delete a running strategy

func (*Apis) DeleteRunningStrategyOnAgentFromRPC

func (r *Apis) DeleteRunningStrategyOnAgentFromRPC(guid string) error

func (*Apis) GetApplicationManager

func (r *Apis) GetApplicationManager() *manager_applications.AppliationManager

func (*Apis) GetBindingsManager

func (r *Apis) GetBindingsManager() *manager_bindings.BindingsManager

func (*Apis) GetClustersManager

func (r *Apis) GetClustersManager() *manager_clusters.ClustersManager

func (*Apis) GetDocker

func (r *Apis) GetDocker() docker.Controller

func (*Apis) GetElk

func (r *Apis) GetElk() elk.Recorder

func (*Apis) GetNervous

func (r *Apis) GetNervous() supbnervous.Controller

func (*Apis) GetOption

func (r *Apis) GetOption() *options.Options

func (*Apis) GetResourcesManager

func (r *Apis) GetResourcesManager() *sponge_resources.ResourcesManager

func (*Apis) GetResourcesWatcher

func (r *Apis) GetResourcesWatcher() clientv3.WatchChan

func (*Apis) GetStrategyManager

func (r *Apis) GetStrategyManager() *manager_strategies.StrategiesManager

func (*Apis) ListImages

func (r *Apis) ListImages() ([]string, error)

func (*Apis) LoadImage

func (r *Apis) LoadImage(image string) error

func (*Apis) RunStaticStrategy

func (r *Apis) RunStaticStrategy(name string) error

RunStaticStrategy todo run a static strategy

func (*Apis) RunStaticStrategyOnAgentFromRPC

func (r *Apis) RunStaticStrategyOnAgentFromRPC(name string) error

kdksf sdf sdf asd

func (*Apis) StopRunningStrategy

func (r *Apis) StopRunningStrategy(guid string) error

StopRunningStrategy todo stop a running strategy

func (*Apis) UploadImage

func (r *Apis) UploadImage(image string) error