ds

Documentation

Index

• func GetDataSourceService() (svc interfaces.DataSourceService, err error)
• func NewDataSourceCockroachdbService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceElasticsearchService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceKafkaService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceMongoService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceMssqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceMysqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourcePostgresqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• func NewDataSourceService(opts ...DataSourceServiceOption) (svc2 interfaces.DataSourceService, err error)
• func NewDataSourceSqliteService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)
• type CockroachdbService
• type DataSourceServiceOption
  • func WithMonitorInterval(duration time.Duration) DataSourceServiceOption
• type ElasticsearchService
  • func (svc *ElasticsearchService) Count(query generic.ListQuery) (n int, err error)
  • func (svc *ElasticsearchService) GetTime() (t time.Time)
  • func (svc *ElasticsearchService) Index(fields []string)
  • func (svc *ElasticsearchService) Insert(records ...interface{}) (err error)
  • func (svc *ElasticsearchService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)
  • func (svc *ElasticsearchService) SetTime(t time.Time)
• type KafkaService
  • func (svc *KafkaService) Count(query generic.ListQuery) (n int, err error)
  • func (svc *KafkaService) GetTime() (t time.Time)
  • func (svc *KafkaService) Index(fields []string)
  • func (svc *KafkaService) Insert(records ...interface{}) (err error)
  • func (svc *KafkaService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)
  • func (svc *KafkaService) SetTime(t time.Time)
• type MongoService
  • func (svc *MongoService) Count(query generic.ListQuery) (n int, err error)
  • func (svc *MongoService) GetTime() (t time.Time)
  • func (svc *MongoService) Index(fields []string)
  • func (svc *MongoService) Insert(records ...interface{}) (err error)
  • func (svc *MongoService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)
  • func (svc *MongoService) SetTime(t time.Time)
• type MssqlService
• type MysqlService
• type PostgresqlService
• type Service
  • func (svc *Service) ChangePassword(id primitive.ObjectID, password string) (err error)
  • func (svc *Service) CheckStatus(id primitive.ObjectID) (err error)
  • func (svc *Service) Init()
  • func (svc *Service) Monitor()
  • func (svc *Service) SetMonitorInterval(duration time.Duration)
  • func (svc *Service) SetTimeout(duration time.Duration)
  • func (svc *Service) Start()
  • func (svc *Service) Stop()
  • func (svc *Service) Wait()
• type SqlOptions
• type SqlService
  • func (svc *SqlService) Count(query generic.ListQuery) (n int, err error)
  • func (svc *SqlService) GetTime() (t time.Time)
  • func (svc *SqlService) Index(fields []string)
  • func (svc *SqlService) Insert(records ...interface{}) (err error)
  • func (svc *SqlService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)
  • func (svc *SqlService) SetTime(t time.Time)
• type SqliteService

Functions

func GetDataSourceService

func GetDataSourceService() (svc interfaces.DataSourceService, err error)

func NewDataSourceCockroachdbService

func NewDataSourceCockroachdbService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceElasticsearchService

func NewDataSourceElasticsearchService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceKafkaService

func NewDataSourceKafkaService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceMongoService

func NewDataSourceMongoService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceMssqlService

func NewDataSourceMssqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceMysqlService

func NewDataSourceMysqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourcePostgresqlService

func NewDataSourcePostgresqlService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

func NewDataSourceService

func NewDataSourceService(opts ...DataSourceServiceOption) (svc2 interfaces.DataSourceService, err error)

func NewDataSourceSqliteService

func NewDataSourceSqliteService(colId primitive.ObjectID, dsId primitive.ObjectID) (svc2 interfaces.ResultService, err error)

Types

type CockroachdbService

type CockroachdbService struct {
	SqlService
}

type DataSourceServiceOption

type DataSourceServiceOption func(svc interfaces.DataSourceService)

func WithMonitorInterval

func WithMonitorInterval(duration time.Duration) DataSourceServiceOption

type ElasticsearchService

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

func (*ElasticsearchService) Count

func (svc *ElasticsearchService) Count(query generic.ListQuery) (n int, err error)

func (*ElasticsearchService) GetTime

func (svc *ElasticsearchService) GetTime() (t time.Time)

func (*ElasticsearchService) Index

func (svc *ElasticsearchService) Index(fields []string)

func (*ElasticsearchService) Insert

func (svc *ElasticsearchService) Insert(records ...interface{}) (err error)

func (*ElasticsearchService) List

func (svc *ElasticsearchService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)

func (*ElasticsearchService) SetTime

func (svc *ElasticsearchService) SetTime(t time.Time)

type KafkaService

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

func (*KafkaService) Count

func (svc *KafkaService) Count(query generic.ListQuery) (n int, err error)

func (*KafkaService) GetTime

func (svc *KafkaService) GetTime() (t time.Time)

func (*KafkaService) Index

func (svc *KafkaService) Index(fields []string)

func (*KafkaService) Insert

func (svc *KafkaService) Insert(records ...interface{}) (err error)

func (*KafkaService) List

func (svc *KafkaService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)

func (*KafkaService) SetTime

func (svc *KafkaService) SetTime(t time.Time)

type MongoService

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

func (*MongoService) Count

func (svc *MongoService) Count(query generic.ListQuery) (n int, err error)

func (*MongoService) GetTime

func (svc *MongoService) GetTime() (t time.Time)

func (*MongoService) Index

func (svc *MongoService) Index(fields []string)

func (*MongoService) Insert

func (svc *MongoService) Insert(records ...interface{}) (err error)

func (*MongoService) List

func (svc *MongoService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)

func (*MongoService) SetTime

func (svc *MongoService) SetTime(t time.Time)

type MssqlService

type MssqlService struct {
	SqlService
}

type MysqlService

type MysqlService struct {
	SqlService
}

type PostgresqlService

type PostgresqlService struct {
	SqlService
}

type Service

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

func (*Service) ChangePassword

func (svc *Service) ChangePassword(id primitive.ObjectID, password string) (err error)

func (*Service) CheckStatus

func (svc *Service) CheckStatus(id primitive.ObjectID) (err error)

func (*Service) Init

func (svc *Service) Init()

func (*Service) Monitor

func (svc *Service) Monitor()

func (*Service) SetMonitorInterval

func (svc *Service) SetMonitorInterval(duration time.Duration)

func (*Service) SetTimeout

func (svc *Service) SetTimeout(duration time.Duration)

func (*Service) Start

func (svc *Service) Start()

func (*Service) Stop

func (svc *Service) Stop()

func (*Service) Wait

func (svc *Service) Wait()

type SqlOptions

type SqlOptions struct {
	DefaultHost string
	DefaultPort string
}

type SqlService

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

func (*SqlService) Count

func (svc *SqlService) Count(query generic.ListQuery) (n int, err error)

func (*SqlService) GetTime

func (svc *SqlService) GetTime() (t time.Time)

func (*SqlService) Index

func (svc *SqlService) Index(fields []string)

func (*SqlService) Insert

func (svc *SqlService) Insert(records ...interface{}) (err error)

func (*SqlService) List

func (svc *SqlService) List(query generic.ListQuery, opts *generic.ListOptions) (results []interface{}, err error)

func (*SqlService) SetTime

func (svc *SqlService) SetTime(t time.Time)

type SqliteService

type SqliteService struct {
	SqlService
}