service

package

v1.0.0 Latest Latest Go to latest Published: Oct 22, 2019 License: GPL-3.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/txix-open/isp-mdb-lib

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type BatchTransformer
- func NewBatchTransformer(service ConverterService) BatchTransformer
- func (t BatchTransformer) ConvertBatch(protocol structure.ProtocolVersion, list []entity.TransitDataRecord, ...) ([]structure.ConvertResponse, error)
- func (t BatchTransformer) FilterDataBatch(list []entity.TransitDataRecord, identity int32, techRecord bool) ([]structure.ConvertResponse, error)
type ConverterService
- func NewConverterService(client *backend.RxGrpcClient, callerId int) ConverterService
type ScriptService
- func NewScriptService(client *backend.RxGrpcClient, callerId int) *ScriptService
- func (s *ScriptService) Execute(req structure.ExecuteRequest, responseResPtr interface{}) (*structure.ScriptResponse, error)
- func (s *ScriptService) ExecuteById(req structure.ExecuteByIdRequest, responseResPtr interface{}) (*structure.ScriptResponse, error)
type SearchService
- func NewSeachService(client *backend.RxGrpcClient, callerId int) SearchService

Constants ¶

View Source

const (
	ScriptServiceExecuteByIdAddr = "script/script/execute_by_id"
	ScriptServiceExecuteAddr     = "script/script/execute"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BatchTransformer ¶

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

func NewBatchTransformer ¶

func NewBatchTransformer(service ConverterService) BatchTransformer

func (BatchTransformer) ConvertBatch ¶

func (t BatchTransformer) ConvertBatch(protocol structure.ProtocolVersion, list []entity.TransitDataRecord, identity int32, techRecord bool) ([]structure.ConvertResponse, error)

func (BatchTransformer) FilterDataBatch ¶

func (t BatchTransformer) FilterDataBatch(list []entity.TransitDataRecord, identity int32, techRecord bool) ([]structure.ConvertResponse, error)

type ConverterService ¶

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

func NewConverterService ¶

func NewConverterService(client *backend.RxGrpcClient, callerId int) ConverterService

func (*ConverterService) ConvertAnySearchRequest ¶

func (s *ConverterService) ConvertAnySearchRequest(req structure.ConvertAnySearchRequest) (*structure.ConvertAnySearchResponse, error)

func (*ConverterService) ConvertToErl ¶

func (s *ConverterService) ConvertToErl(req []structure.BatchConvertErlRequest) (structure.BatchListConvertErlResponse, error)

func (*ConverterService) ConvertToJson ¶

func (s *ConverterService) ConvertToJson(req []structure.BatchConvertAnyRequest) (structure.BatchListConvertAnyResponse, error)

func (*ConverterService) ConvertToSudir ¶

func (s *ConverterService) ConvertToSudir(req []structure.BatchConvertDataRequest) (structure.BatchListConvertForSudirResponse, error)

func (*ConverterService) ConvertToSudirFindEntry ¶

func (s *ConverterService) ConvertToSudirFindEntry(req []structure.BatchConvertForFindServiceRequest) (
	structure.BatchListConvertForFindResponse, error,
)

func (*ConverterService) FilterData ¶

func (s *ConverterService) FilterData(req []structure.BatchFilterDataRequest) (structure.BatchListFilterDataResponse, error)

func (*ConverterService) FilterSearchRequest ¶

func (s *ConverterService) FilterSearchRequest(req structure.FilterSearchRequest) (*structure.ConvertAnySearchResponse, error)

type ScriptService ¶

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

func NewScriptService ¶

func NewScriptService(client *backend.RxGrpcClient, callerId int) *ScriptService

func (*ScriptService) Execute ¶

func (s *ScriptService) Execute(req structure.ExecuteRequest, responseResPtr interface{}) (*structure.ScriptResponse, error)

func (*ScriptService) ExecuteById ¶

func (s *ScriptService) ExecuteById(req structure.ExecuteByIdRequest, responseResPtr interface{}) (*structure.ScriptResponse, error)

type SearchService ¶

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

func NewSeachService ¶

func NewSeachService(client *backend.RxGrpcClient, callerId int) SearchService

func (*SearchService) GetPreferredSlicesCount ¶

func (s *SearchService) GetPreferredSlicesCount(isTech bool) (*structure.PreferredSearchSlicesResponse, error)

func (*SearchService) ParallelSearchWithScrolls ¶

func (s *SearchService) ParallelSearchWithScrolls(
	q query.Term, batchSize int, scrollTTL time.Duration, isTech bool,
	concurrentScrollsCount int, callback func(list []string) bool,
) error

func (*SearchService) Search ¶

func (s *SearchService) Search(req structure.SearchRequest) (*structure.SearchResponse, error)

func (*SearchService) SearchCount ¶

func (s *SearchService) SearchCount(req structure.CountRequest) (*structure.CountResponse, error)

func (*SearchService) SearchIdList ¶

func (s *SearchService) SearchIdList(req structure.SearchRequest) (*structure.SearchResponse, error)

func (*SearchService) SearchIdWithScroll ¶

func (s *SearchService) SearchIdWithScroll(req structure.SearchWithScrollRequest) (*structure.SearchIdWithScrollResponse, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL