row

Documentation

Index

• type Model
  • func NewModel(db *m.Database) Model
  • func (m Model) Add(ctx context.Context, eventID primitive.ObjectID, ...) (err error)
  • func (m Model) Clean(ctx context.Context, eventID primitive.ObjectID) (err error)
  • func (m Model) Flush(ctx context.Context) (err error)
  • func (m Model) PipeMongoToLocalFile(ctx context.Context, eventID primitive.ObjectID) (csvPath string, err error)

Types

type Model

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

func NewModel

func NewModel(db *m.Database) Model

func (Model) Add

func (m Model) Add(
	ctx context.Context,
	eventID primitive.ObjectID,
	fullCompanyV2 *parser.FullCompanyV2,
) (
	err error,
)

func (Model) Clean

func (m Model) Clean(
	ctx context.Context,
	eventID primitive.ObjectID,
) (
	err error,
)

func (Model) Flush

func (m Model) Flush(
	ctx context.Context,
) (
	err error,
)

func (Model) PipeMongoToLocalFile

func (m Model) PipeMongoToLocalFile(
	ctx context.Context,
	eventID primitive.ObjectID,
) (
	csvPath string,
	err error,
)