server

Documentation

Index

• func Start() (err error)
• type SourceManagerServer
  • func NewSourceManagerServer(executor *executor.SourcemanagerExecutor) *SourceManagerServer
  • func (s *SourceManagerServer) CreateDataSource(ctx context.Context, req *request.CreateDataSource) (*response.CreateDataSource, error)
  • func (s *SourceManagerServer) CreateTable(ctx context.Context, req *request.CreateTable) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) DataFormat(ctx context.Context, req *model.EmptyStruct) (*response.JsonList, error)
  • func (s *SourceManagerServer) DataType(ctx context.Context, req *model.EmptyStruct) (*response.JsonList, error)
  • func (s *SourceManagerServer) DeleteDataSources(ctx context.Context, req *request.DeleteDataSources) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) DeleteDataSourcesBySpaceId(ctx context.Context, req *request.DeleteWorkspaces) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) DeleteTable(ctx context.Context, req *request.DeleteTable) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) DescribeDataSource(ctx context.Context, req *request.DescribeDataSource) (*response.DescribeDataSource, error)
  • func (s *SourceManagerServer) DescribeDataSourceKinds(ctx context.Context, req *model.EmptyStruct) (*response.DescribeDataSourceKinds, error)
  • func (s *SourceManagerServer) DescribeTable(ctx context.Context, req *request.DescribeTable) (*response.DescribeTable, error)
  • func (s *SourceManagerServer) DisableDataSources(ctx context.Context, req *request.DisableDataSources) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) EnableDataSources(ctx context.Context, req *request.EnableDataSources) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) ListDataSourceConnections(ctx context.Context, req *request.ListDataSourceConnections) (*response.ListDataSourceConnections, error)
  • func (s *SourceManagerServer) ListDataSources(ctx context.Context, req *request.ListDataSources) (*response.ListDataSources, error)
  • func (s *SourceManagerServer) ListTable(ctx context.Context, req *request.ListTable) (*response.ListTable, error)
  • func (s *SourceManagerServer) PingDataSourceConnection(ctx context.Context, req *request.PingDataSourceConnection) (*response.PingDataSourceConnection, error)
  • func (s *SourceManagerServer) SourceTables(ctx context.Context, req *request.SourceTables) (*response.JsonList, error)
  • func (s *SourceManagerServer) TableColumns(ctx context.Context, req *request.TableColumns) (*response.TableColumns, error)
  • func (s *SourceManagerServer) UpdateDataSource(ctx context.Context, req *request.UpdateDataSource) (*model.EmptyStruct, error)
  • func (s *SourceManagerServer) UpdateTable(ctx context.Context, req *request.UpdateTable) (*model.EmptyStruct, error)

Functions

func Start

func Start() (err error)

Start for start the http server

Types

type SourceManagerServer

type SourceManagerServer struct {
	smpb.UnimplementedSourcemanagerServer
	// contains filtered or unexported fields
}

func NewSourceManagerServer

func NewSourceManagerServer(executor *executor.SourcemanagerExecutor) *SourceManagerServer

func (*SourceManagerServer) CreateDataSource

func (s *SourceManagerServer) CreateDataSource(ctx context.Context, req *request.CreateDataSource) (*response.CreateDataSource, error)

func (*SourceManagerServer) CreateTable

func (s *SourceManagerServer) CreateTable(ctx context.Context, req *request.CreateTable) (*model.EmptyStruct, error)

func (*SourceManagerServer) DataFormat

func (s *SourceManagerServer) DataFormat(ctx context.Context, req *model.EmptyStruct) (*response.JsonList, error)

func (*SourceManagerServer) DataType

func (s *SourceManagerServer) DataType(ctx context.Context, req *model.EmptyStruct) (*response.JsonList, error)

func (*SourceManagerServer) DeleteDataSources

func (s *SourceManagerServer) DeleteDataSources(ctx context.Context, req *request.DeleteDataSources) (*model.EmptyStruct, error)

func (*SourceManagerServer) DeleteDataSourcesBySpaceId

func (s *SourceManagerServer) DeleteDataSourcesBySpaceId(ctx context.Context, req *request.DeleteWorkspaces) (*model.EmptyStruct, error)

func (*SourceManagerServer) DeleteTable

func (s *SourceManagerServer) DeleteTable(ctx context.Context, req *request.DeleteTable) (*model.EmptyStruct, error)

func (*SourceManagerServer) DescribeDataSource

func (s *SourceManagerServer) DescribeDataSource(ctx context.Context, req *request.DescribeDataSource) (*response.DescribeDataSource, error)

func (*SourceManagerServer) DescribeDataSourceKinds

func (s *SourceManagerServer) DescribeDataSourceKinds(ctx context.Context, req *model.EmptyStruct) (*response.DescribeDataSourceKinds, error)

func (*SourceManagerServer) DescribeTable

func (s *SourceManagerServer) DescribeTable(ctx context.Context, req *request.DescribeTable) (*response.DescribeTable, error)

func (*SourceManagerServer) DisableDataSources

func (s *SourceManagerServer) DisableDataSources(ctx context.Context, req *request.DisableDataSources) (*model.EmptyStruct, error)

func (*SourceManagerServer) EnableDataSources

func (s *SourceManagerServer) EnableDataSources(ctx context.Context, req *request.EnableDataSources) (*model.EmptyStruct, error)

func (*SourceManagerServer) ListDataSourceConnections

func (s *SourceManagerServer) ListDataSourceConnections(ctx context.Context, req *request.ListDataSourceConnections) (*response.ListDataSourceConnections, error)

func (*SourceManagerServer) ListDataSources

func (s *SourceManagerServer) ListDataSources(ctx context.Context, req *request.ListDataSources) (*response.ListDataSources, error)

func (*SourceManagerServer) ListTable

func (s *SourceManagerServer) ListTable(ctx context.Context, req *request.ListTable) (*response.ListTable, error)

func (*SourceManagerServer) PingDataSourceConnection

func (s *SourceManagerServer) PingDataSourceConnection(ctx context.Context, req *request.PingDataSourceConnection) (*response.PingDataSourceConnection, error)

func (*SourceManagerServer) SourceTables

func (s *SourceManagerServer) SourceTables(ctx context.Context, req *request.SourceTables) (*response.JsonList, error)

func (*SourceManagerServer) TableColumns

func (s *SourceManagerServer) TableColumns(ctx context.Context, req *request.TableColumns) (*response.TableColumns, error)

func (*SourceManagerServer) UpdateDataSource

func (s *SourceManagerServer) UpdateDataSource(ctx context.Context, req *request.UpdateDataSource) (*model.EmptyStruct, error)

func (*SourceManagerServer) UpdateTable

func (s *SourceManagerServer) UpdateTable(ctx context.Context, req *request.UpdateTable) (*model.EmptyStruct, error)