plugin

Documentation

Index

• type AzurePlugin
  • func NewAzurePlugin() *AzurePlugin
  • func (azp *AzurePlugin) GetConfig() kaytuproto.RegisterConfig
  • func (azp *AzurePlugin) ReEvaluate(evaluate *kaytuproto.ReEvaluate)
  • func (azp *AzurePlugin) SetStream(stream kaytuproto.Plugin_RegisterClient)
  • func (azp *AzurePlugin) StartProcess(cmd string, flags map[string]string, kaytuAccessToken string, ...) error
• type AzureSDKParams
• type AzureSDKWrapper
  • func NewAzureSDKWrapper(params AzureSDKParams) (azsdkWrapper *AzureSDKWrapper, err error)
  • func (w *AzureSDKWrapper) ListVms() (map[string][]*armcompute.VirtualMachine, error)

Types

type AzurePlugin

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

func NewAzurePlugin

func NewAzurePlugin() *AzurePlugin

func (*AzurePlugin) GetConfig

func (azp *AzurePlugin) GetConfig() kaytuproto.RegisterConfig

TODO

func (*AzurePlugin) ReEvaluate

func (azp *AzurePlugin) ReEvaluate(evaluate *kaytuproto.ReEvaluate)

func (*AzurePlugin) SetStream

func (azp *AzurePlugin) SetStream(stream kaytuproto.Plugin_RegisterClient)

func (*AzurePlugin) StartProcess

func (azp *AzurePlugin) StartProcess(cmd string, flags map[string]string, kaytuAccessToken string, jobQueue *sdk.JobQueue) error

type AzureSDKParams

type AzureSDKParams struct {
	TokenCredtials            azcore.TokenCredential
	SubscriptionClientOptions *azcore.ClientOptions
	ComputeClientOptions      *azcore.ClientOptions
}

type AzureSDKWrapper

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

func NewAzureSDKWrapper

func NewAzureSDKWrapper(params AzureSDKParams) (azsdkWrapper *AzureSDKWrapper, err error)

NewAzureSDKWrapper TODO

func (*AzureSDKWrapper) ListVms

func (w *AzureSDKWrapper) ListVms() (map[string][]*armcompute.VirtualMachine, error)