Versions in this module Expand all Collapse all v0 v0.4.0 Oct 11, 2017 Changes in this version + const BatchAPIVersion + const BinContainer + const ComputeAPIVersion + const ComputeServiceCustomScriptExtension + const ComputeServiceDefaultMachineType + const DataContainer + const DefaultAccessPolicyExpiryTime + const DefaultLocation + const DefaultOSOffer + const DefaultOSPublisherName + const DefaultOSSkus + const DefaultOSVersion + const DefaultSleepTime + const LogContainer + const QueuePrefix + const ResourceAPIVersion + const ResultContainer + const RoadieAzureArchiveName + const RoadieAzureVersion + const SourceContainer + const StartupContainer + const StartupTemplate + const SubscriptionsAPIVersion + const TaskPrefix + var RoadieAzureURL = fmt.Sprintf("https://github.com/jkawamoto/roadie-azure/releases/download/%v/%v", ...) + func CreateResourceGroupIfNotExist(ctx context.Context, cfg *Config, logger *log.Logger) (err error) + func Locations(ctx context.Context, token *adal.Token, subscriptionID string) (regions []cloud.Region, err error) + func NewAPIError(err error) error + func StartupScript(cfg *Config, task *script.Script) (res string, err error) + type AuthorizedTransporter struct + func NewAuthorizedTransporter(transport http.RoundTripper, account string, key []byte) *AuthorizedTransporter + func (t *AuthorizedTransporter) RoundTrip(req *http.Request) (*http.Response, error) + type BatchService struct + Config *Config + Logger *log.Logger + SleepTime time.Duration + func NewBatchService(ctx context.Context, cfg *Config, logger *log.Logger) (service *BatchService, err error) + func (s *BatchService) AvailableMachineTypes(ctx context.Context) (types []cloud.MachineType, err error) + func (s *BatchService) AvailableOSImages(ctx context.Context) (images []string, err error) + func (s *BatchService) CreateJob(ctx context.Context, name string) (err error) + func (s *BatchService) CreateTask(ctx context.Context, job string, task *script.Script) (err error) + func (s *BatchService) DeleteJob(ctx context.Context, name string) (err error) + func (s *BatchService) DeleteTask(ctx context.Context, job, task string) (err error) + func (s *BatchService) DisableJob(ctx context.Context, name string) (err error) + func (s *BatchService) EnableJob(ctx context.Context, name string) (err error) + func (s *BatchService) GetJobInfo(ctx context.Context, job string) (info *models.CloudJob, err error) + func (s *BatchService) GetPoolInfo(ctx context.Context, name string) (info *models.CloudPool, err error) + func (s *BatchService) Jobs(ctx context.Context) (set JobSet, err error) + func (s *BatchService) Nodes(ctx context.Context, pool string) (nodes []*models.ComputeNode, err error) + func (s *BatchService) Tasks(ctx context.Context, job string) (set TaskSet, err error) + func (s *BatchService) UpdatePoolSize(ctx context.Context, name string, size int32) (err error) + type ComputeService struct + Config *Config + Logger *log.Logger + func NewComputeService(ctx context.Context, cfg *Config, logger *log.Logger) (s *ComputeService, err error) + func (s *ComputeService) AvailableMachineTypes(ctx context.Context) (types []cloud.MachineType, err error) + func (s *ComputeService) AvailableRegions(ctx context.Context) (regions []cloud.Region, err error) + func (s *ComputeService) ImageID(ctx context.Context, publisherName, offer, skus, version string) (id string, err error) + func (s *ComputeService) ImageOffers(ctx context.Context, publisher string) (offers []Entry, err error) + func (s *ComputeService) ImagePublishers(ctx context.Context) (publishers []Entry, err error) + func (s *ComputeService) ImageSkus(ctx context.Context, publisherName, offer string) (skus []Entry, err error) + func (s *ComputeService) ImageVersions(ctx context.Context, publisherName, offer, skus string) (versions []Entry, err error) + type Config struct + AccountName string + Location string + MachineType string + OS OSInformation + ProjectID string + SubscriptionID string + TenantID string + Token adal.Token + func NewConfig() *Config + func NewConfigFromFile(filename string) (cfg *Config, err error) + func (cfg *Config) String() (str string, err error) + func (cfg *Config) UnmarshalYAML(unmarshal func(interface{}) error) (err error) + func (cfg *Config) Valid() bool + func (cfg *Config) WriteFile(filename string) (err error) + type Entry struct + ID string + Name string + type InstanceManager struct + Config *Config + Logger *log.Logger + func NewInstanceManager(ctx context.Context, cfg *Config, logger *log.Logger) (m *InstanceManager, err error) + func (m *InstanceManager) AvailableMachineTypes(ctx context.Context) (types []cloud.MachineType, err error) + func (m *InstanceManager) AvailableRegions(ctx context.Context) (regions []cloud.Region, err error) + func (m *InstanceManager) CreateInstance(ctx context.Context, task *script.Script) (err error) + func (m *InstanceManager) DeleteInstance(ctx context.Context, name string) error + func (m *InstanceManager) Instances(ctx context.Context, handler cloud.InstanceHandler) (err error) + type JobSet map[string]*models.CloudJob + type LogManager struct + Config *Config + Logger *log.Logger + func NewLogManager(ctx context.Context, cfg *Config, logger *log.Logger) (m *LogManager, err error) + func (m *LogManager) Delete(ctx context.Context, instanceName string) (err error) + func (m *LogManager) Get(ctx context.Context, instanceName string, from time.Time, ...) (err error) + func (m *LogManager) GetQueueLog(ctx context.Context, queue string, handler cloud.LogHandler) (err error) + func (m *LogManager) GetTaskLog(ctx context.Context, queue, task string, handler cloud.LogHandler) (err error) + type MinimalJSONProducer struct + func NewMinimalJSONProducer() *MinimalJSONProducer + func (p *MinimalJSONProducer) Produce(out io.Writer, msg interface{}) (err error) + type OSInformation struct + Offer string + PublisherName string + Skus string + Version string + func (info *OSInformation) UnmarshalYAML(unmarshal func(interface{}) error) (err error) + type Provider struct + Config *Config + Logger *log.Logger + func NewProvider(ctx context.Context, cfg *Config, logger *log.Logger, forceAuth bool) (provider *Provider, err error) + func (p *Provider) InstanceManager(ctx context.Context) (cloud.InstanceManager, error) + func (p *Provider) LogManager(ctx context.Context) (cloud.LogManager, error) + func (p *Provider) QueueManager(ctx context.Context) (cloud.QueueManager, error) + func (p *Provider) ResourceManager(ctx context.Context) (cloud.ResourceManager, error) + func (p *Provider) StorageManager(ctx context.Context) (cloud.StorageManager, error) + type QueueManager struct + Config *Config + Logger *log.Logger + func NewQueueManager(ctx context.Context, cfg *Config, logger *log.Logger) (m *QueueManager, err error) + func (m *QueueManager) CreateWorkers(ctx context.Context, queue string, n int, ...) (err error) + func (m *QueueManager) DeleteQueue(ctx context.Context, queue string) (err error) + func (m *QueueManager) DeleteTask(ctx context.Context, queue, task string) (err error) + func (m *QueueManager) Enqueue(ctx context.Context, queue string, task *script.Script) (err error) + func (m *QueueManager) Queues(ctx context.Context, handler cloud.QueueStatusHandler) (err error) + func (m *QueueManager) Restart(ctx context.Context, queue string) error + func (m *QueueManager) Stop(ctx context.Context, queue string) error + func (m *QueueManager) Tasks(ctx context.Context, queue string, handler cloud.QueueManagerTaskHandler) (err error) + func (m *QueueManager) Workers(ctx context.Context, queue string, handler cloud.QueueManagerNameHandler) (err error) + type ResourceGroupSet map[string]*models.ResourceGroup + type ResourceManager struct + Config *Config + Logger *log.Logger + func NewResourceManager(cfg *Config, logger *log.Logger) *ResourceManager + func (m *ResourceManager) GetMachineType() string + func (m *ResourceManager) GetProjectID() string + func (m *ResourceManager) GetRegion() string + func (m *ResourceManager) MachineTypes(ctx context.Context) ([]cloud.MachineType, error) + func (m *ResourceManager) Regions(ctx context.Context) ([]cloud.Region, error) + func (m *ResourceManager) SetMachineType(t string) + func (m *ResourceManager) SetProjectID(id string) + func (m *ResourceManager) SetRegion(region string) + type ResourceService struct + Config *Config + Logger *log.Logger + SleepTime time.Duration + func NewResourceService(cfg *Config, logger *log.Logger) *ResourceService + func (s *ResourceService) CheckExistence(ctx context.Context, name string) bool + func (s *ResourceService) CreateResourceGroup(ctx context.Context, name string) (err error) + func (s *ResourceService) DeleteResourceGroup(ctx context.Context, name string) (err error) + func (s *ResourceService) ResourceGroups(ctx context.Context) (groups ResourceGroupSet, err error) + type StorageService struct + AccessPolicyExpiryTime time.Duration + Client storage.BlobStorageClient + Config *Config + Logger *log.Logger + func NewStorageService(ctx context.Context, cfg *Config, logger *log.Logger) (s *StorageService, err error) + func (s *StorageService) Delete(ctx context.Context, loc *url.URL) (err error) + func (s *StorageService) Download(ctx context.Context, loc *url.URL, out io.Writer) (err error) + func (s *StorageService) GetFileInfo(ctx context.Context, loc *url.URL) (info *cloud.FileInfo, err error) + func (s *StorageService) GetMetadata(ctx context.Context, container, filename string) (metadata map[string]string, err error) + func (s *StorageService) List(ctx context.Context, loc *url.URL, handler cloud.FileInfoHandler) (err error) + func (s *StorageService) Upload(ctx context.Context, loc *url.URL, in io.Reader) (err error) + func (s *StorageService) UploadWithMetadata(ctx context.Context, container, filename string, in io.Reader, ...) (err error) + type TaskSet map[string]*models.CloudTask
Go to main page