datamandirect

Documentation

Index

• type DatasourceInstanceTransport
  • func NewDatasourceInstanceTransport(dsi *storagenode.DatasourceInstance) *DatasourceInstanceTransport
  • func (d *DatasourceInstanceTransport) DoQuery(ctx context.Context, q *query.Query) (*query.Result, error)
  • func (d *DatasourceInstanceTransport) DoStreamQuery(ctx context.Context, q *query.Query) (*query.ResultStream, error)
• type RouterTransport
  • func NewRouterTransport(node *routernode.RouterNode) *RouterTransport
  • func (r *RouterTransport) DoQuery(ctx context.Context, q *query.Query) (*query.Result, error)
  • func (r *RouterTransport) DoStreamQuery(ctx context.Context, q *query.Query) (*query.ResultStream, error)

Types

type DatasourceInstanceTransport

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

func NewDatasourceInstanceTransport

func NewDatasourceInstanceTransport(dsi *storagenode.DatasourceInstance) *DatasourceInstanceTransport

func (*DatasourceInstanceTransport) DoQuery

func (d *DatasourceInstanceTransport) DoQuery(ctx context.Context, q *query.Query) (*query.Result, error)

func (*DatasourceInstanceTransport) DoStreamQuery

func (d *DatasourceInstanceTransport) DoStreamQuery(ctx context.Context, q *query.Query) (*query.ResultStream, error)

type RouterTransport

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

func NewRouterTransport

func NewRouterTransport(node *routernode.RouterNode) *RouterTransport

func (*RouterTransport) DoQuery

func (r *RouterTransport) DoQuery(ctx context.Context, q *query.Query) (*query.Result, error)

func (*RouterTransport) DoStreamQuery

func (r *RouterTransport) DoStreamQuery(ctx context.Context, q *query.Query) (*query.ResultStream, error)