db

Documentation

Index

• Constants
• type Database
  • func OpenDatabase(l *zap.Logger, client *redis.Client) *Database
  • func (db *Database) AddPartyMember(partyId string, uid string, member *pb.Member) error
  • func (db *Database) ClearParty(id string)
  • func (db *Database) CreateParty(id, uid string, party *pb.PartySetting) error
  • func (db *Database) GetInvite(uid string) (*PartyInvite, error)
  • func (db *Database) GetPartyId() (string, error)
  • func (db *Database) GetPartyMaxNumber(id string) (int, error)
  • func (db *Database) GetPartyMemberNum(partyId string) (int32, error)
  • func (db *Database) GetPartyMembers(partyId string) (map[string]*pb.Member, error)
  • func (db *Database) GetPartyOwner(id string) (string, error)
  • func (db *Database) GetPartySetting(id string) (*pb.PartySetting, error)
  • func (db *Database) GetUid2Pid(uid string) (string, error)
  • func (db *Database) RemovePartyMember(id string, uid string) error
  • func (db *Database) RemoveUid2Pid(uid string) error
  • func (db *Database) SaveInvite(invite *PartyInvite) error
  • func (db *Database) SaveUid2Pid(uid string, pid string) error
  • func (db *Database) UpdatePartyMember(partyId string, member *pb.Member) error
  • func (db *Database) UpdatePartySetting(id string, msg *pb.PartySetting) error
• type Party
  • func (p *Party) MarshalBinary() ([]byte, error)
  • func (p *Party) ToProto() *pb.PartySetting
• type PartyInvite
  • func (pi *PartyInvite) MarshalBinary() ([]byte, error)

Constants

const PartyExpireTime = time.Hour * 4

Types

type Database

type Database struct {
	*redis.Client
	// contains filtered or unexported fields
}

func OpenDatabase

func OpenDatabase(l *zap.Logger, client *redis.Client) *Database

func (*Database) AddPartyMember

func (db *Database) AddPartyMember(partyId string, uid string, member *pb.Member) error

func (*Database) ClearParty

func (db *Database) ClearParty(id string)

func (*Database) CreateParty

func (db *Database) CreateParty(id, uid string, party *pb.PartySetting) error

func (*Database) GetInvite

func (db *Database) GetInvite(uid string) (*PartyInvite, error)

func (*Database) GetPartyId

func (db *Database) GetPartyId() (string, error)

func (*Database) GetPartyMaxNumber

func (db *Database) GetPartyMaxNumber(id string) (int, error)

func (*Database) GetPartyMemberNum

func (db *Database) GetPartyMemberNum(partyId string) (int32, error)

func (*Database) GetPartyMembers

func (db *Database) GetPartyMembers(partyId string) (map[string]*pb.Member, error)

func (*Database) GetPartyOwner

func (db *Database) GetPartyOwner(id string) (string, error)

func (*Database) GetPartySetting

func (db *Database) GetPartySetting(id string) (*pb.PartySetting, error)

func (*Database) GetUid2Pid

func (db *Database) GetUid2Pid(uid string) (string, error)

func (*Database) RemovePartyMember

func (db *Database) RemovePartyMember(id string, uid string) error

func (*Database) RemoveUid2Pid

func (db *Database) RemoveUid2Pid(uid string) error

func (*Database) SaveInvite

func (db *Database) SaveInvite(invite *PartyInvite) error

func (*Database) SaveUid2Pid

func (db *Database) SaveUid2Pid(uid string, pid string) error

func (*Database) UpdatePartyMember

func (db *Database) UpdatePartyMember(partyId string, member *pb.Member) error

func (*Database) UpdatePartySetting

func (db *Database) UpdatePartySetting(id string, msg *pb.PartySetting) error

type Party

type Party struct {
	Id        string           `redis:"id"`
	Type      int32            `redis:"type"`
	Owner     string           `redis:"owner"`
	Name      string           `redis:"name"`
	MaxMember int32            `redis:"max_member"`
	Refuse    map[string]int64 `redis:"refuse"` //拒绝列表 key:申请的玩家ID value:拒绝时间戳 秒
}

func (*Party) MarshalBinary

func (p *Party) MarshalBinary() ([]byte, error)

func (*Party) ToProto

func (p *Party) ToProto() *pb.PartySetting

type PartyInvite

type PartyInvite struct {
	Id         string           `redis:"id"`
	Inviter    string           `redis:"Inviter"`     //邀请玩家ID
	InviteTime int64            `redis:"invite_time"` //邀请时间戳 秒
	Refuse     map[string]int64 `redis:"refuse"`      //拒绝列表 key:邀请玩家ID value:拒绝时间戳 秒
}

func (*PartyInvite) MarshalBinary

func (pi *PartyInvite) MarshalBinary() ([]byte, error)