structure

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Dec 20, 2019 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ErrorTypeCompile = "Compilation"
	ErrorTypeRunTime = "Runtime"
)

Variables

This section is empty.

Functions

func GetPkFilterValue

func GetPkFilterValue(cond *query.Term) string

Types

type AbstractConvertBatchRequest

type AbstractConvertBatchRequest struct {
	ExternalId string
	Id         uint64
	Version    int64
	Protocol   ProtocolVersion
	IsTech     bool
	AppIdList  []NotificationTarget `valid:"required~Required"`
}

type AbstractConvertResult

type AbstractConvertResult struct {
	Target     NotificationTarget
	Error      *ConvertError
	ExternalId string
	Id         uint64
	Version    int64
	Protocol   ProtocolVersion
	IsTech     bool
}

type Amqp

type Amqp struct {
	ExchangeName string `valid:"required~Required" schema:"Название точки маршрутизации"`
	ExchangeKind string `schema:"Тип точки маршрутизации,'direct', 'topic', 'fanout' (по умолчанию - 'direct')"`
	QueueName    string `schema:"Название очереди"`
	RoutingKey   string `` /* 189-byte string literal not displayed */
	// автоматическое объявление очереди,точки маршрутизации,привязк
	Declare bool `` /* 128-byte string literal not displayed */
}

type AnyConvertResult

type AnyConvertResult struct {
	Result map[string]interface{}
	AbstractConvertResult
}

func (AnyConvertResult) GetMetadata

func (r AnyConvertResult) GetMetadata() AbstractConvertResult

func (AnyConvertResult) GetResult

func (r AnyConvertResult) GetResult() interface{}

type AsyncSearchRequest

type AsyncSearchRequest struct {
	// размер пакета с результатами поиска
	PackageSize int
	// поиск по техническим записям
	TechEntries bool
	// если поле не заданно используется внутренее хранилище результатов поиска
	// Поддерживается rabbit (начинается с amqp://) и http (c http:// или https://)
	// amqp://user:pass@host:10000/vhost
	Callback string
	Protocol ProtocolVersion
	// обязательный параметр, если указан callback RabbitMQ
	Amqp *Amqp
}

type Attribute

type Attribute struct {
	Name  *string
	Value []*string
}

type BatchConvertAnyRequest

type BatchConvertAnyRequest struct {
	Record *Record `valid:"required~Required"`
	*AbstractConvertBatchRequest
}

type BatchConvertAnyResponse

type BatchConvertAnyResponse map[int32]*AnyConvertResult

type BatchConvertDataRequest

type BatchConvertDataRequest struct {
	*ConvertRequestPayload `valid:"required~Required"`
	*AbstractConvertBatchRequest
}

type BatchConvertErlRequest

type BatchConvertErlRequest struct {
	Record *Record `valid:"required~Required"`
	*AbstractConvertBatchRequest
}

type BatchConvertErlResponse

type BatchConvertErlResponse map[int32]*ErlConvertResult

type BatchConvertForFindResponse

type BatchConvertForFindResponse map[int32]*FindConvertResult

type BatchConvertForFindServiceRequest

type BatchConvertForFindServiceRequest struct {
	*ConvertForFindServiceRequestPayload `valid:"required~Required"`
	*AbstractConvertBatchRequest
}

type BatchConvertForSudirResponse

type BatchConvertForSudirResponse map[int32]*SudirConvertResult

type BatchConvertResponse

type BatchConvertResponse interface {
	GetResult() []ConvertResponse
}

type BatchFilterDataRequest

type BatchFilterDataRequest struct {
	Record *Record `valid:"required~Required"`
	*AbstractConvertBatchRequest
}

type BatchFilterDataResponse

type BatchFilterDataResponse map[int32]*FilterDataResult

type BatchListConvertAnyResponse

type BatchListConvertAnyResponse map[int32][]AnyConvertResult

func (BatchListConvertAnyResponse) GetResult

type BatchListConvertErlResponse

type BatchListConvertErlResponse map[int32][]ErlConvertResult

func (BatchListConvertErlResponse) GetResult

type BatchListConvertForFindResponse

type BatchListConvertForFindResponse map[int32][]FindConvertResult

func (BatchListConvertForFindResponse) GetResult

type BatchListConvertForSudirResponse

type BatchListConvertForSudirResponse map[int32][]SudirConvertResult

func (BatchListConvertForSudirResponse) GetResult

type BatchListFilterDataResponse

type BatchListFilterDataResponse map[int32][]FilterDataResult

func (BatchListFilterDataResponse) GetResult

type BinaryCondition

type BinaryCondition struct {
	Field    string         `valid:"required~Required"` //путь до атрибута
	Operator query.Operator ``                          //условный оператор
	/* 136-byte string literal not displayed */
	Value interface{} //(строка, число, булево значение) значение атрибута,обязательно для всех операторов, кроме (exists, not exists)
}

type ConvertAnyRequest

type ConvertAnyRequest struct {
	Record        *Record         `valid:"required~Required"`
	ApplicationId int32           `valid:"required~Required"`
	Protocol      ProtocolVersion `valid:"required~Required"`
}

type ConvertAnySearchRequest

type ConvertAnySearchRequest struct {
	Condition     *OneOfCondition `valid:"required~Required"`
	ApplicationId int32           `valid:"required~Required"`
	Protocol      ProtocolVersion
}

type ConvertAnySearchResponse

type ConvertAnySearchResponse struct {
	Condition         *query.Term
	UnavailableFields []string
}

type ConvertDataRequest

type ConvertDataRequest struct {
	*ConvertRequestPayload `valid:"required~Required"`
	ApplicationId          int32 `valid:"required~Required"`
	Protocol               ProtocolVersion
}

type ConvertErlRequest

type ConvertErlRequest struct {
	Record        *Record `valid:"required~Required"`
	ApplicationId int32   `valid:"required~Required"`
}

type ConvertError

type ConvertError struct {
	Code  codes.Code
	Error string
}

func (*ConvertError) ToGrpcError

func (e *ConvertError) ToGrpcError() error

type ConvertForFindServiceRequest

type ConvertForFindServiceRequest struct {
	*ConvertForFindServiceRequestPayload `valid:"required~Required"`
	ApplicationId                        int32           `valid:"required~Required"`
	Protocol                             ProtocolVersion `valid:"required~Required"`
}

type ConvertForFindServiceRequestPayload

type ConvertForFindServiceRequestPayload struct {
	Records             []*Record
	AttachedObjectTypes []string
	AttachedRefType     []string
	ObjectType          string
}

type ConvertRequestPayload

type ConvertRequestPayload struct {
	Data                  interface{} `valid:"required~Required"`
	CustomData            interface{}
	AttachedObjectTypes   []string
	FilterByAttachedTypes bool
}

func (ConvertRequestPayload) CastToMaps

func (p ConvertRequestPayload) CastToMaps() (map[string]interface{}, map[string]interface{})

type ConvertResponse

type ConvertResponse interface {
	GetMetadata() AbstractConvertResult
	GetResult() interface{}
}

type ConvertSearchError

type ConvertSearchError struct {
	Field  string
	Reason Reason
}

func (ConvertSearchError) Error

func (e ConvertSearchError) Error() string

type ConvertSearchForFindServiceRequest

type ConvertSearchForFindServiceRequest struct {
	ApplicationId int32           `valid:"required~Required"`
	Protocol      ProtocolVersion `valid:"required~Required"`
	Source        *findV2.Filter
}

type ConvertSearchRequest

type ConvertSearchRequest struct {
	ApplicationId int32           `valid:"required~Required"`
	Protocol      ProtocolVersion `valid:"required~Required"`
	Source        *EntryType
}

type ConvertSearchResponse

type ConvertSearchResponse struct {
	Condition *query.Term
	Error     *ConvertSearchError
}

type CountRequest

type CountRequest struct {
	IsTech    bool
	Condition query.Term
}

type CountResponse

type CountResponse struct {
	TotalCount int64
}

type DataRecordByExternalId

type DataRecordByExternalId struct {
	ExternalId string `json:"externalId" valid:"required~Required"`
	TechRecord bool
}

type DataRecordsByExternalIdList

type DataRecordsByExternalIdList struct {
	ExternalIdList []string `valid:"required~Required"`
	TechRecord     bool
}

type EntryType

type EntryType struct {
	EntryName *string
	Seq       *int64
	Attribute []*Attribute
	Object    []*Object
}

type ErlConvertResult

type ErlConvertResult struct {
	Result *erl.PersonsIncoming
	AbstractConvertResult
}

func (ErlConvertResult) GetMetadata

func (r ErlConvertResult) GetMetadata() AbstractConvertResult

func (ErlConvertResult) GetResult

func (r ErlConvertResult) GetResult() interface{}

type ExecuteByIdRequest

type ExecuteByIdRequest struct {
	Id  string `valid:"required~Required"`
	Arg interface{}
}

type ExecuteRequest

type ExecuteRequest struct {
	Script string `valid:"required~Required"`
	Arg    interface{}
}

type ExternalAsyncSearchRequest

type ExternalAsyncSearchRequest struct {
	//название атрибута -> значение, все элементы объекта объединяются логическим 'И'
	Query map[string]interface{} `valid:"required~Required"`
	AsyncSearchRequest
}

type ExternalExtendedAsyncSearchRequest

type ExternalExtendedAsyncSearchRequest struct {
	Query *OneOfCondition `valid:"required~Required"`
	AsyncSearchRequest
}

type FilterAttributeRequest

type FilterAttributeRequest struct {
	Attributes    []entity.Attribute `valid:"required~Required"`
	ApplicationId int32              `valid:"required~Required"`
}

type FilterDataRequest

type FilterDataRequest struct {
	Record        *Record `valid:"required~Required"`
	ApplicationId int32   `valid:"required~Required"`
}

type FilterDataResult

type FilterDataResult struct {
	Result *Record
	AbstractConvertResult
}

func (FilterDataResult) GetMetadata

func (r FilterDataResult) GetMetadata() AbstractConvertResult

func (FilterDataResult) GetResult

func (r FilterDataResult) GetResult() interface{}

type FilterSearchRequest

type FilterSearchRequest struct {
	Query         map[string]interface{}
	ApplicationId int32 `valid:"required~Required"`
}

type FindConvertResult

type FindConvertResult struct {
	Result []*MdmObject
	AbstractConvertResult
}

func (FindConvertResult) GetMetadata

func (r FindConvertResult) GetMetadata() AbstractConvertResult

func (FindConvertResult) GetResult

func (r FindConvertResult) GetResult() interface{}

type GetAsyncResultRequest

type GetAsyncResultRequest struct {
	RequestId string `valid:"required~Required"`
	Limit     int
	Offset    int
}

type GetJobStatusRequest

type GetJobStatusRequest struct {
	RequestId string `valid:"required~Required"`
}

type GetJobStatusResponse

type GetJobStatusResponse struct {
	RequestId       string
	Status          string `json:",omitempty"`
	CreatedAt       time.Time
	FinishedAt      time.Time `json:",omitempty"`
	ExecutedTime    string    `json:",omitempty"`
	TtlUntil        time.Time `json:",omitempty"`
	Description     string
	PackagesCount   int
	ExecutedEntries int64
}

type Identities

type Identities struct {
	Ids []int64 `json:"ids" valid:"required~Required"`
}

type InternalAsyncSearchRequest

type InternalAsyncSearchRequest struct {
	Query         query.Term
	ApplicationId int32 `valid:"required~Required"`
	JobCountLimit int
	RequestId     string `valid:"required~Required"`
	AsyncSearchRequest
}

type LogicCondition

type LogicCondition struct {
	Operator   query.LogicOperator `valid:"required~Required,in(AND|OR)"` //логический оператор
	Conditions []OneOfCondition    `valid:"required~Required"`            //список условий для объединения
}

type MdmHandleRequest

type MdmHandleRequest struct {
	TechRecord  bool
	OperationId string
	Record      *entity.DataRecord `valid:"required~Required"`
}

type MdmObject

type MdmObject struct {
	ObjectType   string
	RelationType *string
	Attribute    []*Attribute
	Relations    *Relations
}

type NotificationTarget added in v1.1.0

type NotificationTarget struct {
	AppId    int32
	Notifier string
}

type Object

type Object struct {
	Name      *string
	Attribute []*Attribute
}

type OneOfCondition

type OneOfCondition struct {
	Logic  *LogicCondition  //логическая условие
	Binary *BinaryCondition //бинарное условия
}

type PreferredSearchSlicesRequest

type PreferredSearchSlicesRequest struct {
	IsTech bool
}

type PreferredSearchSlicesResponse

type PreferredSearchSlicesResponse struct {
	MaxSlices int
}

type ProtocolVersion

type ProtocolVersion string
const (
	SudirV1      ProtocolVersion = "sudir_v1"
	SudirV1Find  ProtocolVersion = "sudir_v1_find"
	SudirV2      ProtocolVersion = "sudir_v2"
	SudirV2Find  ProtocolVersion = "sudir_v2_find"
	JsonProtocol ProtocolVersion = "json"
	ErlProtocol  ProtocolVersion = "erl"
	SmaProtocol  ProtocolVersion = "sma"
)

type Reason

type Reason int
const (
	ReasonUnsupported Reason = iota
	ReasonWrongValue
	ReasonNotAccepted
	ReasonEmptyCond
	ReasonNoValue
)

type Record

type Record struct {
	Data       interface{} `valid:"required~Required"`
	CustomData interface{}
}

func (Record) CastToMaps

func (r Record) CastToMaps() (map[string]interface{}, map[string]interface{})

type Reference

type Reference struct {
	ObjectType   string
	RelationType *string
	ObjectId     *string
}

type Relations

type Relations struct {
	Object []*MdmObject
	Ref    []*Reference
}

type ScriptResponse

type ScriptResponse struct {
	Result interface{}
	Error  *ScriptResponseError
}

type ScriptResponseError

type ScriptResponseError struct {
	Type        string
	Description string
}

func (ScriptResponseError) Error

func (err ScriptResponseError) Error() string

type SearchIdResponse

type SearchIdResponse struct {
	Items      []string
	TotalCount int64
}

type SearchIdWithScrollResponse

type SearchIdWithScrollResponse struct {
	SearchIdResponse
	ScrollId string
}

type SearchRequest

type SearchRequest struct {
	Limit     int
	Offset    int
	IsTech    bool
	Condition query.Term
}

type SearchResponse

type SearchResponse struct {
	Items      []entity.TransitDataRecord
	TotalCount int64
}

type SearchWithScrollRequest

type SearchWithScrollRequest struct {
	IsTech    bool
	Condition query.Term
	BatchSize int `valid:"required~Required"`
	ScrollId  string
	ScrollTTL time.Duration `valid:"required~Required"`
	Slicing   *struct {
		SliceId   int
		MaxSlices int
	}
}

type SudirConvertResult

type SudirConvertResult struct {
	Result *EntryType
	AbstractConvertResult
}

func (SudirConvertResult) GetMetadata

func (r SudirConvertResult) GetMetadata() AbstractConvertResult

func (SudirConvertResult) GetResult

func (r SudirConvertResult) GetResult() interface{}

type UpsertResponse

type UpsertResponse struct {
	OldValue *entity.DataRecord
	NewValue *entity.DataRecord
	Inserted bool
	Updated  bool
}

Jump to

Keyboard shortcuts

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