luci: go.chromium.org/luci/logdog/api/config/svcconfig Index | Files | Directories

package svcconfig

import "go.chromium.org/luci/logdog/api/config/svcconfig"

Package svcconfig stores service configuration for a LogDog instance.

Each LogDog instantiation will have a single Config protobuf. It will be located under config set "services/<app-id>", path "services.cfg". The path is exposed via ServiceConfigFilename.

Each LogDog project will have its own project-specific configuration. It will be located under config set "projects/<project-name>", path "<app-id>.cfg".

Package svcconfig contains LogDog service configuration protobufs.

The package name here must match the protobuf package name, as the generated files will reside in the same directory.

Index

Package Files

archival.pb.go config.pb.go doc.go gen.go project.pb.go storage.pb.go transport.pb.go util.go

Constants

const (
    // ServiceConfigPath is the config service path of the Config protobuf.
    ServiceConfigPath = "services.cfg"
)

func ProjectConfigPath Uses

func ProjectConfigPath(serviceName string) string

ProjectConfigPath returns the path of a LogDog project config given the LogDog service's name.

type ArchiveIndexConfig Uses

type ArchiveIndexConfig struct {
    // If not zero, the maximum number of stream indices between index entries.
    StreamRange int32 `protobuf:"varint,1,opt,name=stream_range,json=streamRange" json:"stream_range,omitempty"`
    // If not zero, the maximum number of prefix indices between index entries.
    PrefixRange int32 `protobuf:"varint,2,opt,name=prefix_range,json=prefixRange" json:"prefix_range,omitempty"`
    // If not zero, the maximum number of log data bytes between index entries.
    ByteRange            int32    `protobuf:"varint,3,opt,name=byte_range,json=byteRange" json:"byte_range,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ArchiveIndexConfig specifies how archive indexes should be generated.

By default, each log entry will be present in the index. This is generally overkill; instead, the index can be more sparse at the expense of a slightly higher data load.

func (*ArchiveIndexConfig) Descriptor Uses

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

func (*ArchiveIndexConfig) GetByteRange Uses

func (m *ArchiveIndexConfig) GetByteRange() int32

func (*ArchiveIndexConfig) GetPrefixRange Uses

func (m *ArchiveIndexConfig) GetPrefixRange() int32

func (*ArchiveIndexConfig) GetStreamRange Uses

func (m *ArchiveIndexConfig) GetStreamRange() int32

func (*ArchiveIndexConfig) ProtoMessage Uses

func (*ArchiveIndexConfig) ProtoMessage()

func (*ArchiveIndexConfig) Reset Uses

func (m *ArchiveIndexConfig) Reset()

func (*ArchiveIndexConfig) String Uses

func (m *ArchiveIndexConfig) String() string

func (*ArchiveIndexConfig) XXX_DiscardUnknown Uses

func (m *ArchiveIndexConfig) XXX_DiscardUnknown()

func (*ArchiveIndexConfig) XXX_Marshal Uses

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

func (*ArchiveIndexConfig) XXX_Merge Uses

func (dst *ArchiveIndexConfig) XXX_Merge(src proto.Message)

func (*ArchiveIndexConfig) XXX_Size Uses

func (m *ArchiveIndexConfig) XXX_Size() int

func (*ArchiveIndexConfig) XXX_Unmarshal Uses

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

type Archivist Uses

type Archivist struct {
    // The name of the archival Pub/Sub subscription.
    //
    // This should be connected to "archive_topic", and the Archivist must have
    // permission to consume from this subscription.
    Subscription string `protobuf:"bytes,1,opt,name=subscription" json:"subscription,omitempty"`
    // The number of tasks to run at a time. If blank, the archivist will choose a
    // default value.
    Tasks int32 `protobuf:"varint,2,opt,name=tasks" json:"tasks,omitempty"`
    // The name of the staging storage bucket. All projects will share the same
    // staging bucket. Logs for a project will be staged under:
    //
    // gs://<gs_staging_bucket>/<app-id>/<project-name>/...
    GsStagingBucket string `protobuf:"bytes,3,opt,name=gs_staging_bucket,json=gsStagingBucket" json:"gs_staging_bucket,omitempty"`
    // Service-wide index configuration. This is used if per-project configuration
    // is not specified.
    ArchiveIndexConfig *ArchiveIndexConfig `protobuf:"bytes,10,opt,name=archive_index_config,json=archiveIndexConfig" json:"archive_index_config,omitempty"`
    // If true, always render the log entries as a binary file during archival,
    // regardless of whether a specific stream has a binary file extension.
    //
    // By default, a stream will only be rendered as a binary if its descriptor
    // includes a non-empty binary file extension field.
    //
    // The binary stream consists of each log entry's data rendered back-to-back.
    //   - For text streams, this produces a text document similar to the source
    //     text.
    //   - For binary streams and datagram streams, this reproduces the source
    //     contiguous binary file.
    //   - For datagram streams, the size-prefixed datagrams are written back-to-
    //     back.
    //
    // Enabling this option will consume roughly twice the archival space, as each
    // stream's data will be archived once as a series of log entries and once as
    // a binary file.
    //
    // Streams without an explicit binary file extension will default to ".bin" if
    // this is enabled.
    RenderAllStreams     bool     `protobuf:"varint,13,opt,name=render_all_streams,json=renderAllStreams" json:"render_all_streams,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

Configuration for the Archivist microservice.

func (*Archivist) Descriptor Uses

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

func (*Archivist) GetArchiveIndexConfig Uses

func (m *Archivist) GetArchiveIndexConfig() *ArchiveIndexConfig

func (*Archivist) GetGsStagingBucket Uses

func (m *Archivist) GetGsStagingBucket() string

func (*Archivist) GetRenderAllStreams Uses

func (m *Archivist) GetRenderAllStreams() bool

func (*Archivist) GetSubscription Uses

func (m *Archivist) GetSubscription() string

func (*Archivist) GetTasks Uses

func (m *Archivist) GetTasks() int32

func (*Archivist) ProtoMessage Uses

func (*Archivist) ProtoMessage()

func (*Archivist) Reset Uses

func (m *Archivist) Reset()

func (*Archivist) String Uses

func (m *Archivist) String() string

func (*Archivist) XXX_DiscardUnknown Uses

func (m *Archivist) XXX_DiscardUnknown()

func (*Archivist) XXX_Marshal Uses

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

func (*Archivist) XXX_Merge Uses

func (dst *Archivist) XXX_Merge(src proto.Message)

func (*Archivist) XXX_Size Uses

func (m *Archivist) XXX_Size() int

func (*Archivist) XXX_Unmarshal Uses

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

type Collector Uses

type Collector struct {
    // The maximum number of concurrent transport messages to process. If <= 0,
    // a default will be chosen based on the transport.
    MaxConcurrentMessages int32 `protobuf:"varint,1,opt,name=max_concurrent_messages,json=maxConcurrentMessages" json:"max_concurrent_messages,omitempty"`
    // The maximum number of concurrent workers to process each ingested message.
    // If <= 0, collector.DefaultMaxMessageWorkers will be used.
    MaxMessageWorkers int32 `protobuf:"varint,2,opt,name=max_message_workers,json=maxMessageWorkers" json:"max_message_workers,omitempty"`
    // The maximum number of log stream states to cache locally. If <= 0, a
    // default will be used.
    StateCacheSize int32 `protobuf:"varint,3,opt,name=state_cache_size,json=stateCacheSize" json:"state_cache_size,omitempty"`
    // The maximum amount of time that cached stream state is valid. If <= 0, a
    // default will be used.
    StateCacheExpiration *duration.Duration `protobuf:"bytes,4,opt,name=state_cache_expiration,json=stateCacheExpiration" json:"state_cache_expiration,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Collector is the set of configuration parameters for Collector instances.

func (*Collector) Descriptor Uses

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

func (*Collector) GetMaxConcurrentMessages Uses

func (m *Collector) GetMaxConcurrentMessages() int32

func (*Collector) GetMaxMessageWorkers Uses

func (m *Collector) GetMaxMessageWorkers() int32

func (*Collector) GetStateCacheExpiration Uses

func (m *Collector) GetStateCacheExpiration() *duration.Duration

func (*Collector) GetStateCacheSize Uses

func (m *Collector) GetStateCacheSize() int32

func (*Collector) ProtoMessage Uses

func (*Collector) ProtoMessage()

func (*Collector) Reset Uses

func (m *Collector) Reset()

func (*Collector) String Uses

func (m *Collector) String() string

func (*Collector) XXX_DiscardUnknown Uses

func (m *Collector) XXX_DiscardUnknown()

func (*Collector) XXX_Marshal Uses

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

func (*Collector) XXX_Merge Uses

func (dst *Collector) XXX_Merge(src proto.Message)

func (*Collector) XXX_Size Uses

func (m *Collector) XXX_Size() int

func (*Collector) XXX_Unmarshal Uses

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

type Config Uses

type Config struct {
    // Configuration for the Butler's log transport.
    Transport *Transport `protobuf:"bytes,10,opt,name=transport" json:"transport,omitempty"`
    // Configuration for intermediate Storage.
    Storage *Storage `protobuf:"bytes,11,opt,name=storage" json:"storage,omitempty"`
    // Coordinator is the coordinator service configuration.
    Coordinator *Coordinator `protobuf:"bytes,20,opt,name=coordinator" json:"coordinator,omitempty"`
    // Collector is the collector fleet configuration.
    Collector *Collector `protobuf:"bytes,21,opt,name=collector" json:"collector,omitempty"`
    // Archivist microservice configuration.
    Archivist            *Archivist `protobuf:"bytes,22,opt,name=archivist" json:"archivist,omitempty"`
    XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    XXX_unrecognized     []byte     `json:"-"`
    XXX_sizecache        int32      `json:"-"`
}

Config is the overall instance configuration.

func (*Config) Descriptor Uses

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

func (*Config) GetArchivist Uses

func (m *Config) GetArchivist() *Archivist

func (*Config) GetCollector Uses

func (m *Config) GetCollector() *Collector

func (*Config) GetCoordinator Uses

func (m *Config) GetCoordinator() *Coordinator

func (*Config) GetStorage Uses

func (m *Config) GetStorage() *Storage

func (*Config) GetTransport Uses

func (m *Config) GetTransport() *Transport

func (*Config) ProtoMessage Uses

func (*Config) ProtoMessage()

func (*Config) Reset Uses

func (m *Config) Reset()

func (*Config) String Uses

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown Uses

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal Uses

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

func (*Config) XXX_Merge Uses

func (dst *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size Uses

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal Uses

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

type Coordinator Uses

type Coordinator struct {
    // The name of the authentication group for administrators.
    AdminAuthGroup string `protobuf:"bytes,10,opt,name=admin_auth_group,json=adminAuthGroup" json:"admin_auth_group,omitempty"`
    // The name of the authentication group for backend services.
    ServiceAuthGroup string `protobuf:"bytes,11,opt,name=service_auth_group,json=serviceAuthGroup" json:"service_auth_group,omitempty"`
    // A list of origin URLs that are allowed to perform CORS RPC calls.
    RpcAllowOrigins []string `protobuf:"bytes,20,rep,name=rpc_allow_origins,json=rpcAllowOrigins" json:"rpc_allow_origins,omitempty"`
    // The maximum amount of time after a prefix has been registered when log
    // streams may also be registered under that prefix.
    //
    // After the expiration period has passed, new log stream registration will
    // fail.
    //
    // Project configurations or stream prefix regitrations may override this by
    // providing >= 0 values for prefix expiration. The smallest configured
    // expiration will be applied.
    PrefixExpiration *duration.Duration `protobuf:"bytes,21,opt,name=prefix_expiration,json=prefixExpiration" json:"prefix_expiration,omitempty"`
    // The full path of the archival Pub/Sub topic.
    //
    // The Coordinator must have permission to publish to this topic.
    ArchiveTopic string `protobuf:"bytes,30,opt,name=archive_topic,json=archiveTopic" json:"archive_topic,omitempty"`
    // The amount of time after an archive request has been dispatched before it
    // should be executed.
    //
    // Since terminal messages can arrive out of order, the archival request may
    // be kicked off before all of the log stream data has been loaded into
    // intermediate storage. If this happens, the Archivist will retry archival
    // later autometically.
    //
    // This parameter is an optimization to stop the archivist from wasting its
    // time until the log stream has a reasonable expectation of being available.
    ArchiveSettleDelay *duration.Duration `protobuf:"bytes,31,opt,name=archive_settle_delay,json=archiveSettleDelay" json:"archive_settle_delay,omitempty"`
    // The amount of time before a log stream is candidate for archival regardless
    // of whether or not it's been terminated or complete.
    //
    // This is a failsafe designed to ensure that log streams with missing records
    // or no terminal record (e.g., Butler crashed) are eventually archived.
    //
    // This should be fairly large (days) to avoid prematurely archiving
    // long-running streams, but should be considerably smaller than the
    // intermediate storage data retention period.
    //
    // If a project's "max_stream_age" is smaller than this value, it will be used
    // on that project's streams.
    ArchiveDelayMax      *duration.Duration `protobuf:"bytes,32,opt,name=archive_delay_max,json=archiveDelayMax" json:"archive_delay_max,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Coordinator is the Coordinator service configuration.

func (*Coordinator) Descriptor Uses

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

func (*Coordinator) GetAdminAuthGroup Uses

func (m *Coordinator) GetAdminAuthGroup() string

func (*Coordinator) GetArchiveDelayMax Uses

func (m *Coordinator) GetArchiveDelayMax() *duration.Duration

func (*Coordinator) GetArchiveSettleDelay Uses

func (m *Coordinator) GetArchiveSettleDelay() *duration.Duration

func (*Coordinator) GetArchiveTopic Uses

func (m *Coordinator) GetArchiveTopic() string

func (*Coordinator) GetPrefixExpiration Uses

func (m *Coordinator) GetPrefixExpiration() *duration.Duration

func (*Coordinator) GetRpcAllowOrigins Uses

func (m *Coordinator) GetRpcAllowOrigins() []string

func (*Coordinator) GetServiceAuthGroup Uses

func (m *Coordinator) GetServiceAuthGroup() string

func (*Coordinator) ProtoMessage Uses

func (*Coordinator) ProtoMessage()

func (*Coordinator) Reset Uses

func (m *Coordinator) Reset()

func (*Coordinator) String Uses

func (m *Coordinator) String() string

func (*Coordinator) XXX_DiscardUnknown Uses

func (m *Coordinator) XXX_DiscardUnknown()

func (*Coordinator) XXX_Marshal Uses

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

func (*Coordinator) XXX_Merge Uses

func (dst *Coordinator) XXX_Merge(src proto.Message)

func (*Coordinator) XXX_Size Uses

func (m *Coordinator) XXX_Size() int

func (*Coordinator) XXX_Unmarshal Uses

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

type ProjectConfig Uses

type ProjectConfig struct {
    // The set of auth service groups that are permitted READ access to this
    // project's log streams.
    ReaderAuthGroups []string `protobuf:"bytes,2,rep,name=reader_auth_groups,json=readerAuthGroups" json:"reader_auth_groups,omitempty"`
    // The set of chrome-infra-auth groups that are permitted WRITE access to this
    // project's log streams.
    WriterAuthGroups []string `protobuf:"bytes,3,rep,name=writer_auth_groups,json=writerAuthGroups" json:"writer_auth_groups,omitempty"`
    // The maximum lifetime of a log stream.
    //
    // If a stream has not terminated after this period of time, it will be
    // forcefully archived, and additional stream data will be discarded.
    //
    // This is upper-bounded by the global "archive_delay_max" parameter.
    MaxStreamAge *duration.Duration `protobuf:"bytes,4,opt,name=max_stream_age,json=maxStreamAge" json:"max_stream_age,omitempty"`
    // The maximum amount of time after a prefix has been registered when log
    // streams may also be registered under that prefix.
    //
    // See Config's "prefix_expiration" for more information.
    PrefixExpiration *duration.Duration `protobuf:"bytes,5,opt,name=prefix_expiration,json=prefixExpiration" json:"prefix_expiration,omitempty"`
    // The archival Google Storage bucket name.
    //
    // Log streams artifacts will be stored in a subdirectory of this bucket:
    // gs://<archive_gs_bucket>/<app-id>/<project-name>/<log-path>/artifact...
    //
    // Note that the Archivist microservice must have WRITE access to this
    // bucket, and the Coordinator must have READ access.
    //
    // If this is not set, the logs will be archived in a project-named
    // subdirectory in the global "archive_gs_base" location.
    ArchiveGsBucket string `protobuf:"bytes,10,opt,name=archive_gs_bucket,json=archiveGsBucket" json:"archive_gs_bucket,omitempty"`
    // If true, always create an additional data file that is the rendered content
    // of the stream data. By default, only streams that explicitly register a
    // binary file extension must be rendered.
    //
    // See Config's "always_create_binary" for more information.
    RenderAllStreams bool `protobuf:"varint,11,opt,name=render_all_streams,json=renderAllStreams" json:"render_all_streams,omitempty"`
    // Project-specific archive index configuration.
    //
    // Any unspecified index configuration will default to the service archival
    // config.
    ArchiveIndexConfig   *ArchiveIndexConfig `protobuf:"bytes,12,opt,name=archive_index_config,json=archiveIndexConfig" json:"archive_index_config,omitempty"`
    XXX_NoUnkeyedLiteral struct{}            `json:"-"`
    XXX_unrecognized     []byte              `json:"-"`
    XXX_sizecache        int32               `json:"-"`
}

ProjectConfig is a set of per-project configuration parameters. Each luci-config project must include one of these configs in order to register or view log streams in that project's log stream space.

A project's configuration should reside in the "projects/<project>" config set and be named "<app-id>.cfg".

Many of the parameters here can be bounded by GlobalConfig parameters.

func (*ProjectConfig) Descriptor Uses

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

func (*ProjectConfig) GetArchiveGsBucket Uses

func (m *ProjectConfig) GetArchiveGsBucket() string

func (*ProjectConfig) GetArchiveIndexConfig Uses

func (m *ProjectConfig) GetArchiveIndexConfig() *ArchiveIndexConfig

func (*ProjectConfig) GetMaxStreamAge Uses

func (m *ProjectConfig) GetMaxStreamAge() *duration.Duration

func (*ProjectConfig) GetPrefixExpiration Uses

func (m *ProjectConfig) GetPrefixExpiration() *duration.Duration

func (*ProjectConfig) GetReaderAuthGroups Uses

func (m *ProjectConfig) GetReaderAuthGroups() []string

func (*ProjectConfig) GetRenderAllStreams Uses

func (m *ProjectConfig) GetRenderAllStreams() bool

func (*ProjectConfig) GetWriterAuthGroups Uses

func (m *ProjectConfig) GetWriterAuthGroups() []string

func (*ProjectConfig) ProtoMessage Uses

func (*ProjectConfig) ProtoMessage()

func (*ProjectConfig) Reset Uses

func (m *ProjectConfig) Reset()

func (*ProjectConfig) String Uses

func (m *ProjectConfig) String() string

func (*ProjectConfig) XXX_DiscardUnknown Uses

func (m *ProjectConfig) XXX_DiscardUnknown()

func (*ProjectConfig) XXX_Marshal Uses

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

func (*ProjectConfig) XXX_Merge Uses

func (dst *ProjectConfig) XXX_Merge(src proto.Message)

func (*ProjectConfig) XXX_Size Uses

func (m *ProjectConfig) XXX_Size() int

func (*ProjectConfig) XXX_Unmarshal Uses

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

type Storage Uses

type Storage struct {
    // Type is the transport configuration that is being used.
    //
    // Types that are valid to be assigned to Type:
    //	*Storage_Bigtable
    Type isStorage_Type `protobuf_oneof:"Type"`
    // The maximum lifetime of a log's intermediate storage entries. The Storage
    // instance is free to begin deleting log entries if they are older than this.
    //
    // It is recommended that this be set to 4*[terminal archival threshold],
    // where the terminal archival threshold is the amount of time that the
    // Coordinator will wait on a log stream that has not been terminated before
    // constructing an archive.
    //
    // Waiting at least the archival threshold ensures that the log entries are
    // available for streams that expire. Waiting longer than the threshold is
    // good because a user may be streaming logs from intermediate storage as they
    // become archived. Waiting a *lot* longer is useful to prevent data loss in
    // the event of issues with the archival process.
    MaxLogAge            *duration.Duration `protobuf:"bytes,2,opt,name=max_log_age,json=maxLogAge" json:"max_log_age,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

Storage is the in-transit storage configuration.

func (*Storage) Descriptor Uses

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

func (*Storage) GetBigtable Uses

func (m *Storage) GetBigtable() *Storage_BigTable

func (*Storage) GetMaxLogAge Uses

func (m *Storage) GetMaxLogAge() *duration.Duration

func (*Storage) GetType Uses

func (m *Storage) GetType() isStorage_Type

func (*Storage) ProtoMessage Uses

func (*Storage) ProtoMessage()

func (*Storage) Reset Uses

func (m *Storage) Reset()

func (*Storage) String Uses

func (m *Storage) String() string

func (*Storage) XXX_DiscardUnknown Uses

func (m *Storage) XXX_DiscardUnknown()

func (*Storage) XXX_Marshal Uses

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

func (*Storage) XXX_Merge Uses

func (dst *Storage) XXX_Merge(src proto.Message)

func (*Storage) XXX_OneofFuncs Uses

func (*Storage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Storage) XXX_Size Uses

func (m *Storage) XXX_Size() int

func (*Storage) XXX_Unmarshal Uses

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

type Storage_BigTable Uses

type Storage_BigTable struct {
    // The name of the BigTable instance project.
    Project string `protobuf:"bytes,1,opt,name=project" json:"project,omitempty"`
    // The name of the BigTable instance.
    Instance string `protobuf:"bytes,2,opt,name=instance" json:"instance,omitempty"`
    // The name of the BigTable instance's log table.
    LogTableName         string   `protobuf:"bytes,3,opt,name=log_table_name,json=logTableName" json:"log_table_name,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

BigTable is the set of BigTable configuration parameters.

func (*Storage_BigTable) Descriptor Uses

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

func (*Storage_BigTable) GetInstance Uses

func (m *Storage_BigTable) GetInstance() string

func (*Storage_BigTable) GetLogTableName Uses

func (m *Storage_BigTable) GetLogTableName() string

func (*Storage_BigTable) GetProject Uses

func (m *Storage_BigTable) GetProject() string

func (*Storage_BigTable) ProtoMessage Uses

func (*Storage_BigTable) ProtoMessage()

func (*Storage_BigTable) Reset Uses

func (m *Storage_BigTable) Reset()

func (*Storage_BigTable) String Uses

func (m *Storage_BigTable) String() string

func (*Storage_BigTable) XXX_DiscardUnknown Uses

func (m *Storage_BigTable) XXX_DiscardUnknown()

func (*Storage_BigTable) XXX_Marshal Uses

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

func (*Storage_BigTable) XXX_Merge Uses

func (dst *Storage_BigTable) XXX_Merge(src proto.Message)

func (*Storage_BigTable) XXX_Size Uses

func (m *Storage_BigTable) XXX_Size() int

func (*Storage_BigTable) XXX_Unmarshal Uses

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

type Storage_Bigtable Uses

type Storage_Bigtable struct {
    Bigtable *Storage_BigTable `protobuf:"bytes,1,opt,name=bigtable,oneof"`
}

type Transport Uses

type Transport struct {
    // Type is the transport configuration that is being used.
    //
    // Types that are valid to be assigned to Type:
    //	*Transport_Pubsub
    Type                 isTransport_Type `protobuf_oneof:"Type"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

Transport is the transport configuration.

func (*Transport) Descriptor Uses

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

func (*Transport) GetPubsub Uses

func (m *Transport) GetPubsub() *Transport_PubSub

func (*Transport) GetType Uses

func (m *Transport) GetType() isTransport_Type

func (*Transport) ProtoMessage Uses

func (*Transport) ProtoMessage()

func (*Transport) Reset Uses

func (m *Transport) Reset()

func (*Transport) String Uses

func (m *Transport) String() string

func (*Transport) XXX_DiscardUnknown Uses

func (m *Transport) XXX_DiscardUnknown()

func (*Transport) XXX_Marshal Uses

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

func (*Transport) XXX_Merge Uses

func (dst *Transport) XXX_Merge(src proto.Message)

func (*Transport) XXX_OneofFuncs Uses

func (*Transport) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Transport) XXX_Size Uses

func (m *Transport) XXX_Size() int

func (*Transport) XXX_Unmarshal Uses

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

type Transport_PubSub Uses

type Transport_PubSub struct {
    // The name of the authentication group for administrators.
    Project string `protobuf:"bytes,1,opt,name=project" json:"project,omitempty"`
    // The name of the authentication group for administrators.
    Topic string `protobuf:"bytes,2,opt,name=topic" json:"topic,omitempty"`
    // The name of the authentication group for administrators.
    Subscription         string   `protobuf:"bytes,3,opt,name=subscription" json:"subscription,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

PubSub is a transport configuration for Google Cloud Pub/Sub.

func (*Transport_PubSub) Descriptor Uses

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

func (*Transport_PubSub) GetProject Uses

func (m *Transport_PubSub) GetProject() string

func (*Transport_PubSub) GetSubscription Uses

func (m *Transport_PubSub) GetSubscription() string

func (*Transport_PubSub) GetTopic Uses

func (m *Transport_PubSub) GetTopic() string

func (*Transport_PubSub) ProtoMessage Uses

func (*Transport_PubSub) ProtoMessage()

func (*Transport_PubSub) Reset Uses

func (m *Transport_PubSub) Reset()

func (*Transport_PubSub) String Uses

func (m *Transport_PubSub) String() string

func (*Transport_PubSub) XXX_DiscardUnknown Uses

func (m *Transport_PubSub) XXX_DiscardUnknown()

func (*Transport_PubSub) XXX_Marshal Uses

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

func (*Transport_PubSub) XXX_Merge Uses

func (dst *Transport_PubSub) XXX_Merge(src proto.Message)

func (*Transport_PubSub) XXX_Size Uses

func (m *Transport_PubSub) XXX_Size() int

func (*Transport_PubSub) XXX_Unmarshal Uses

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

type Transport_Pubsub Uses

type Transport_Pubsub struct {
    Pubsub *Transport_PubSub `protobuf:"bytes,1,opt,name=pubsub,oneof"`
}

Directories

PathSynopsis
validatePackage main implements the LogDog Coordinator validation binary.

Package svcconfig imports 4 packages (graph) and is imported by 12 packages. Updated 2018-08-14. Refresh now. Tools for package owners.