X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftypes.go;h=0123357b858f3cb91add939b1df168df55a609c7;hb=53dbe7eafa69dcea736ba19c66581a80f374b51a;hp=3a9587f2ab2728037f1bc26f89fd34b72114bbd2;hpb=1455c85dea3fba44cdcba8a92864be730691a6ec;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/types.go b/pkg/control/types.go index 3a9587f..0123357 100644 --- a/pkg/control/types.go +++ b/pkg/control/types.go @@ -20,31 +20,54 @@ package control import ( - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" + "time" + + "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap" ) -type RmrDatagram struct { - MessageType int - SubscriptionId uint16 - Payload []byte +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- +type RequestId struct { + e2ap.RequestId +} + +func (rid *RequestId) String() string { + return "reqid(" + rid.RequestId.String() + ")" } -type SubRouteInfo struct { - Command Action - Address string - Port uint16 - SubID uint16 +type Sdlnterface interface { + Set(pairs ...interface{}) error + Get(keys []string) (map[string]interface{}, error) + GetAll() ([]string, error) + Remove(keys []string) error + RemoveAll() error } -type Action int +type E2SubscriptionDirectives struct { + // How many times E2 subscription request is retried + // Required: true + // Maximum: 10 + // Minimum: 0 + E2MaxTryCount int64 + + // How long time response is waited from E2 node + // Maximum: 10s + // Minimum: 1s + E2TimeoutTimerValue time.Duration + + // Subscription needs RMR route from E2Term to xApp + CreateRMRRoute bool +} -type TransactionKey struct { - SubID uint16 - transType Action +type ErrorInfo struct { + ErrorCause string + ErrorSource string + TimeoutType string } -type Transaction struct { - XappInstanceAddress string - XappPort uint16 - OrigParams *xapp.RMRParams +func (e *ErrorInfo) SetInfo(errorCause string, errorSource string, timeoutType string) { + e.ErrorCause = errorCause + e.ErrorSource = errorSource + e.TimeoutType = timeoutType }