external

Documentation

Index

• type DataProxyClient
  • func NewDataProxyClient(conf *config.DataProxyConfig) (*DataProxyClient, error)
  • func (dp *DataProxyClient) GetFlightInfoDataMeshQuery(ctx context.Context, query *datamesh.CommandDataMeshQuery) (*flight.FlightInfo, error)
  • func (dp *DataProxyClient) GetFlightInfoDataMeshUpdate(ctx context.Context, query *datamesh.CommandDataMeshUpdate) (*flight.FlightInfo, error)
• type DataProxyConfig
• type IDataProxyClient
• type IOServer
  • func NewIOServer(conf *config.DataProxyConfig) *IOServer
  • func (d *IOServer) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) (err error)
  • func (d *IOServer) DoPut(stream flight.FlightService_DoPutServer) (err error)
  • func (d *IOServer) GetFlightInfo(ctx context.Context, reqCtx *utils.DataMeshRequestContext) (flightInfo *flight.FlightInfo, err error)

Types

type DataProxyClient

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

func NewDataProxyClient

func NewDataProxyClient(conf *config.DataProxyConfig) (*DataProxyClient, error)

func (*DataProxyClient) GetFlightInfoDataMeshQuery

func (dp *DataProxyClient) GetFlightInfoDataMeshQuery(ctx context.Context,
	query *datamesh.CommandDataMeshQuery) (*flight.FlightInfo, error)

func (*DataProxyClient) GetFlightInfoDataMeshUpdate

func (dp *DataProxyClient) GetFlightInfoDataMeshUpdate(ctx context.Context,
	query *datamesh.CommandDataMeshUpdate) (*flight.FlightInfo, error)

type DataProxyConfig

type DataProxyConfig struct {
	Addr            string
	ClientTLSConfig *kusciaconfig.TLSConfig
}

type IDataProxyClient

type IDataProxyClient interface {
	GetFlightInfoDataMeshQuery(context.Context, *datamesh.CommandDataMeshQuery) (*flight.FlightInfo, error)
	GetFlightInfoDataMeshUpdate(context.Context, *datamesh.CommandDataMeshUpdate) (*flight.FlightInfo, error)
}

type IOServer

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

func NewIOServer

func NewIOServer(conf *config.DataProxyConfig) *IOServer

func (*IOServer) DoGet

func (d *IOServer) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) (err error)

func (*IOServer) DoPut

func (d *IOServer) DoPut(stream flight.FlightService_DoPutServer) (err error)

func (*IOServer) GetFlightInfo

func (d *IOServer) GetFlightInfo(ctx context.Context, reqCtx *utils.DataMeshRequestContext) (flightInfo *flight.FlightInfo, err error)