service

Documentation

Index

• type CustomAction
  • func NewCustomActionService(domainDataService service.IDomainDataService, ...) CustomAction
• type FlightIO
  • func NewFlightIO(dd service.IDomainDataService, ds service.IDomainDataSourceService, ...) *FlightIO
  • func (dp *FlightIO) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) (err error)
  • func (dp *FlightIO) DoPut(stream flight.FlightService_DoPutServer) (err error)
  • func (dp *FlightIO) GetFlightInfo(ctx context.Context, msg proto.Message) (flightInfo *flight.FlightInfo, err error)

Types

type CustomAction

type CustomAction interface {
	DoActionCreateDomainDataRequest(ctx context.Context, body []byte) (*flight.Result, error)
	DoActionQueryDomainDataRequest(ctx context.Context, body []byte) (*flight.Result, error)
	DoActionUpdateDomainDataRequest(ctx context.Context, body []byte) (*flight.Result, error)
	DoActionDeleteDomainDataRequest(ctx context.Context, body []byte) (*flight.Result, error)
	DoActionQueryDomainDataSourceRequest(ctx context.Context, body []byte) (*flight.Result, error)
}

func NewCustomActionService

func NewCustomActionService(domainDataService service.IDomainDataService, dataSourceService service.IDomainDataSourceService) CustomAction

type FlightIO

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

func NewFlightIO

func NewFlightIO(dd service.IDomainDataService, ds service.IDomainDataSourceService, configs []config.DataProxyConfig) *FlightIO

func (*FlightIO) DoGet

func (dp *FlightIO) DoGet(tkt *flight.Ticket, fs flight.FlightService_DoGetServer) (err error)

func (*FlightIO) DoPut

func (dp *FlightIO) DoPut(stream flight.FlightService_DoPutServer) (err error)

func (*FlightIO) GetFlightInfo

func (dp *FlightIO) GetFlightInfo(ctx context.Context, msg proto.Message) (flightInfo *flight.FlightInfo, err error)