pgopher

Documentation

Index

• type Config
  • func DefaultConfig() Config
  • func LoadConfig(path string) (Config, error)
• type FileSinkOptions
• type KubernetesSinkOptions
• type ProfilingTarget
• type S3SinkOptions
• type Server
  • func NewServer(cfg Config) (*Server, error)
  • func (s *Server) Run(ctx context.Context) error
• type Sink

Types

type Config

type Config struct {
	ListenAddress      string            `yaml:"listenAddress"`
	PprofListenAddress string            `yaml:"pprofListenAddress"`
	ProfilingTargets   []ProfilingTarget `yaml:"profilingTargets"`
	Sink               Sink              `yaml:"sink"`
}

func DefaultConfig

func DefaultConfig() Config

func LoadConfig

func LoadConfig(path string) (Config, error)

type FileSinkOptions

type FileSinkOptions struct {
	Folder string `yaml:"folder"`
}

type KubernetesSinkOptions

type KubernetesSinkOptions struct {
	APIServerURL string `yaml:"apiServerURL"`
	Namespace    string `yaml:"namespace"`
}

type ProfilingTarget

type ProfilingTarget struct {
	Name     string        `yaml:"name"`
	URL      string        `yaml:"url"`
	Duration time.Duration `yaml:"duration"`
	Schedule string        `yaml:"schedule"`
}

type S3SinkOptions

type S3SinkOptions struct {
	Bucket string `yaml:"bucket"`
}

type Server

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

func NewServer

func NewServer(cfg Config) (*Server, error)

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

type Sink

type Sink struct {
	Type                  string                `yaml:"type"`
	FileSinkOptions       FileSinkOptions       `yaml:"fileSinkOptions"`
	S3SinkOptions         S3SinkOptions         `yaml:"s3SinkOptions"`
	KubernetesSinkOptions KubernetesSinkOptions `yaml:"kubernetesSinkOptions"`
}