client

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 14, 2019 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source
const (
	NoMongosError = iota
)

Variables

View Source
var ErrNoMongos = errors.New("no mongos")

Functions

func IsError added in v0.4.0

func IsError(err error, code int) bool

Types

type Client

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

func NewClient

func NewClient(inctx context.Context, in InputOptions) (*Client, error)

func (*Client) ID

func (c *Client) ID() string

func (*Client) IsDBBackupRunning

func (c *Client) IsDBBackupRunning() bool

func (*Client) IsOplogBackupRunning

func (c *Client) IsOplogBackupRunning() bool

func (*Client) ListStorages added in v0.4.0

func (c *Client) ListStorages() ([]*pb.StorageInfo, error)

func (*Client) NodeName

func (c *Client) NodeName() string

func (*Client) NodeTye added in v0.4.0

func (c *Client) NodeTye() pb.NodeType

func (*Client) ReplicasetName

func (c *Client) ReplicasetName() string

func (*Client) Start added in v0.3.0

func (c *Client) Start() error

func (*Client) Stop

func (c *Client) Stop()

type ConnectionOptions

type ConnectionOptions struct {
	Host                string `yaml:"host,omitempty" kingpin:"mongodb-host"`
	Port                string `yaml:"port,omitempty" kingpin:"mongodb-port"`
	User                string `yaml:"username,omitempty" kingpin:"mongodb-user"`
	Password            string `yaml:"password,omitempty" kingpin:"mongodb-password"`
	AuthDB              string `yaml:"authdb,omitempty" kingpin:"mongodb-authdb"`
	ReplicasetName      string `yaml:"replicaset,omitempty" kingpin:"mongodb-replicaset"`
	Timeout             int    `yaml:"timeout,omitempty"`
	TCPKeepAliveSeconds int    `yaml:"tcp_keep_alive_seconds,omitempty"`
	ReconnectDelay      int    `yaml:"reconnect_delay,omitempty" kingpin:"mongodb-reconnect-delay"`
	ReconnectCount      int    `yaml:"reconnect_count,omitempty" kingpin:"mongodb-reconnect-count"` // 0: forever
	DSN                 string `yaml:"dsn,omitempty" kingpin:"dsn"`
}

type Error added in v0.4.0

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

func Errorf added in v0.4.0

func Errorf(code int, args ...string) *Error

func (*Error) Cause added in v0.4.0

func (ce *Error) Cause() error

func (*Error) Error added in v0.4.0

func (ce *Error) Error() string

type InputOptions added in v0.3.0

type InputOptions struct {
	BackupDir     string
	DbConnOptions ConnectionOptions
	DbSSLOptions  SSLOptions
	GrpcConn      *grpc.ClientConn
	Logger        *logrus.Logger
	Storages      *storage.Storages
}

type SSLOptions

type SSLOptions struct {
	SSLCAFile           string `yaml:"sslca_file,omitempty"`
	SSLPEMKeyFile       string `yaml:"sslpem_key_file,omitempty"`
	SSLPEMKeyPassword   string `yaml:"sslpem_key_password,omitempty"`
	SSLCRLFile          string `yaml:"sslcrl_file,omitempty"`
	UseSSL              bool   `yaml:"use_ssl,omitempty"`
	SSLAllowInvalidCert bool   `yaml:"ssl_allow_invalid_cert,omitempty"`
	SSLAllowInvalidHost bool   `yaml:"ssl_allow_invalid_host,omitempty"`
	SSLFipsMode         bool   `yaml:"ssl_fips_mode,omitempty"`
}

Struct holding ssl-related options

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL