pushdb

package

v1.4.0 Latest Latest Go to latest Published: Jun 4, 2026 License: GPL-3.0 Imports: 4 Imported by: 0

Details

Code generated by godddx, DO AVOID EDIT.

This section is empty.

This section is empty.

This section is empty.

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

DB Related business namespaces

func NewDB(db *gorm.DB) DB

NewDB instance object

func (d DB) AutoMigrate(ok bool) DB

AutoMigrate sync database

func (d DB) StreamPush() push.StreamPushStorer

StreamPush Get business instance

type StreamPush DB

StreamPush Related business namespaces

func NewStreamPush(db *gorm.DB) StreamPush

NewStreamPush instance object

func (d StreamPush) Add(ctx context.Context, model *push.StreamPush) error

Add implements push.StreamPushStorer.

func (d StreamPush) Del(ctx context.Context, model *push.StreamPush, opts ...orm.QueryOption) error

Del implements push.StreamPushStorer.

func (d StreamPush) Edit(ctx context.Context, model *push.StreamPush, changeFn func(*push.StreamPush), opts ...orm.QueryOption) error

Edit implements push.StreamPushStorer.

func (d StreamPush) EditWithSession(tx *gorm.DB, model *push.StreamPush, changeFn func(b *push.StreamPush) error, opts ...orm.QueryOption) error

func (d StreamPush) Find(ctx context.Context, bs *[]*push.StreamPush, page orm.Pager, opts ...orm.QueryOption) (int64, error)

Find implements push.StreamPushStorer.

func (d StreamPush) Get(ctx context.Context, model *push.StreamPush, opts ...orm.QueryOption) error

Get implements push.StreamPushStorer.

func (d StreamPush) Session(ctx context.Context, changeFns ...func(*gorm.DB) error) error