rcs_server

Documentation

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) DeleteFriendshipByRoomID(ctx context.Context, roomID string) error
  • func (d *Database) GetFriendshipByFcIDAndToFcID(ctx context.Context, fcID, toFcID string) (*types.RCSFriendship, error)
  • func (d *Database) GetFriendshipByFcIDOrToFcID(ctx context.Context, fcID, toFcID string) (*external.GetFriendshipResponse, error)
  • func (d *Database) GetFriendshipByRoomID(ctx context.Context, roomID string) (*types.RCSFriendship, error)
  • func (d *Database) GetFriendshipsByFcIDOrToFcID(ctx context.Context, userID string) ([]external.Friendship, error)
  • func (d *Database) GetFriendshipsByFcIDOrToFcIDWithBot(ctx context.Context, userID string) ([]external.Friendship, error)
  • func (d *Database) InsertFriendship(ctx context.Context, ID, roomID, fcID, toFcID, fcIDState, toFcIDState string, ...) error
  • func (d *Database) NotFound(err error) bool
  • func (d *Database) SetGauge(gauge mon.LabeledGauge)
  • func (d *Database) SetIDGenerator(idg *uid.UidGenerator)
  • func (d *Database) UpdateFriendshipByRoomID(ctx context.Context, ID, roomID, fcID, toFcID, fcIDState, toFcIDState string, ...) error

Functions

func NewDatabase

func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)

Types

type Database

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

func (*Database) DeleteFriendshipByRoomID

func (d *Database) DeleteFriendshipByRoomID(
	ctx context.Context, roomID string,
) error

func (*Database) GetFriendshipByFcIDAndToFcID

func (d *Database) GetFriendshipByFcIDAndToFcID(
	ctx context.Context, fcID, toFcID string,
) (*types.RCSFriendship, error)

func (*Database) GetFriendshipByFcIDOrToFcID

func (d *Database) GetFriendshipByFcIDOrToFcID(
	ctx context.Context, fcID, toFcID string,
) (*external.GetFriendshipResponse, error)

func (*Database) GetFriendshipByRoomID

func (d *Database) GetFriendshipByRoomID(
	ctx context.Context, roomID string,
) (*types.RCSFriendship, error)

func (*Database) GetFriendshipsByFcIDOrToFcID

func (d *Database) GetFriendshipsByFcIDOrToFcID(
	ctx context.Context, userID string,
) ([]external.Friendship, error)

func (*Database) GetFriendshipsByFcIDOrToFcIDWithBot

func (d *Database) GetFriendshipsByFcIDOrToFcIDWithBot(
	ctx context.Context, userID string,
) ([]external.Friendship, error)

func (*Database) InsertFriendship

func (d *Database) InsertFriendship(
	ctx context.Context, ID, roomID, fcID, toFcID, fcIDState, toFcIDState string,
	fcIDIsBot, toFcIDIsBot bool, fcIDRemark, toFcIDRemark string,
	fcIDOnceJoined, toFcIDOnceJoined bool, fcIDDomain, toFcIDDomain, eventID string,
) error

func (*Database) NotFound

func (d *Database) NotFound(err error) bool

func (*Database) SetGauge

func (d *Database) SetGauge(gauge mon.LabeledGauge)

func (*Database) SetIDGenerator

func (d *Database) SetIDGenerator(idg *uid.UidGenerator)

func (*Database) UpdateFriendshipByRoomID

func (d *Database) UpdateFriendshipByRoomID(
	ctx context.Context, ID, roomID, fcID, toFcID, fcIDState, toFcIDState string,
	fcIDIsBot, toFcIDIsBot bool, fcIDRemark, toFcIDRemark string,
	fcIDOnceJoined, toFcIDOnceJoined bool, fcIDDomain, toFcIDDomain, eventID string,
) error