datatest

Documentation

Index

• func NewDocStoreService(ctx context.Context, svc service.Service) (grpc.ClientConnInterface, error)
• func NewIndexService(ctx context.Context, svc service.Service) (grpc.ClientConnInterface, error)
• func NewMetaService(ctx context.Context, svc service.Service, nodes ...*tree.Node) (grpc.ClientConnInterface, error)
• func NewTreeService(ctx context.Context, svc service.Service, dss []string, nodes ...*tree.Node) (grpc.ClientConnInterface, error)
• func RegisterDataServices(ctx context.Context, nodes ...*tree.Node) error
• type DataSourceService
  • func NewDataSourceService(ctx context.Context, dsName string) *DataSourceService
  • func (u *DataSourceService) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
  • func (u *DataSourceService) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

Functions

func NewDocStoreService

func NewDocStoreService(ctx context.Context, svc service.Service) (grpc.ClientConnInterface, error)

func NewIndexService

func NewIndexService(ctx context.Context, svc service.Service) (grpc.ClientConnInterface, error)

func NewMetaService

func NewMetaService(ctx context.Context, svc service.Service, nodes ...*tree.Node) (grpc.ClientConnInterface, error)

func NewTreeService

func NewTreeService(ctx context.Context, svc service.Service, dss []string, nodes ...*tree.Node) (grpc.ClientConnInterface, error)

func RegisterDataServices

func RegisterDataServices(ctx context.Context, nodes ...*tree.Node) error

Types

type DataSourceService

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

func NewDataSourceService

func NewDataSourceService(ctx context.Context, dsName string) *DataSourceService

func (*DataSourceService) Invoke

func (u *DataSourceService) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error

func (*DataSourceService) NewStream

func (u *DataSourceService) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)