cockroachdb

Documentation

Index

• type ContactRepo
  • func NewContactRepo(db *sqlx.DB) *ContactRepo
  • func (repo *ContactRepo) Block(ctx context.Context, target *messenger.Contact) error
  • func (repo *ContactRepo) Contacts(ctx context.Context, opts *messenger.FindContactOptions) ([]*messenger.Contact, error)
  • func (repo *ContactRepo) DB() *sqlx.DB
  • func (repo *ContactRepo) InsertTx(ctx context.Context, target *messenger.Contact, tx *sqlx.Tx) error
• type ConversationRepo
  • func NewConversationRepo(db *sqlx.DB) *ConversationRepo
  • func (repo *ConversationRepo) Conversations(ctx context.Context, opts *messenger.FindConversionOptions) ([]*messenger.Conversation, error)
  • func (repo *ConversationRepo) DB() *sqlx.DB
  • func (repo *ConversationRepo) InsertTx(ctx context.Context, target *messenger.Conversation, tx *sqlx.Tx) error
• type GroupMemberRepo
  • func NewGroupMemberRepo(db *sqlx.DB) *GroupMemberRepo
  • func (repo *GroupMemberRepo) BatchInsertTx(ctx context.Context, members []*messenger.GroupMember, tx *sqlx.Tx) error
  • func (repo *GroupMemberRepo) DB() *sqlx.DB
  • func (repo *GroupMemberRepo) GroupMembers(ctx context.Context, opts *messenger.FindGroupMemberOptions) ([]*messenger.GroupMember, error)
• type GroupRepo
  • func NewGroupRepo(db *sqlx.DB) *GroupRepo
  • func (repo *GroupRepo) DB() *sqlx.DB
  • func (repo *GroupRepo) Groups(ctx context.Context, opts *messenger.FindGroupOptions) ([]*messenger.Group, error)
  • func (repo *GroupRepo) InsertTx(ctx context.Context, target *messenger.Group, tx *sqlx.Tx) error
  • func (repo *GroupRepo) IsMemberInGroup(ctx context.Context, memberID, groupID string) bool
• type MessageRepo
  • func NewMessageRepo(db *sqlx.DB) *MessageRepo
  • func (repo *MessageRepo) BatchInsert(ctx context.Context, targets []*messenger.Message) error
  • func (repo *MessageRepo) DB() *sqlx.DB

Types

type ContactRepo

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

func NewContactRepo

func NewContactRepo(db *sqlx.DB) *ContactRepo

func (*ContactRepo) Block

func (repo *ContactRepo) Block(ctx context.Context, target *messenger.Contact) error

func (*ContactRepo) Contacts

func (repo *ContactRepo) Contacts(ctx context.Context, opts *messenger.FindContactOptions) ([]*messenger.Contact, error)

func (*ContactRepo) DB

func (repo *ContactRepo) DB() *sqlx.DB

func (*ContactRepo) InsertTx

func (repo *ContactRepo) InsertTx(ctx context.Context, target *messenger.Contact, tx *sqlx.Tx) error

type ConversationRepo

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

func NewConversationRepo

func NewConversationRepo(db *sqlx.DB) *ConversationRepo

func (*ConversationRepo) Conversations

func (repo *ConversationRepo) Conversations(ctx context.Context, opts *messenger.FindConversionOptions) ([]*messenger.Conversation, error)

func (*ConversationRepo) DB

func (repo *ConversationRepo) DB() *sqlx.DB

func (*ConversationRepo) InsertTx

func (repo *ConversationRepo) InsertTx(ctx context.Context, target *messenger.Conversation, tx *sqlx.Tx) error

type GroupMemberRepo

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

func NewGroupMemberRepo

func NewGroupMemberRepo(db *sqlx.DB) *GroupMemberRepo

func (*GroupMemberRepo) BatchInsertTx

func (repo *GroupMemberRepo) BatchInsertTx(ctx context.Context, members []*messenger.GroupMember, tx *sqlx.Tx) error

func (*GroupMemberRepo) DB

func (repo *GroupMemberRepo) DB() *sqlx.DB

func (*GroupMemberRepo) GroupMembers

func (repo *GroupMemberRepo) GroupMembers(ctx context.Context, opts *messenger.FindGroupMemberOptions) ([]*messenger.GroupMember, error)

type GroupRepo

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

func NewGroupRepo

func NewGroupRepo(db *sqlx.DB) *GroupRepo

func (*GroupRepo) DB

func (repo *GroupRepo) DB() *sqlx.DB

func (*GroupRepo) Groups

func (repo *GroupRepo) Groups(ctx context.Context, opts *messenger.FindGroupOptions) ([]*messenger.Group, error)

func (*GroupRepo) InsertTx

func (repo *GroupRepo) InsertTx(ctx context.Context, target *messenger.Group, tx *sqlx.Tx) error

func (*GroupRepo) IsMemberInGroup

func (repo *GroupRepo) IsMemberInGroup(ctx context.Context, memberID, groupID string) bool

type MessageRepo

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

func NewMessageRepo

func NewMessageRepo(db *sqlx.DB) *MessageRepo

func (*MessageRepo) BatchInsert

func (repo *MessageRepo) BatchInsert(ctx context.Context, targets []*messenger.Message) error

func (*MessageRepo) DB

func (repo *MessageRepo) DB() *sqlx.DB