Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type CleanerOptions ¶
type CleanerOptions struct {
Enable bool `long:"enable" description:"Enable DB cleaner"`
ActivePeriod time.Duration `` /* 131-byte string literal not displayed */
PassivePeriod time.Duration `` /* 131-byte string literal not displayed */
RetentionDays int `` /* 130-byte string literal not displayed */
BatchSize int `` /* 134-byte string literal not displayed */
ReadTimeout time.Duration `` /* 132-byte string literal not displayed */
WriteTimeout time.Duration `` /* 132-byte string literal not displayed */
}
type Options ¶
type Options struct {
Enable bool `long:"enable" description:"Enable store"`
DbConnectionString string `long:"db-connection-string" description:"A Postgres database connection string"`
DbReaderConnectionString string `long:"reader-db-connection-string" description:"A Postgres database reader connection string"`
ReadTimeout time.Duration `long:"db-read-timeout" description:"Timeout for reading from the database" default:"10s"`
WriteTimeout time.Duration `long:"db-write-timeout" description:"Timeout for writing to the database" default:"10s"`
MaxOpenConns int `long:"max-open-conns" description:"Maximum number of open connections" default:"80"`
MetricsPeriod time.Duration `long:"metrics-period" description:"Polling period for store metrics" default:"30s"`
Cleaner CleanerOptions `group:"DB Cleaner Options" namespace:"cleaner"`
}
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
func (*Store) Query ¶
func (s *Store) Query(query *messagev1.QueryRequest) (res *messagev1.QueryResponse, err error)
Click to show internal directories.
Click to hide internal directories.