pushdb

package

v1.4.21 Latest Latest Go to latest Published: Aug 10, 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) Create(ctx context.Context, model *push.StreamPush) error

Create implements push.StreamPushStorer.

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

Delete implements push.StreamPushStorer.

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

Get implements push.StreamPushStorer.

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

List implements push.StreamPushStorer.

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

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

Update implements push.StreamPushStorer.

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