source

Documentation

Index

• type ChangeEvent
• type Params
• type Source
  • func NewSource(ctx context.Context) *Source
  • func (o *Source) Connect(config settings.MongoSource) error
  • func (o *Source) GetClone(param *Params) (*mongo.Cursor, error)
  • func (o *Source) GetCount(param *Params) (int64, error)
  • func (o *Source) GetStream(param *Params) (*mongo.ChangeStream, error)

Types

type ChangeEvent

type ChangeEvent struct {
	ID            token.Data             `bson:"_id" json:"_id"`
	FullDocument  map[string]interface{} `bson:"fullDocument" json:"fullDocument"`
	OperationType string                 `bson:"operationType" json:"operationType"`
	DocumentKey   struct {
		Id primitive.ObjectID `bson:"_id" json:"_id"`
	} `bson:"documentKey" json:"documentKey"`
	Ns struct {
		Coll string `bson:"coll" json:"coll"`
		Db   string `bson:"db" json:"db"`
	} `bson:"ns" json:"ns"`
}

type Params

type Params struct {
	DbName  string
	ColName string
	Time    string
	Token   token.Data
}

type Source

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

func NewSource

func NewSource(ctx context.Context) *Source

func (*Source) Connect

func (o *Source) Connect(config settings.MongoSource) error

func (*Source) GetClone

func (o *Source) GetClone(param *Params) (*mongo.Cursor, error)

func (*Source) GetCount

func (o *Source) GetCount(param *Params) (int64, error)

func (*Source) GetStream

func (o *Source) GetStream(param *Params) (*mongo.ChangeStream, error)