resources

package

Go to main page

Versions in this module

v0

v0.2.0

Apr 26, 2023

Changes in this version

+ type SortDtoData struct

+ Key string

+ Values []primitive.ObjectID

v0.1.4

Apr 17, 2023

v0.1.3

Apr 17, 2023

Changes in this version

type Service

+ func (x *Service) Pipe(data M, keys []string, kind interface{}) (err error)

v0.1.2

Mar 15, 2023

v0.1.1

Mar 15, 2023

Changes in this version

type BulkCreateDto

+ Txn string

type BulkDeleteDto

+ Txn string

type DeleteDto

+ Txn string

type PendingDto

+ Filter M

+ Id primitive.ObjectID

type ReplaceDto

+ Txn string

type UpdateByIdDto

+ Txn string

type UpdateDto

+ Txn string

v0.1.0

Mar 15, 2023

Changes in this version

+ var ErrTxnTimeOut = errors.NewPublic("the transaction has timed out")

+ var Provides = wire.NewSet(wire.Struct(new(Controller), "*"))

+ type BulkCreateDto struct

+ Collection string

+ Data []M

+ Format M

+ type BulkDeleteDto struct

+ Collection string

+ Data M

+ Format M

+ type CommitDto struct

+ Txn string

+ type Controller struct

+ Service *Service

+ func (x *Controller) BulkCreate(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) BulkDelete(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Commit(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Create(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Delete(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Find(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) FindById(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) FindOne(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Replace(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Size(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Sort(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Transaction(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) Update(ctx context.Context, c *app.RequestContext)

+ func (x *Controller) UpdateById(ctx context.Context, c *app.RequestContext)

+ type CreateDto struct

+ Collection string

+ Data M

+ Format M

+ Txn string

+ type DeleteDto struct

+ Collection string

+ Id string

+ type FindByIdDto struct

+ Collection string

+ Id string

+ Keys []string

+ type FindDto struct

+ Collection string

+ Filter M

+ Format M

+ Keys []string

+ Page int64

+ Pagesize int64

+ Sort []string

+ type FindOneDto struct

+ Collection string

+ Filter M

+ Format M

+ Keys []string

+ type M = map[string]interface

+ type Option func(x *Service)

+ func SetDatabase(v *mongo.Database) Option

+ func SetDynamicValues(v *values.DynamicValues) Option

+ func SetJetStream(v nats.JetStreamContext) Option

+ func SetMongoClient(v *mongo.Client) Option

+ func SetNamespace(v string) Option

+ func SetRedis(v *redis.Client) Option

+ type PendingDto struct

+ Action string

+ Data map[string]interface{}

+ Name string

+ type PublishDto struct

+ Action string

+ Data interface{}

+ Filter M

+ Id string

+ Result interface{}

+ type ReplaceDto struct

+ Collection string

+ Data M

+ Format M

+ Id string

+ type Service struct

+ Db *mongo.Database

+ DynamicValues *values.DynamicValues

+ Js nats.JetStreamContext

+ MongoClient *mongo.Client

+ Namespace string

+ Redis *redis.Client

+ func New(options ...Option) (x *Service, err error)

+ func (x *Service) BulkCreate(ctx context.Context, name string, docs []interface{}) (r interface{}, err error)

+ func (x *Service) BulkDelete(ctx context.Context, name string, filter M) (r interface{}, err error)

+ func (x *Service) Commit(ctx context.Context, txn string) (_ interface{}, err error)

+ func (x *Service) Create(ctx context.Context, name string, doc M) (r interface{}, err error)

+ func (x *Service) Delete(ctx context.Context, name string, id primitive.ObjectID) (r interface{}, err error)

+ func (x *Service) Find(ctx context.Context, name string, filter M, option *options.FindOptions) (data []M, err error)

+ func (x *Service) FindOne(ctx context.Context, name string, filter M, option *options.FindOneOptions) (data M, err error)

+ func (x *Service) Invoke(ctx context.Context, dto PendingDto) (_ interface{}, _ error)

+ func (x *Service) Load(ctx context.Context) (err error)

+ func (x *Service) Pending(ctx context.Context, txn string, dto PendingDto) (err error)

+ func (x *Service) Projection(name string, keys []string) (result bson.M)

+ func (x *Service) Publish(ctx context.Context, name string, dto PublishDto) (err error)

+ func (x *Service) Replace(ctx context.Context, name string, id primitive.ObjectID, doc M) (r interface{}, err error)

+ func (x *Service) Size(ctx context.Context, name string, filter M) (_ int64, err error)

+ func (x *Service) Sort(ctx context.Context, name string, ids []primitive.ObjectID) (r interface{}, err error)

+ func (x *Service) Transaction(ctx context.Context, txn string) (err error)

+ func (x *Service) Transform(data M, format M) (err error)

+ func (x *Service) Update(ctx context.Context, name string, filter M, update M) (r interface{}, err error)

+ func (x *Service) UpdateById(ctx context.Context, name string, id primitive.ObjectID, update M) (r interface{}, err error)

+ type SizeDto struct

+ Collection string

+ Filter M

+ Format M

+ type SortDto struct

+ Collection string

+ Data []primitive.ObjectID

+ Txn string

+ type UpdateByIdDto struct

+ Collection string

+ Data M

+ Format M

+ Id string

+ type UpdateDto struct

+ Collection string

+ DFormat M

+ Data M

+ FFormat M

+ Filter M

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL