datasource

Documentation

Index

• type MetricService
  • func NewMetricService(metricBiz *biz.MetricBiz) *MetricService
  • func (s *MetricService) DeleteMetric(ctx context.Context, req *datasourceapi.DeleteMetricRequest) (*datasourceapi.DeleteMetricReply, error)
  • func (s *MetricService) GetMetric(ctx context.Context, req *datasourceapi.GetMetricRequest) (*datasourceapi.GetMetricReply, error)
  • func (s *MetricService) ListMetric(ctx context.Context, req *datasourceapi.ListMetricRequest) (*datasourceapi.ListMetricReply, error)
  • func (s *MetricService) SelectMetric(ctx context.Context, req *datasourceapi.ListMetricRequest) (*datasourceapi.SelectMetricReply, error)
  • func (s *MetricService) SyncMetric(ctx context.Context, req *datasourceapi.SyncMetricRequest) (*datasourceapi.SyncMetricReply, error)
  • func (s *MetricService) UpdateMetric(ctx context.Context, req *datasourceapi.UpdateMetricRequest) (*datasourceapi.UpdateMetricReply, error)
• type Service
  • func NewDatasourceService(datasourceBiz *biz.DatasourceBiz) *Service
  • func (s *Service) CreateDatasource(ctx context.Context, req *datasourceapi.CreateDatasourceRequest) (*datasourceapi.CreateDatasourceReply, error)
  • func (s *Service) DatasourceQuery(ctx context.Context, req *datasourceapi.DatasourceQueryRequest) (*datasourceapi.DatasourceQueryReply, error)
  • func (s *Service) DeleteDatasource(ctx context.Context, req *datasourceapi.DeleteDatasourceRequest) (*datasourceapi.DeleteDatasourceReply, error)
  • func (s *Service) GetDatasource(ctx context.Context, req *datasourceapi.GetDatasourceRequest) (*datasourceapi.GetDatasourceReply, error)
  • func (s *Service) GetDatasourceSelect(ctx context.Context, req *datasourceapi.ListDatasourceRequest) (*datasourceapi.GetDatasourceSelectReply, error)
  • func (s *Service) ListDatasource(ctx context.Context, req *datasourceapi.ListDatasourceRequest) (*datasourceapi.ListDatasourceReply, error)
  • func (s *Service) MetricProxy() http.HandlerFunc
  • func (s *Service) ProxyQuery(ctx http.Context) error
  • func (s *Service) SyncDatasourceMeta(ctx context.Context, req *datasourceapi.SyncDatasourceMetaRequest) (*datasourceapi.SyncDatasourceMetaReply, error)
  • func (s *Service) UpdateDatasource(ctx context.Context, req *datasourceapi.UpdateDatasourceRequest) (*datasourceapi.UpdateDatasourceReply, error)
  • func (s *Service) UpdateDatasourceStatus(ctx context.Context, req *datasourceapi.UpdateDatasourceStatusRequest) (*datasourceapi.UpdateDatasourceStatusReply, error)

Types

type MetricService

type MetricService struct {
	datasourceapi.UnimplementedMetricServer
	// contains filtered or unexported fields
}

MetricService 指标服务

func NewMetricService

func NewMetricService(metricBiz *biz.MetricBiz) *MetricService

NewMetricService 创建指标服务

func (*MetricService) DeleteMetric

func (s *MetricService) DeleteMetric(ctx context.Context, req *datasourceapi.DeleteMetricRequest) (*datasourceapi.DeleteMetricReply, error)

DeleteMetric 删除指标

func (*MetricService) GetMetric

func (s *MetricService) GetMetric(ctx context.Context, req *datasourceapi.GetMetricRequest) (*datasourceapi.GetMetricReply, error)

GetMetric 获取指标

func (*MetricService) ListMetric

func (s *MetricService) ListMetric(ctx context.Context, req *datasourceapi.ListMetricRequest) (*datasourceapi.ListMetricReply, error)

ListMetric 获取指标列表

func (*MetricService) SelectMetric

func (s *MetricService) SelectMetric(ctx context.Context, req *datasourceapi.ListMetricRequest) (*datasourceapi.SelectMetricReply, error)

SelectMetric 获取指标下拉列表

func (*MetricService) SyncMetric

func (s *MetricService) SyncMetric(ctx context.Context, req *datasourceapi.SyncMetricRequest) (*datasourceapi.SyncMetricReply, error)

SyncMetric 同步指标

func (*MetricService) UpdateMetric

func (s *MetricService) UpdateMetric(ctx context.Context, req *datasourceapi.UpdateMetricRequest) (*datasourceapi.UpdateMetricReply, error)

UpdateMetric 更新指标

type Service

type Service struct {
	datasourceapi.UnimplementedDatasourceServer
	// contains filtered or unexported fields
}

Service 数据源服务

func NewDatasourceService

func NewDatasourceService(datasourceBiz *biz.DatasourceBiz) *Service

NewDatasourceService 创建数据源服务

func (*Service) CreateDatasource

func (s *Service) CreateDatasource(ctx context.Context, req *datasourceapi.CreateDatasourceRequest) (*datasourceapi.CreateDatasourceReply, error)

CreateDatasource 创建数据源

func (*Service) DatasourceQuery

func (s *Service) DatasourceQuery(ctx context.Context, req *datasourceapi.DatasourceQueryRequest) (*datasourceapi.DatasourceQueryReply, error)

DatasourceQuery 查询数据

func (*Service) DeleteDatasource

func (s *Service) DeleteDatasource(ctx context.Context, req *datasourceapi.DeleteDatasourceRequest) (*datasourceapi.DeleteDatasourceReply, error)

DeleteDatasource 删除数据源

func (*Service) GetDatasource

func (s *Service) GetDatasource(ctx context.Context, req *datasourceapi.GetDatasourceRequest) (*datasourceapi.GetDatasourceReply, error)

GetDatasource 获取数据源详情

func (*Service) GetDatasourceSelect

func (s *Service) GetDatasourceSelect(ctx context.Context, req *datasourceapi.ListDatasourceRequest) (*datasourceapi.GetDatasourceSelectReply, error)

GetDatasourceSelect 获取数据源下拉列表

func (*Service) ListDatasource

func (s *Service) ListDatasource(ctx context.Context, req *datasourceapi.ListDatasourceRequest) (*datasourceapi.ListDatasourceReply, error)

ListDatasource 获取数据源列表

func (*Service) MetricProxy

func (s *Service) MetricProxy() http.HandlerFunc

func (*Service) ProxyQuery

func (s *Service) ProxyQuery(ctx http.Context) error

ProxyQuery 查询数据

func (*Service) SyncDatasourceMeta

func (s *Service) SyncDatasourceMeta(ctx context.Context, req *datasourceapi.SyncDatasourceMetaRequest) (*datasourceapi.SyncDatasourceMetaReply, error)

SyncDatasourceMeta 同步数据源元数据

func (*Service) UpdateDatasource

func (s *Service) UpdateDatasource(ctx context.Context, req *datasourceapi.UpdateDatasourceRequest) (*datasourceapi.UpdateDatasourceReply, error)

UpdateDatasource 更新数据源

func (*Service) UpdateDatasourceStatus

func (s *Service) UpdateDatasourceStatus(ctx context.Context, req *datasourceapi.UpdateDatasourceStatusRequest) (*datasourceapi.UpdateDatasourceStatusReply, error)

UpdateDatasourceStatus 更新数据源状态