destination

Documentation

Index

• type Destination
  • func NewSource(ctx context.Context) *Destination
  • func (o *Destination) Add(param *Params) (interface{}, bool, error)
  • func (o *Destination) Connect(config settings.MongoUri) error
  • func (o *Destination) Delete(param *Params) (bool, error)
  • func (o *Destination) Drop(param *Params) error
  • func (o *Destination) Upsert(param *Params) (bool, error)
• type Params

Types

type Destination

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

func NewSource

func NewSource(ctx context.Context) *Destination

func (*Destination) Add

func (o *Destination) Add(param *Params) (interface{}, bool, error)

func (*Destination) Connect

func (o *Destination) Connect(config settings.MongoUri) error

func (*Destination) Delete

func (o *Destination) Delete(param *Params) (bool, error)

func (*Destination) Drop

func (o *Destination) Drop(param *Params) error

func (*Destination) Upsert

func (o *Destination) Upsert(param *Params) (bool, error)

type Params

type Params struct {
	DbName  string
	ColName string
	Id      primitive.ObjectID
	Record  map[string]interface{}
}