collector

Documentation

Index

• type AclGrants
• type AclOwner
• type Bucket
• type BucketAcl
• type BucketPolicy
• type BucketPolicyPrincipal
• type BucketPolicyStatement
• type Collector
  • func (c *Collector) ConfigureCephServer() (bool, error)
  • func (c *Collector) CreateCephConfigFile() error
  • func (c *Collector) ParseCsvToYaml() error
  • func (c *Collector) ParseYamlToCsv() error
  • func (c *Collector) UpdateConfigFromApp() error
• type LifecycleRule

Types

type AclGrants

type AclGrants struct {
	FullControl []string `yaml:"full_control"`
	Read        []string `yaml:"read"`
	Write       []string `yaml:"write"`
}

type AclOwner

type AclOwner struct {
	DisplayName string `yaml:"display_name"`
	Id          string `yaml:"id"`
}

type Bucket

type Bucket struct {
	Acl            BucketAcl       `yaml:"acl"`
	AclType        string          `yaml:"acl_type,omitempty"`
	BucketType     string          `yaml:"bucket_type,omitempty"`
	LifecycleRules []LifecycleRule `yaml:"lifecycle_rules"`
	LifecycleType  string          `yaml:"lifecycle_type,omitempty"`
	Versioning     string          `yaml:"versioning"`
	VersioningType string          `yaml:"versioning_type,omitempty"`
	// contains filtered or unexported fields
}

type BucketAcl

type BucketAcl struct {
	Grants AclGrants `yaml:"grants"`
	Owner  AclOwner  `yaml:"owner"`
}

type BucketPolicy

type BucketPolicy struct {
	Id        string                  `json:"Id"`
	Version   string                  `json:"Version"`
	Statement []BucketPolicyStatement `json:"Statement"`
}

type BucketPolicyPrincipal

type BucketPolicyPrincipal struct {
	PrincipalType []string `json:"AWS"`
}

type BucketPolicyStatement

type BucketPolicyStatement struct {
	Sid       string                `json:"Sid"`
	Action    []string              `json:"Action"`
	Effect    string                `json:"Effect"`
	Resource  []string              `json:"Resource"`
	Principal BucketPolicyPrincipal `json:"Principal"`
}

type Collector

type Collector struct {
	EndpointUrl         string `yaml:"endpoint_url"`
	AwsAccessKey        string `yaml:"access_key"`
	AwsSecretKey        string `yaml:"secret_key"`
	DisableSSL          bool   `yaml:"disable_ssl"`
	AwsRegion           string `yaml:"aws_region"`
	BucketsPostfix      string
	ForcePath           bool
	AppConfigPath       string
	CephConfigPath      string
	CsvFilePath         string
	YamlFilePath        string
	CephCredentialsPath string
	CsvFieldSeparator   string
	CsvFieldsNum        int
	LoggerDebug         bool
	Logger              log.Logger
	CephBuckets         buckets
	CephClient          *s3.Client
	ParallelThreads     int
	RetryNum            int
	// contains filtered or unexported fields
}

func (*Collector) ConfigureCephServer

func (c *Collector) ConfigureCephServer() (bool, error)

func (*Collector) CreateCephConfigFile

func (c *Collector) CreateCephConfigFile() error

func (*Collector) ParseCsvToYaml

func (c *Collector) ParseCsvToYaml() error

func (*Collector) ParseYamlToCsv

func (c *Collector) ParseYamlToCsv() error

func (*Collector) UpdateConfigFromApp

func (c *Collector) UpdateConfigFromApp() error

type LifecycleRule

type LifecycleRule struct {
	ExpirationDays int32  `yaml:"cur_ver_expiration_days"`
	Id             string `yaml:"id"`
	NonCurrentDays int32  `yaml:"non_cur_ver_expiration_days"`
	Prefix         string `yaml:"prefix"`
	Status         string `yaml:"status"`
}