sources

type ChangeStreamOperation struct {
	ResumeToken       map[string]interface{} `bson:"_id" json:"_id"`
	ResumeTokenString string                 `bson:"_id._data" json:"_id._data"`
	DocumentId        map[string]interface{} `bson:"documentKey" json:"documentKey"`
	DocumentIdString  string                 `bson:"documentKey._id" json:"documentKey._id"`
	OperationType     string                 `bson:"operationType" json:"operationType"`
	FullDocument      map[string]interface{} `bson:"fullDocument" json:"fullDocument"`
	WallTime          time.Time              `bson:"wallTime" json:"wallTime"`
	Ns                struct {
		Db   string `bson:"db" json:"db"`
		Coll string `bson:"coll" json:"coll"`
	} `bson:"ns" json:"ns"`
	UpdateDescription struct {
		UpdatedFields   map[string]interface{} `bson:"updatedFields" json:"updatedFields"`
		RemovedFields   []interface{}          `bson:"removedFields" json:"removedFields"`
		TruncatedArrays []interface{}          `bson:"truncatedArrays" json:"truncatedArrays"`
	} `bson:"updateDescription" json:"updateDescription"`
	ClusterTime primitive.Timestamp `json:"clusterTime" bson:"clusterTime"`
}

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

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

type SourceConfig struct {
	Name           string            `koanf:"name" json:"name"`
	ConnectionType string            `koanf:"type" json:"type"`
	Config         map[string]string `koanf:"config" json:"config"`
	Key            string            `koanf:"key" json:"key"`
}