service

package
v1.15.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 17, 2022 License: GPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ScriptServiceExecuteByIdAddr  = "script/script/execute_by_id"
	ScriptServiceExecuteAddr      = "script/script/execute"
	ScriptServiceBatchExecute     = "script/script/batch_execute"
	ScriptServiceBatchExecuteById = "script/script/batch_execute_by_ids"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ApiService added in v1.3.0 

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

func NewApiService added in v1.3.0 

func NewApiService(client http.RestClient, address string, applicationToken string) *ApiService

func (*ApiService) SyncFind added in v1.3.0 

func (s *ApiService) SyncFind(request structure.SyncSearchApiRequest, response *structure.ApiResponse) error

func (*ApiService) SyncFindExtended added in v1.3.0 

func (s *ApiService) SyncFindExtended(request structure.SyncSearchExtendedApiRequest, response *structure.ApiResponse) error

func (*ApiService) SyncFindIdList added in v1.3.0 

func (s *ApiService) SyncFindIdList(request structure.SyncSearchApiRequest, response *structure.ApiResponse) error

func (*ApiService) SyncFindIdListExtended added in v1.3.0 

func (s *ApiService) SyncFindIdListExtended(request structure.SyncSearchExtendedApiRequest, response *structure.ApiResponse) error

func (*ApiService) SyncGetByIdList added in v1.3.0 

func (s *ApiService) SyncGetByIdList(request structure.IdListApiRequest, response *structure.ApiResponse) error

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) ConvertToPdpSudir added in v1.13.2 

func (s *ConverterService) ConvertToPdpSudir(req []pdpstructure.BatchConvertPdpRequest) (structure.BatchListConvertForSudirResponse, 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) BatchExecute added in v1.6.0 

func (s *ScriptService) BatchExecute(req []structure.ExecuteByIdRequest, responsePtr interface{}) error

func (*ScriptService) BatchExecuteById added in v1.6.0 

func (s *ScriptService) BatchExecuteById(req structure.BatchExecuteByIdsRequest, responsePtr interface{}) error

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.SearchIdResponse, error)

func (*SearchService) SearchIdWithScroll 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.