mongo

Nov 12, 2024

Changes in this version

type ConfigMembers

+ func (m *ConfigMembers) FixMemberConfigs(ctx context.Context, compareWith ConfigMembers) (changes bool)

+ func (m *ConfigMembers) FixMemberHostnames(ctx context.Context, compareWith ConfigMembers, rsStatus Status) (member *Member, changes bool)

+ type GetRoleResult struct

+ AuthenticationRestrictions [][]RoleAuthenticationRestriction

+ DB string

+ Privileges []RolePrivilege

+ Role string

+ Roles []InheritenceRole

+ type InheritenceRole struct

+ DB string

+ Role string

type Role

+ AuthenticationRestrictions []RoleAuthenticationRestriction

+ DB string

+ type RoleAuthenticationRestriction struct

+ ClientSource []string

+ ServerAddress []string

type User

+ DB string

Oct 9, 2023

Changes in this version

+ type Client interface

+ AddShard func(ctx context.Context, rsName, host string) error

+ CreateRole func(ctx context.Context, role string, privileges []RolePrivilege, ...) error

+ CreateUser func(ctx context.Context, user, pwd string, roles ...map[string]interface{}) error

+ Database func(name string, opts ...*options.DatabaseOptions) ClientDatabase

+ Disconnect func(ctx context.Context) error

+ Freeze func(ctx context.Context, seconds int) error

+ GetFCV func(ctx context.Context) (string, error)

+ GetRole func(ctx context.Context, role string) (*Role, error)

+ GetUserInfo func(ctx context.Context, username string) (*User, error)

+ IsBalancerRunning func(ctx context.Context) (bool, error)

+ IsMaster func(ctx context.Context) (*IsMasterResp, error)

+ ListDBs func(ctx context.Context) (DBList, error)

+ ListShard func(ctx context.Context) (ShardList, error)

+ Ping func(ctx context.Context, rp *readpref.ReadPref) error

+ RSBuildInfo func(ctx context.Context) (BuildInfo, error)

+ RSStatus func(ctx context.Context) (Status, error)

+ ReadConfig func(ctx context.Context) (RSConfig, error)

+ RemoveShard func(ctx context.Context, shard string) (ShardRemoveResp, error)

+ SetDefaultRWConcern func(ctx context.Context, readConcern, writeConcern string) error

+ SetFCV func(ctx context.Context, version string) error

+ StartBalancer func(ctx context.Context) error

+ StepDown func(ctx context.Context, seconds int, force bool) error

+ StopBalancer func(ctx context.Context) error

+ UpdateRole func(ctx context.Context, role string, privileges []RolePrivilege, ...) error

+ UpdateUser func(ctx context.Context, currName, newName, pass string) error

+ UpdateUserPass func(ctx context.Context, name, pass string) error

+ UpdateUserRoles func(ctx context.Context, username string, roles []map[string]interface{}) error

+ WriteConfig func(ctx context.Context, cfg RSConfig) error

+ func ToInterface(client *mongo.Client) Client

+ type ClientDatabase interface

+ RunCommand func(ctx context.Context, runCommand interface{}, opts ...*options.RunCmdOptions) *mongo.SingleResult

type ConfigMember

+ Horizons map[string]string

type ConfigMembers

+ func (m *ConfigMembers) HorizonsChanged(compareWith ConfigMembers) bool

Sep 14, 2022

Changes in this version

+ const DefaultReadConcern

+ const DefaultVotes

+ const DefaultWriteConcern

+ func SetDefaultRWConcern(ctx context.Context, client *mongo.Client, readConcern, writeConcern string) error

May 4, 2022

Changes in this version

+ const DefaultPriority

+ func UpdateRole(ctx context.Context, client *mongo.Client, role string, ...) error

+ func UpdateUserRoles(ctx context.Context, client *mongo.Client, username string, ...) error

type Config

+ Direct bool

type ConfigMembers

+ func (m *ConfigMembers) FixHosts(compareWith ConfigMembers) (changes bool)

+ type Role struct

+ Privileges []RolePrivilege

+ Role string

+ Roles []map[string]interface{}

+ func GetRole(ctx context.Context, client *mongo.Client, role string) (*Role, error)

+ type RoleInfo struct

+ Roles []Role

+ type RolePrivilege struct

+ Actions []string

+ Resource map[string]interface{}

+ type User struct

+ Roles []map[string]interface{}

+ func GetUserInfo(ctx context.Context, client *mongo.Client, username string) (*User, error)

+ type UsersInfo struct

+ Users []User

Sep 29, 2021

Changes in this version

type ConfigMember

+ SecondaryDelaySecs *int64

type ConfigMembers

+ func (m *ConfigMembers) ExternalNodesChanged(compareWith ConfigMembers) bool

+ func (m *ConfigMembers) FixTags(compareWith ConfigMembers) (changes bool)

+ type IsMasterResp struct

+ IsArbiter bool

+ IsMaster bool

+ Msg string

+ func IsMaster(ctx context.Context, client *mongo.Client) (*IsMasterResp, error)

type Status

+ func (s *Status) GetSelf() *Member

May 4, 2021

Changes in this version

+ func AddShard(ctx context.Context, client *mongo.Client, rsName, host string) error

+ func CreateRole(ctx context.Context, client *mongo.Client, role string, ...) error

+ func CreateUser(ctx context.Context, client *mongo.Client, user, pwd string, ...) error

+ func GetFCV(ctx context.Context, client *mongo.Client) (string, error)

+ func SetFCV(ctx context.Context, client *mongo.Client, version string) error

+ type FCV struct

+ FCV struct{ ... }

Mar 5, 2021

Changes in this version

+ const ShardRemoveCompleted

+ type DBList struct

+ DBs []struct{ ... }

+ func ListDBs(ctx context.Context, client *mongo.Client) (DBList, error)

+ type ShardRemoveResp struct

+ Msg string

+ Remaining struct{ ... }

+ State string

+ func RemoveShard(ctx context.Context, client *mongo.Client, shard string) (ShardRemoveResp, error)

Dec 21, 2020

Changes in this version

+ func IsBalancerRunning(ctx context.Context, client *mongo.Client) (bool, error)

+ func StartBalancer(ctx context.Context, client *mongo.Client) error

+ func StopBalancer(ctx context.Context, client *mongo.Client) error

+ type BalancerStatus struct

+ Mode string

+ type Config struct

+ Hosts []string

+ Password string

+ ReplSetName string

+ TLSConf *tls.Config

+ Username string

+ type ShardList struct

+ Shards []struct{ ... }

+ func ListShard(ctx context.Context, client *mongo.Client) (ShardList, error)

Sep 4, 2020

Changes in this version

+ const MemberHealthDown

+ const MemberHealthUp

+ const MemberStateArbiter

+ const MemberStateDown

+ const MemberStatePrimary

+ const MemberStateRecovering

+ const MemberStateRemoved

+ const MemberStateRollback

+ const MemberStateSecondary

+ const MemberStateStartup

+ const MemberStateStartup2

+ const MemberStateUnknown

+ var MemberStateStrings = map[MemberState]string

+ func StepDown(ctx context.Context, client *mongo.Client) error

+ func UpdateUser(ctx context.Context, client *mongo.Client, currName, newName, pass string) error

+ func UpdateUserPass(ctx context.Context, client *mongo.Client, name, pass string) error

+ type BuildInfo struct

+ Version string

+ func RSBuildInfo(ctx context.Context, client *mongo.Client) (BuildInfo, error)

+ type ConfigMember struct

+ ArbiterOnly bool

+ BuildIndexes bool

+ Hidden bool

+ Host string

+ ID int

+ Priority int

+ SlaveDelay int64

+ Tags ReplsetTags

+ Votes int

+ func (m ConfigMember) String() string

+ type ConfigMembers []ConfigMember

+ func (m *ConfigMembers) AddNew(from ConfigMembers) (changes bool)

+ func (m *ConfigMembers) RemoveOld(compareWith ConfigMembers) (changes bool)

+ func (m *ConfigMembers) SetVotes()

type Member

+ ConfigVersion int

+ ElectionDate time.Time

+ ElectionTime primitive.Timestamp

+ Health MemberHealth

+ Id int

+ InfoMessage string

+ LastHeartbeat time.Time

+ LastHeartbeatRecv time.Time

+ Name string

+ Optime *Optime

+ OptimeDate time.Time

+ OptimeDurable *Optime

+ OptimeDurableDate time.Time

+ PingMs int64

+ Self bool

+ State MemberState

+ StateStr string

+ SyncingTo string

+ Uptime int64

+ type MemberHealth int

+ type MemberState int

+ type Optime struct

+ Term int64

+ Timestamp primitive.Timestamp

+ type Status struct

+ Date time.Time

+ HeartbeatIntervalMillis int64

+ Members []*Member

+ MyState MemberState

+ Optimes *StatusOptimes

+ Set string

+ Term int64

+ func RSStatus(ctx context.Context, client *mongo.Client) (Status, error)

+ func (s *Status) GetMembersByState(state MemberState, limit int) []*Member

+ func (s *Status) Primary() *Member

+ type StatusOptimes struct

+ AppliedOpTime *Optime

+ DurableOptime *Optime

+ LastCommittedOpTime *Optime

Jun 26, 2019

Changes in this version

+ const MaxMembers

+ const MaxVotingMembers

+ const MinVotingMembers

+ func Dial(addrs []string, replset string, usersSecret *corev1.Secret, useTLS bool) (*mgo.Session, error)

+ func WriteConfig(session *mgo.Session, cfg RSConfig) error

+ type Member struct

+ ArbiterOnly bool

+ BuildIndexes bool

+ Hidden bool

+ Host string

+ ID int

+ Priority int

+ SlaveDelay int64

+ Tags ReplsetTags

+ Votes int

+ func (m Member) String() string

+ type OKResponse struct

+ Errmsg string

+ OK int

+ type RSConfig struct

+ Configsvr bool

+ ID string

+ Members RSMembers

+ ProtocolVersion int

+ Settings Settings

+ Version int

+ WriteConcernMajorityJournalDefault bool

+ func ReadConfig(session *mgo.Session) (RSConfig, error)

+ type RSMembers []Member

+ func (m *RSMembers) AddNew(from RSMembers) (changes bool)

+ func (m *RSMembers) RemoveOld(compareWith RSMembers) (changes bool)

+ func (m *RSMembers) SetVotes()

+ type ReplSetGetConfig struct

+ Config *RSConfig

+ Errmsg string

+ type ReplsetTags map[string]string

+ type Settings struct

+ CatchUpTimeoutMillis int64

+ ChainingAllowed bool

+ ElectionTimeoutMillis int64

+ GetLastErrorDefaults WriteConcern

+ GetLastErrorModes map[string]ReplsetTags

+ HeartbeatIntervalMillis int64

+ HeartbeatTimeoutSecs int

+ ReplicaSetID bson.ObjectId

+ type WriteConcern struct

+ Journal bool

+ WriteConcern interface{}

+ WriteTimeout int