proto: go.chromium.org/chromiumos/infra/proto/go/cycler Index | Files

package cycler

import "go.chromium.org/chromiumos/infra/proto/go/cycler"

Index

Package Files

config.pb.go effect.pb.go

type ChillEffectConfiguration Uses

type ChillEffectConfiguration struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Change the storage class of an object in place.

func (*ChillEffectConfiguration) Descriptor Uses

func (*ChillEffectConfiguration) Descriptor() ([]byte, []int)

func (*ChillEffectConfiguration) ProtoMessage Uses

func (*ChillEffectConfiguration) ProtoMessage()

func (*ChillEffectConfiguration) Reset Uses

func (m *ChillEffectConfiguration) Reset()

func (*ChillEffectConfiguration) String Uses

func (m *ChillEffectConfiguration) String() string

func (*ChillEffectConfiguration) XXX_DiscardUnknown Uses

func (m *ChillEffectConfiguration) XXX_DiscardUnknown()

func (*ChillEffectConfiguration) XXX_Marshal Uses

func (m *ChillEffectConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChillEffectConfiguration) XXX_Merge Uses

func (m *ChillEffectConfiguration) XXX_Merge(src proto.Message)

func (*ChillEffectConfiguration) XXX_Size Uses

func (m *ChillEffectConfiguration) XXX_Size() int

func (*ChillEffectConfiguration) XXX_Unmarshal Uses

func (m *ChillEffectConfiguration) XXX_Unmarshal(b []byte) error

type DuplicateEffectConfiguration Uses

type DuplicateEffectConfiguration struct {
    // The destination bucket for the copied objects (e.g. 'engeg-testing-bucket').
    DestinationBucket string `protobuf:"bytes,1,opt,name=destination_bucket,json=destinationBucket,proto3" json:"destination_bucket,omitempty"`
    // The destination prefix for the copied objects (e.g. 'copied-files-prefix/').
    // Note: Prefixes are literal, and no '/' will be infered/appended.
    DestinationPrefix    string   `protobuf:"bytes,2,opt,name=destination_prefix,json=destinationPrefix,proto3" json:"destination_prefix,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Duplicate objects that match the configuration to another bucket + prefix. If the destination is within the configured bucket/prefix the behavior on those objects created via the duplicate is undefined. They may or may not exist in whole or in part at the time the prefix is iterated.

func (*DuplicateEffectConfiguration) Descriptor Uses

func (*DuplicateEffectConfiguration) Descriptor() ([]byte, []int)

func (*DuplicateEffectConfiguration) GetDestinationBucket Uses

func (m *DuplicateEffectConfiguration) GetDestinationBucket() string

func (*DuplicateEffectConfiguration) GetDestinationPrefix Uses

func (m *DuplicateEffectConfiguration) GetDestinationPrefix() string

func (*DuplicateEffectConfiguration) ProtoMessage Uses

func (*DuplicateEffectConfiguration) ProtoMessage()

func (*DuplicateEffectConfiguration) Reset Uses

func (m *DuplicateEffectConfiguration) Reset()

func (*DuplicateEffectConfiguration) String Uses

func (m *DuplicateEffectConfiguration) String() string

func (*DuplicateEffectConfiguration) XXX_DiscardUnknown Uses

func (m *DuplicateEffectConfiguration) XXX_DiscardUnknown()

func (*DuplicateEffectConfiguration) XXX_Marshal Uses

func (m *DuplicateEffectConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DuplicateEffectConfiguration) XXX_Merge Uses

func (m *DuplicateEffectConfiguration) XXX_Merge(src proto.Message)

func (*DuplicateEffectConfiguration) XXX_Size Uses

func (m *DuplicateEffectConfiguration) XXX_Size() int

func (*DuplicateEffectConfiguration) XXX_Unmarshal Uses

func (m *DuplicateEffectConfiguration) XXX_Unmarshal(b []byte) error

type HistogramOptions Uses

type HistogramOptions struct {
    // The number of unique buckets in the histrogram.
    NumBuckets int32 `protobuf:"varint,1,opt,name=num_buckets,json=numBuckets,proto3" json:"num_buckets,omitempty"`
    // The growth factor of each bucket to the next.
    GrowthFactor float64 `protobuf:"fixed64,2,opt,name=growth_factor,json=growthFactor,proto3" json:"growth_factor,omitempty"`
    // The base bucket's size.
    BaseBucketSize float64 `protobuf:"fixed64,3,opt,name=base_bucket_size,json=baseBucketSize,proto3" json:"base_bucket_size,omitempty"`
    // The minimum valued bucket's value.
    MinValue             int64    `protobuf:"varint,4,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Options for the Histogram generation during a cycler run. See definition in: "google.golang.org/grpc/benchmark/stats"

func (*HistogramOptions) Descriptor Uses

func (*HistogramOptions) Descriptor() ([]byte, []int)

func (*HistogramOptions) GetBaseBucketSize Uses

func (m *HistogramOptions) GetBaseBucketSize() float64

func (*HistogramOptions) GetGrowthFactor Uses

func (m *HistogramOptions) GetGrowthFactor() float64

func (*HistogramOptions) GetMinValue Uses

func (m *HistogramOptions) GetMinValue() int64

func (*HistogramOptions) GetNumBuckets Uses

func (m *HistogramOptions) GetNumBuckets() int32

func (*HistogramOptions) ProtoMessage Uses

func (*HistogramOptions) ProtoMessage()

func (*HistogramOptions) Reset Uses

func (m *HistogramOptions) Reset()

func (*HistogramOptions) String Uses

func (m *HistogramOptions) String() string

func (*HistogramOptions) XXX_DiscardUnknown Uses

func (m *HistogramOptions) XXX_DiscardUnknown()

func (*HistogramOptions) XXX_Marshal Uses

func (m *HistogramOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistogramOptions) XXX_Merge Uses

func (m *HistogramOptions) XXX_Merge(src proto.Message)

func (*HistogramOptions) XXX_Size Uses

func (m *HistogramOptions) XXX_Size() int

func (*HistogramOptions) XXX_Unmarshal Uses

func (m *HistogramOptions) XXX_Unmarshal(b []byte) error

type MoveEffectConfiguration Uses

type MoveEffectConfiguration struct {
    // The destination bucket for the moved objects (e.g. 'engeg-testing-bucket').
    DestinationBucket string `protobuf:"bytes,1,opt,name=destination_bucket,json=destinationBucket,proto3" json:"destination_bucket,omitempty"`
    // The destination prefix for the moved objects (e.g. 'moved-files-prefix/').
    // Note: Prefixes are literal, and no '/' will be infered/appended.
    DestinationPrefix    string   `protobuf:"bytes,2,opt,name=destination_prefix,json=destinationPrefix,proto3" json:"destination_prefix,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Move objects that match the configuration to another bucket + prefix. If the destination is within the configured bucket/prefix the behavior on those objects created via the move is undefined. They may or may not exist in whole or in part at the time the prefix is iterated.

func (*MoveEffectConfiguration) Descriptor Uses

func (*MoveEffectConfiguration) Descriptor() ([]byte, []int)

func (*MoveEffectConfiguration) GetDestinationBucket Uses

func (m *MoveEffectConfiguration) GetDestinationBucket() string

func (*MoveEffectConfiguration) GetDestinationPrefix Uses

func (m *MoveEffectConfiguration) GetDestinationPrefix() string

func (*MoveEffectConfiguration) ProtoMessage Uses

func (*MoveEffectConfiguration) ProtoMessage()

func (*MoveEffectConfiguration) Reset Uses

func (m *MoveEffectConfiguration) Reset()

func (*MoveEffectConfiguration) String Uses

func (m *MoveEffectConfiguration) String() string

func (*MoveEffectConfiguration) XXX_DiscardUnknown Uses

func (m *MoveEffectConfiguration) XXX_DiscardUnknown()

func (*MoveEffectConfiguration) XXX_Marshal Uses

func (m *MoveEffectConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MoveEffectConfiguration) XXX_Merge Uses

func (m *MoveEffectConfiguration) XXX_Merge(src proto.Message)

func (*MoveEffectConfiguration) XXX_Size Uses

func (m *MoveEffectConfiguration) XXX_Size() int

func (*MoveEffectConfiguration) XXX_Unmarshal Uses

func (m *MoveEffectConfiguration) XXX_Unmarshal(b []byte) error

type NoopEffectConfiguration Uses

type NoopEffectConfiguration struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Like it says on the tin, will run stats only.

func (*NoopEffectConfiguration) Descriptor Uses

func (*NoopEffectConfiguration) Descriptor() ([]byte, []int)

func (*NoopEffectConfiguration) ProtoMessage Uses

func (*NoopEffectConfiguration) ProtoMessage()

func (*NoopEffectConfiguration) Reset Uses

func (m *NoopEffectConfiguration) Reset()

func (*NoopEffectConfiguration) String Uses

func (m *NoopEffectConfiguration) String() string

func (*NoopEffectConfiguration) XXX_DiscardUnknown Uses

func (m *NoopEffectConfiguration) XXX_DiscardUnknown()

func (*NoopEffectConfiguration) XXX_Marshal Uses

func (m *NoopEffectConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NoopEffectConfiguration) XXX_Merge Uses

func (m *NoopEffectConfiguration) XXX_Merge(src proto.Message)

func (*NoopEffectConfiguration) XXX_Size Uses

func (m *NoopEffectConfiguration) XXX_Size() int

func (*NoopEffectConfiguration) XXX_Unmarshal Uses

func (m *NoopEffectConfiguration) XXX_Unmarshal(b []byte) error

type PolicyEffectConfiguration Uses

type PolicyEffectConfiguration struct {
    // The effect configuration must be one of the following configs.
    //
    // Types that are valid to be assigned to EffectConfiguration:
    //	*PolicyEffectConfiguration_Noop
    //	*PolicyEffectConfiguration_Move
    //	*PolicyEffectConfiguration_Chill
    //	*PolicyEffectConfiguration_Duplicate
    EffectConfiguration isPolicyEffectConfiguration_EffectConfiguration `protobuf_oneof:"effect_configuration"`
    // The policy document to be parsed by rego and executed to determine if an
    // effect is going to be taken upon the object.
    PolicyDocumentPath   string   `protobuf:"bytes,5,opt,name=policy_document_path,json=policyDocumentPath,proto3" json:"policy_document_path,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

A policy effect configuration defines the policy and the resulting effect.

func (*PolicyEffectConfiguration) Descriptor Uses

func (*PolicyEffectConfiguration) Descriptor() ([]byte, []int)

func (*PolicyEffectConfiguration) GetChill Uses

func (m *PolicyEffectConfiguration) GetChill() *ChillEffectConfiguration

func (*PolicyEffectConfiguration) GetDuplicate Uses

func (m *PolicyEffectConfiguration) GetDuplicate() *DuplicateEffectConfiguration

func (*PolicyEffectConfiguration) GetEffectConfiguration Uses

func (m *PolicyEffectConfiguration) GetEffectConfiguration() isPolicyEffectConfiguration_EffectConfiguration

func (*PolicyEffectConfiguration) GetMove Uses

func (m *PolicyEffectConfiguration) GetMove() *MoveEffectConfiguration

func (*PolicyEffectConfiguration) GetNoop Uses

func (m *PolicyEffectConfiguration) GetNoop() *NoopEffectConfiguration

func (*PolicyEffectConfiguration) GetPolicyDocumentPath Uses

func (m *PolicyEffectConfiguration) GetPolicyDocumentPath() string

func (*PolicyEffectConfiguration) ProtoMessage Uses

func (*PolicyEffectConfiguration) ProtoMessage()

func (*PolicyEffectConfiguration) Reset Uses

func (m *PolicyEffectConfiguration) Reset()

func (*PolicyEffectConfiguration) String Uses

func (m *PolicyEffectConfiguration) String() string

func (*PolicyEffectConfiguration) XXX_DiscardUnknown Uses

func (m *PolicyEffectConfiguration) XXX_DiscardUnknown()

func (*PolicyEffectConfiguration) XXX_Marshal Uses

func (m *PolicyEffectConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PolicyEffectConfiguration) XXX_Merge Uses

func (m *PolicyEffectConfiguration) XXX_Merge(src proto.Message)

func (*PolicyEffectConfiguration) XXX_OneofWrappers Uses

func (*PolicyEffectConfiguration) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*PolicyEffectConfiguration) XXX_Size Uses

func (m *PolicyEffectConfiguration) XXX_Size() int

func (*PolicyEffectConfiguration) XXX_Unmarshal Uses

func (m *PolicyEffectConfiguration) XXX_Unmarshal(b []byte) error

type PolicyEffectConfiguration_Chill Uses

type PolicyEffectConfiguration_Chill struct {
    Chill *ChillEffectConfiguration `protobuf:"bytes,3,opt,name=chill,proto3,oneof"`
}

type PolicyEffectConfiguration_Duplicate Uses

type PolicyEffectConfiguration_Duplicate struct {
    Duplicate *DuplicateEffectConfiguration `protobuf:"bytes,4,opt,name=duplicate,proto3,oneof"`
}

type PolicyEffectConfiguration_Move Uses

type PolicyEffectConfiguration_Move struct {
    Move *MoveEffectConfiguration `protobuf:"bytes,2,opt,name=move,proto3,oneof"`
}

type PolicyEffectConfiguration_Noop Uses

type PolicyEffectConfiguration_Noop struct {
    Noop *NoopEffectConfiguration `protobuf:"bytes,1,opt,name=noop,proto3,oneof"`
}

type RunConfig Uses

type RunConfig struct {
    // The runlog configuration.
    RunLogConfiguration *RunLogConfiguration `protobuf:"bytes,1,opt,name=run_log_configuration,json=runLogConfiguration,proto3" json:"run_log_configuration,omitempty"`
    // The stats configuration for the prefix and the action statistics.
    StatsConfiguration *StatsConfiguration `protobuf:"bytes,2,opt,name=stats_configuration,json=statsConfiguration,proto3" json:"stats_configuration,omitempty"`
    // Policy effect configuration.
    PolicyEffectConfiguration *PolicyEffectConfiguration `protobuf:"bytes,3,opt,name=policy_effect_configuration,json=policyEffectConfiguration,proto3" json:"policy_effect_configuration,omitempty"`
    // Must match the command line argument and policy effect as well.
    MutationAllowed bool `protobuf:"varint,4,opt,name=mutation_allowed,json=mutationAllowed,proto3" json:"mutation_allowed,omitempty"`
    // The bucket to operate on (can be overridden on the command line).
    Bucket               string   `protobuf:"bytes,5,opt,name=bucket,proto3" json:"bucket,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Closure of all config for a single cycler run.

func (*RunConfig) Descriptor Uses

func (*RunConfig) Descriptor() ([]byte, []int)

func (*RunConfig) GetBucket Uses

func (m *RunConfig) GetBucket() string

func (*RunConfig) GetMutationAllowed Uses

func (m *RunConfig) GetMutationAllowed() bool

func (*RunConfig) GetPolicyEffectConfiguration Uses

func (m *RunConfig) GetPolicyEffectConfiguration() *PolicyEffectConfiguration

func (*RunConfig) GetRunLogConfiguration Uses

func (m *RunConfig) GetRunLogConfiguration() *RunLogConfiguration

func (*RunConfig) GetStatsConfiguration Uses

func (m *RunConfig) GetStatsConfiguration() *StatsConfiguration

func (*RunConfig) ProtoMessage Uses

func (*RunConfig) ProtoMessage()

func (*RunConfig) Reset Uses

func (m *RunConfig) Reset()

func (*RunConfig) String Uses

func (m *RunConfig) String() string

func (*RunConfig) XXX_DiscardUnknown Uses

func (m *RunConfig) XXX_DiscardUnknown()

func (*RunConfig) XXX_Marshal Uses

func (m *RunConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunConfig) XXX_Merge Uses

func (m *RunConfig) XXX_Merge(src proto.Message)

func (*RunConfig) XXX_Size Uses

func (m *RunConfig) XXX_Size() int

func (*RunConfig) XXX_Unmarshal Uses

func (m *RunConfig) XXX_Unmarshal(b []byte) error

type RunLogConfiguration Uses

type RunLogConfiguration struct {
    // The destination url 'directory' for the logs, can be file:// or gs://.
    DestinationUrl string `protobuf:"bytes,1,opt,name=destination_url,json=destinationUrl,proto3" json:"destination_url,omitempty"`
    // The rough chunk size in bytes to deliver the logs in (before compression).
    ChunkSizeBytes int64 `protobuf:"varint,2,opt,name=chunk_size_bytes,json=chunkSizeBytes,proto3" json:"chunk_size_bytes,omitempty"`
    // How many outstanding log messages can we have before blocking producers.
    ChannelSize int64 `protobuf:"varint,3,opt,name=channel_size,json=channelSize,proto3" json:"channel_size,omitempty"`
    // How many retries we should make to persist logs.
    PersistRetries int64 `protobuf:"varint,4,opt,name=persist_retries,json=persistRetries,proto3" json:"persist_retries,omitempty"`
    // How many logs we'll allow to fail persistence and still continue.
    // Since we do log shipping in goroutines this is also the cap on the number
    // of those.
    MaxUnpersistedLogs   int64    `protobuf:"varint,5,opt,name=max_unpersisted_logs,json=maxUnpersistedLogs,proto3" json:"max_unpersisted_logs,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Options for the log generation during a cycler run.

func (*RunLogConfiguration) Descriptor Uses

func (*RunLogConfiguration) Descriptor() ([]byte, []int)

func (*RunLogConfiguration) GetChannelSize Uses

func (m *RunLogConfiguration) GetChannelSize() int64

func (*RunLogConfiguration) GetChunkSizeBytes Uses

func (m *RunLogConfiguration) GetChunkSizeBytes() int64

func (*RunLogConfiguration) GetDestinationUrl Uses

func (m *RunLogConfiguration) GetDestinationUrl() string

func (*RunLogConfiguration) GetMaxUnpersistedLogs Uses

func (m *RunLogConfiguration) GetMaxUnpersistedLogs() int64

func (*RunLogConfiguration) GetPersistRetries Uses

func (m *RunLogConfiguration) GetPersistRetries() int64

func (*RunLogConfiguration) ProtoMessage Uses

func (*RunLogConfiguration) ProtoMessage()

func (*RunLogConfiguration) Reset Uses

func (m *RunLogConfiguration) Reset()

func (*RunLogConfiguration) String Uses

func (m *RunLogConfiguration) String() string

func (*RunLogConfiguration) XXX_DiscardUnknown Uses

func (m *RunLogConfiguration) XXX_DiscardUnknown()

func (*RunLogConfiguration) XXX_Marshal Uses

func (m *RunLogConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunLogConfiguration) XXX_Merge Uses

func (m *RunLogConfiguration) XXX_Merge(src proto.Message)

func (*RunLogConfiguration) XXX_Size Uses

func (m *RunLogConfiguration) XXX_Size() int

func (*RunLogConfiguration) XXX_Unmarshal Uses

func (m *RunLogConfiguration) XXX_Unmarshal(b []byte) error

type StatsConfiguration Uses

type StatsConfiguration struct {
    // When generating a report for a prefix, how deep should the breakdown be.
    PrefixReportMaxDepth int64 `protobuf:"varint,1,opt,name=prefix_report_max_depth,json=prefixReportMaxDepth,proto3" json:"prefix_report_max_depth,omitempty"`
    // Histogram options for the objects ages.
    AgeDaysHistogramOptions *HistogramOptions `protobuf:"bytes,2,opt,name=age_days_histogram_options,json=ageDaysHistogramOptions,proto3" json:"age_days_histogram_options,omitempty"`
    // Histogram options for the objects sizes.
    SizeBytesHistogramOptions *HistogramOptions `protobuf:"bytes,3,opt,name=size_bytes_histogram_options,json=sizeBytesHistogramOptions,proto3" json:"size_bytes_histogram_options,omitempty"`
    XXX_NoUnkeyedLiteral      struct{}          `json:"-"`
    XXX_unrecognized          []byte            `json:"-"`
    XXX_sizecache             int32             `json:"-"`
}

Options provided to any run providing stats.

func (*StatsConfiguration) Descriptor Uses

func (*StatsConfiguration) Descriptor() ([]byte, []int)

func (*StatsConfiguration) GetAgeDaysHistogramOptions Uses

func (m *StatsConfiguration) GetAgeDaysHistogramOptions() *HistogramOptions

func (*StatsConfiguration) GetPrefixReportMaxDepth Uses

func (m *StatsConfiguration) GetPrefixReportMaxDepth() int64

func (*StatsConfiguration) GetSizeBytesHistogramOptions Uses

func (m *StatsConfiguration) GetSizeBytesHistogramOptions() *HistogramOptions

func (*StatsConfiguration) ProtoMessage Uses

func (*StatsConfiguration) ProtoMessage()

func (*StatsConfiguration) Reset Uses

func (m *StatsConfiguration) Reset()

func (*StatsConfiguration) String Uses

func (m *StatsConfiguration) String() string

func (*StatsConfiguration) XXX_DiscardUnknown Uses

func (m *StatsConfiguration) XXX_DiscardUnknown()

func (*StatsConfiguration) XXX_Marshal Uses

func (m *StatsConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsConfiguration) XXX_Merge Uses

func (m *StatsConfiguration) XXX_Merge(src proto.Message)

func (*StatsConfiguration) XXX_Size Uses

func (m *StatsConfiguration) XXX_Size() int

func (*StatsConfiguration) XXX_Unmarshal Uses

func (m *StatsConfiguration) XXX_Unmarshal(b []byte) error

Package cycler imports 3 packages (graph). Updated 2020-01-25. Refresh now. Tools for package owners.