flight

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

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

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

type DomainDataMetaServer struct {
	datamesh.UnimplementedDomainDataServiceServer
	datamesh.UnimplementedDomainDataSourceServiceServer
	// contains filtered or unexported fields
}

type MetaServer interface {
	GetSchema(context.Context, *datamesh.CommandGetDomainDataSchema) (*flight.SchemaResult, error)
	GetFlightInfoDomainDataQuery(context.Context, *datamesh.CommandDomainDataQuery) (*flight.FlightInfo, error)
	GetFlightInfoDomainDataUpdate(context.Context, *datamesh.CommandDomainDataUpdate) (*flight.FlightInfo, error)
	DoActionCreateDomainDataRequest(ctx context.Context, request *datamesh.ActionCreateDomainDataRequest) (*flight.Result, error)
	DoActionQueryDomainDataRequest(ctx context.Context, request *datamesh.ActionQueryDomainDataRequest) (*flight.Result, error)
	DoActionUpdateDomainDataRequest(ctx context.Context, request *datamesh.ActionUpdateDomainDataRequest) (*flight.Result, error)
	DoActionDeleteDomainDataRequest(ctx context.Context, request *datamesh.ActionDeleteDomainDataRequest) (*flight.Result, error)
	DoActionQueryDomainDataSourceRequest(ctx context.Context, request *datamesh.ActionQueryDomainDataSourceRequest) (
		*flight.Result, error)
}