internal

Documentation

Index

• type MetaClientMock
  • func (c *MetaClientMock) Close() error
  • func (c *MetaClientMock) CreateContinuousQuery(database, name, query string) error
  • func (c *MetaClientMock) CreateDatabase(name string) (*meta.DatabaseInfo, error)
  • func (c *MetaClientMock) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)
  • func (c *MetaClientMock) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec) (*meta.RetentionPolicyInfo, error)
  • func (c *MetaClientMock) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)
  • func (c *MetaClientMock) CreateSubscription(database, rp, name, mode string, destinations []string) error
  • func (c *MetaClientMock) CreateUser(name, password string, admin bool) (*meta.UserInfo, error)
  • func (c *MetaClientMock) Data() meta.Data
  • func (c *MetaClientMock) Database(name string) *meta.DatabaseInfo
  • func (c *MetaClientMock) Databases() []meta.DatabaseInfo
  • func (c *MetaClientMock) DeleteShardGroup(database string, policy string, id uint64) error
  • func (c *MetaClientMock) DropContinuousQuery(database, name string) error
  • func (c *MetaClientMock) DropDatabase(name string) error
  • func (c *MetaClientMock) DropRetentionPolicy(database, name string) error
  • func (c *MetaClientMock) DropShard(id uint64) error
  • func (c *MetaClientMock) DropSubscription(database, rp, name string) error
  • func (c *MetaClientMock) DropUser(name string) error
  • func (c *MetaClientMock) Open() error
  • func (c *MetaClientMock) RetentionPolicy(database, name string) (rpi *meta.RetentionPolicyInfo, err error)
  • func (c *MetaClientMock) SetAdminPrivilege(username string, admin bool) error
  • func (c *MetaClientMock) SetData(d *meta.Data) error
  • func (c *MetaClientMock) SetDefaultRetentionPolicy(database, name string) error
  • func (c *MetaClientMock) SetPrivilege(username, database string, p influxql.Privilege) error
  • func (c *MetaClientMock) ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)
  • func (c *MetaClientMock) ShardsByTimeRange(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)
  • func (c *MetaClientMock) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate) error
  • func (c *MetaClientMock) UpdateUser(name, password string) error
  • func (c *MetaClientMock) UserPrivilege(username, database string) (*influxql.Privilege, error)
  • func (c *MetaClientMock) UserPrivileges(username string) (map[string]influxql.Privilege, error)
  • func (c *MetaClientMock) Users() []meta.UserInfo

Types

type MetaClientMock

type MetaClientMock struct {
	CloseFn                             func() error
	CreateContinuousQueryFn             func(database, name, query string) error
	CreateDatabaseFn                    func(name string) (*meta.DatabaseInfo, error)
	CreateDatabaseWithRetentionPolicyFn func(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)
	CreateRetentionPolicyFn             func(database string, spec *meta.RetentionPolicySpec) (*meta.RetentionPolicyInfo, error)
	CreateShardGroupFn                  func(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)
	CreateSubscriptionFn                func(database, rp, name, mode string, destinations []string) error
	CreateUserFn                        func(name, password string, admin bool) (*meta.UserInfo, error)

	DatabaseFn  func(name string) *meta.DatabaseInfo
	DatabasesFn func() []meta.DatabaseInfo

	DataFn                func() meta.Data
	DeleteShardGroupFn    func(database string, policy string, id uint64) error
	DropContinuousQueryFn func(database, name string) error
	DropDatabaseFn        func(name string) error
	DropRetentionPolicyFn func(database, name string) error
	DropSubscriptionFn    func(database, rp, name string) error
	DropShardFn           func(id uint64) error
	DropUserFn            func(name string) error

	OpenFn func() error

	RetentionPolicyFn func(database, name string) (rpi *meta.RetentionPolicyInfo, err error)

	SetAdminPrivilegeFn         func(username string, admin bool) error
	SetDataFn                   func(*meta.Data) error
	SetDefaultRetentionPolicyFn func(database, name string) error
	SetPrivilegeFn              func(username, database string, p influxql.Privilege) error
	ShardsByTimeRangeFn         func(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)
	ShardOwnerFn                func(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)
	UpdateRetentionPolicyFn     func(database, name string, rpu *meta.RetentionPolicyUpdate) error
	UpdateUserFn                func(name, password string) error
	UserPrivilegeFn             func(username, database string) (*influxql.Privilege, error)
	UserPrivilegesFn            func(username string) (map[string]influxql.Privilege, error)
	UsersFn                     func() []meta.UserInfo
}

MetaClientMock is a mockable implementation of meta.MetaClient.

func (*MetaClientMock) Close

func (c *MetaClientMock) Close() error

func (*MetaClientMock) CreateContinuousQuery

func (c *MetaClientMock) CreateContinuousQuery(database, name, query string) error

func (*MetaClientMock) CreateDatabase

func (c *MetaClientMock) CreateDatabase(name string) (*meta.DatabaseInfo, error)

func (*MetaClientMock) CreateDatabaseWithRetentionPolicy

func (c *MetaClientMock) CreateDatabaseWithRetentionPolicy(name string, spec *meta.RetentionPolicySpec) (*meta.DatabaseInfo, error)

func (*MetaClientMock) CreateRetentionPolicy

func (c *MetaClientMock) CreateRetentionPolicy(database string, spec *meta.RetentionPolicySpec) (*meta.RetentionPolicyInfo, error)

func (*MetaClientMock) CreateShardGroup

func (c *MetaClientMock) CreateShardGroup(database, policy string, timestamp time.Time) (*meta.ShardGroupInfo, error)

func (*MetaClientMock) CreateSubscription

func (c *MetaClientMock) CreateSubscription(database, rp, name, mode string, destinations []string) error

func (*MetaClientMock) CreateUser

func (c *MetaClientMock) CreateUser(name, password string, admin bool) (*meta.UserInfo, error)

func (*MetaClientMock) Data

func (c *MetaClientMock) Data() meta.Data

func (*MetaClientMock) Database

func (c *MetaClientMock) Database(name string) *meta.DatabaseInfo

func (*MetaClientMock) Databases

func (c *MetaClientMock) Databases() []meta.DatabaseInfo

func (*MetaClientMock) DeleteShardGroup

func (c *MetaClientMock) DeleteShardGroup(database string, policy string, id uint64) error

func (*MetaClientMock) DropContinuousQuery

func (c *MetaClientMock) DropContinuousQuery(database, name string) error

func (*MetaClientMock) DropDatabase

func (c *MetaClientMock) DropDatabase(name string) error

func (*MetaClientMock) DropRetentionPolicy

func (c *MetaClientMock) DropRetentionPolicy(database, name string) error

func (*MetaClientMock) DropShard

func (c *MetaClientMock) DropShard(id uint64) error

func (*MetaClientMock) DropSubscription

func (c *MetaClientMock) DropSubscription(database, rp, name string) error

func (*MetaClientMock) DropUser

func (c *MetaClientMock) DropUser(name string) error

func (*MetaClientMock) Open

func (c *MetaClientMock) Open() error

func (*MetaClientMock) RetentionPolicy

func (c *MetaClientMock) RetentionPolicy(database, name string) (rpi *meta.RetentionPolicyInfo, err error)

func (*MetaClientMock) SetAdminPrivilege

func (c *MetaClientMock) SetAdminPrivilege(username string, admin bool) error

func (*MetaClientMock) SetData

func (c *MetaClientMock) SetData(d *meta.Data) error

func (*MetaClientMock) SetDefaultRetentionPolicy

func (c *MetaClientMock) SetDefaultRetentionPolicy(database, name string) error

func (*MetaClientMock) SetPrivilege

func (c *MetaClientMock) SetPrivilege(username, database string, p influxql.Privilege) error

func (*MetaClientMock) ShardOwner

func (c *MetaClientMock) ShardOwner(shardID uint64) (database, policy string, sgi *meta.ShardGroupInfo)

func (*MetaClientMock) ShardsByTimeRange

func (c *MetaClientMock) ShardsByTimeRange(sources influxql.Sources, tmin, tmax time.Time) (a []meta.ShardInfo, err error)

func (*MetaClientMock) UpdateRetentionPolicy

func (c *MetaClientMock) UpdateRetentionPolicy(database, name string, rpu *meta.RetentionPolicyUpdate) error

func (*MetaClientMock) UpdateUser

func (c *MetaClientMock) UpdateUser(name, password string) error

func (*MetaClientMock) UserPrivilege

func (c *MetaClientMock) UserPrivilege(username, database string) (*influxql.Privilege, error)

func (*MetaClientMock) UserPrivileges

func (c *MetaClientMock) UserPrivileges(username string) (map[string]influxql.Privilege, error)

func (*MetaClientMock) Users

func (c *MetaClientMock) Users() []meta.UserInfo