io

Documentation

Overview

-------------------------------------------------------------------------

*
* disk_io_collector.go
*    collect block device IO stat
*
*
* Copyright (c) 2021, Alibaba Group Holding Limited
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* IDENTIFICATION
*           plugins/polardb_pg_opensource/resource/io/disk_io_collector.go
*-------------------------------------------------------------------------

-------------------------------------------------------------------------

*
* polarswitch_io_collector.go
*    collect polar switch IO stat
*
*
* Copyright (c) 2021, Alibaba Group Holding Limited
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* IDENTIFICATION
*           plugins/polardb_pg_opensource/resource/io/polarswitch_io_collector.go
*-------------------------------------------------------------------------

Index

• Constants
• func ParseFloat(s string) float64
• type DiskIOCollector
  • func NewDiskIOCollector() *DiskIOCollector
  • func (c *DiskIOCollector) Collect(out map[string]interface{}) error
  • func (c *DiskIOCollector) Init(m map[string]interface{}, logger *log.PluginLogger) error
  • func (c *DiskIOCollector) PfsdGetDiskIo(devName string) (uint64, uint64, uint64, uint64, uint64, uint64, uint64, error)
  • func (c *DiskIOCollector) Stop() error
• type PbdInfo
• type PlsIOCollector
  • func NewPlsIOCollector() *PlsIOCollector
  • func (p *PlsIOCollector) Collect(out map[string]interface{}) error
  • func (p *PlsIOCollector) ExecCommand(cmd string) (string, error)
  • func (p *PlsIOCollector) Init(m map[string]interface{}, logger *log.PluginLogger) error
  • func (p *PlsIOCollector) Stop() error

Constants

const (
	PFSCmdTimeout        = 5
	PLSIOCollectInterval = 15
)

Functions

func ParseFloat

func ParseFloat(s string) float64

Types

type DiskIOCollector

type DiskIOCollector struct {
	InsName string
	// contains filtered or unexported fields
}

func NewDiskIOCollector

func NewDiskIOCollector() *DiskIOCollector

func (*DiskIOCollector) Collect

func (c *DiskIOCollector) Collect(out map[string]interface{}) error

func (*DiskIOCollector) Init

func (c *DiskIOCollector) Init(m map[string]interface{}, logger *log.PluginLogger) error

func (*DiskIOCollector) PfsdGetDiskIo

func (c *DiskIOCollector) PfsdGetDiskIo(devName string) (uint64, uint64, uint64, uint64, uint64, uint64, uint64, error)

func (*DiskIOCollector) Stop

func (c *DiskIOCollector) Stop() error

type PbdInfo

type PbdInfo struct {
	// contains filtered or unexported fields
}

type PlsIOCollector

type PlsIOCollector struct {
	InsName     string
	DBType      string
	Environment string
	// contains filtered or unexported fields
}

func NewPlsIOCollector

func NewPlsIOCollector() *PlsIOCollector

func (*PlsIOCollector) Collect

func (p *PlsIOCollector) Collect(out map[string]interface{}) error

func (*PlsIOCollector) ExecCommand

func (p *PlsIOCollector) ExecCommand(cmd string) (string, error)

func (*PlsIOCollector) Init

func (p *PlsIOCollector) Init(m map[string]interface{}, logger *log.PluginLogger) error

func (*PlsIOCollector) Stop

func (p *PlsIOCollector) Stop() error