Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

observer

package

Go to main page

Versions in this module

v2

v2.4.0

Jul 9, 2021

Changes in this version

+ func BuildArtifactFilename(artifactType string) string

+ func InitConnection(clone *models.Clone, socketDir string) (*pgx.Conn, error)

+ func IsAvailableArtifactType(artifactType string) bool

+ type DBSize struct

+ Diff string

+ ObjectsStat ObjectsStat

+ Total string

+ type Duration struct

+ FinishedAt time.Time

+ MaxQueryDuration string

+ StartedAt time.Time

+ Total string

+ type Locks struct

+ TotalInterval int

+ WarningInterval int

+ type LogErrors struct

+ Count int

+ Message string

+ type ObjectsStat struct

+ Count int

+ IndexesSizeBytesSum int64

+ RowEstimateSum int64

+ TableSizeBytesSum int64

+ ToastSizeBytesSum int64

+ TotalSizeBytesSum int64

type Observer

+ func (o *Observer) AddObservingClone(cloneID string, port uint, session *ObservingClone)

+ func (o *Observer) GetObservingClone(cloneID string) (*ObservingClone, error)

+ func (o *Observer) RemoveObservingClone(cloneID string)

+ type ObservingClone struct

+ func NewObservingClone(config types.Config, sudb *pgx.Conn) *ObservingClone

+ func (c *ObservingClone) AddArtifact(sessionID uint64)

+ func (c *ObservingClone) BuildArtifactPath(sessionID uint64, artifactType string) string

+ func (c *ObservingClone) CheckDuration() bool

+ func (c *ObservingClone) CheckLocks() bool

+ func (c *ObservingClone) CheckOverallSuccess() bool

+ func (c *ObservingClone) CheckPerformanceRequirements() error

+ func (c *ObservingClone) Config() types.Config

+ func (c *ObservingClone) CsvFields() string

+ func (c *ObservingClone) GetArtifactList() []uint64

+ func (c *ObservingClone) Init(clone *models.Clone, sessionID uint64, startedAt time.Time, ...) error

+ func (c *ObservingClone) IsExistArtifacts(sessionID uint64) bool

+ func (c *ObservingClone) ReadSummary(sessionID uint64) ([]byte, error)

+ func (c *ObservingClone) RunSession() error

+ func (c *ObservingClone) Session() *Session

+ func (c *ObservingClone) SetOverallError(overallErrors bool)

+ func (c *ObservingClone) Stop() error

type Session

+ Artifacts []string

+ Result *models.ObservationResult

+ func (s Session) IsFinished() bool

+ type State struct

+ CurrentDBSize int64

+ InitialDBSize int64

+ LogErrors LogErrors

+ MaxDBQueryTimeMS float64

+ ObjectStat ObjectsStat

+ OverallError bool

+ type SummaryArtifact struct

+ ArtifactTypes []string

+ CloneID string

+ DBSize DBSize

+ Duration Duration

+ Locks Locks

+ LogErrors LogErrors

+ SessionID uint64

v2.2.0

Feb 9, 2021

Changes in this version

+ type Config struct

+ CloneDir string

+ DataSubDir string

+ ReplacementRules map[string]string

+ SocketDir string

+ type Observer struct

+ Platform *platform.Client

+ func NewObserver(dockerClient *client.Client, cfg *Config, platform *platform.Client, ...) *Observer

+ func (o *Observer) AddSession(cloneID string, session *Session)

+ func (o *Observer) GetCloneLog(ctx context.Context, port uint, session *Session) ([]byte, error)

+ func (o *Observer) GetSession(cloneID string) (*Session, error)

+ func (o *Observer) RemoveSession(cloneID string)

+ type ReplacementRule struct

+ type Session struct

+ Config types.Config

+ FinishedAt time.Time

+ SessionID uint64

+ StartedAt time.Time

+ Tags map[string]string

+ func NewSession(config types.Config) *Session

+ func (s *Session) CheckDuration() bool

+ func (s *Session) CheckLocks() bool

+ func (s *Session) CheckPerformanceRequirements() error

+ func (s *Session) CsvFields() string

+ func (s *Session) PrintSummary() string

+ func (s *Session) Start(clone *models.Clone) error

+ func (s *Session) Stop()

Other modules containing this package

gitlab.com/postgres-ai/database-lab