src

Documentation

Index

• Constants
• type MongoStore
  • func (ms *MongoStore) Init(setting map[string]interface{}) (err error)
  • func (MongoStore) Push(params output.Params, replay *output.Replay) (err error)
  • func (MongoStore) UpdateDeleted(params output.Params, replay *int32) (err error)
  • func (MongoStore) UpdateSyncJob(params output.JobParams, jobId *string) (err error)

Constants

const DefaultConnectURI string = "mongodb://localhost:27017"

const DefaultDatabase string = "CloudTracker"

const DefaultMaxPoolSize uint64 = 100

const DefaultTimeout time.Duration = 30

Types

type MongoStore

type MongoStore struct {
	output.Provider
	// contains filtered or unexported fields
}

func (*MongoStore) Init

func (ms *MongoStore) Init(setting map[string]interface{}) (err error)

func (MongoStore) Push

func (MongoStore) Push(params output.Params, replay *output.Replay) (err error)

func (MongoStore) UpdateDeleted

func (MongoStore) UpdateDeleted(params output.Params, replay *int32) (err error)

func (MongoStore) UpdateSyncJob

func (MongoStore) UpdateSyncJob(params output.JobParams, jobId *string) (err error)