uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Fixed some typos

Browse Source
This commit is contained in:
Trial97
2020-11-02 17:20:31 +02:00
committed by Dan Christian Bogos
parent bbd303e2c0
commit 5927e96437
6 changed files with 62 additions and 62 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
apier/v1/concreqs_it_test.go
View File

@@ -96,7 +96,7 @@ func testConcReqsStartEngine(t *testing.T) {
}
func handlePing(clnt *rpc2.Client, arg *utils.DurationArgs, reply *string) error {
time.Sleep(arg.DurationTime)
time.Sleep(arg.Duration)
*reply = utils.OK
return nil
}
@@ -126,7 +126,7 @@ func testConcReqsBusyAPIs(t *testing.T) {
go func() {
var resp string
if err := concReqsRPC.Call(utils.CoreSv1Sleep,
&utils.DurationArgs{DurationTime: 10 * time.Millisecond},
&utils.DurationArgs{Duration: 10 * time.Millisecond},
&resp); err != nil {
lock.Lock()
failedAPIs++
@@ -153,7 +153,7 @@ func testConcReqsQueueAPIs(t *testing.T) {
go func() {
var resp string
if err := concReqsRPC.Call(utils.CoreSv1Sleep,
&utils.DurationArgs{DurationTime: 10 * time.Millisecond},
&utils.DurationArgs{Duration: 10 * time.Millisecond},
&resp); err != nil {
wg.Done()
t.Error(err)
@@ -236,7 +236,7 @@ func testConcReqsOnBiJSONBusy(t *testing.T) {
go func() {
var resp string
if err := concReqsBiRPC.Call(utils.SessionSv1Sleep,
&utils.DurationArgs{DurationTime: 10 * time.Millisecond},
&utils.DurationArgs{Duration: 10 * time.Millisecond},
&resp); err != nil {
lock.Lock()
failedAPIs++
@@ -263,7 +263,7 @@ func testConcReqsOnBiJSONQueue(t *testing.T) {
go func() {
var resp string
if err := concReqsBiRPC.Call(utils.SessionSv1Sleep,
&utils.DurationArgs{DurationTime: 10 * time.Millisecond},
&utils.DurationArgs{Duration: 10 * time.Millisecond},
&resp); err != nil {
wg.Done()
t.Error(err)

2
apier/v1/core.go
View File

@@ -52,7 +52,7 @@ func (cS *CoreSv1) Ping(ign *utils.CGREventWithOpts, reply *string) error {
// Sleep is used to test the concurrent requests mechanism
func (cS *CoreSv1) Sleep(arg *utils.DurationArgs, reply *string) error {
time.Sleep(arg.DurationTime)
time.Sleep(arg.Duration)
*reply = utils.OK
return nil
}

52
apier/v1/sessions.go
View File

@@ -26,94 +26,94 @@ import (
func NewSessionSv1(sS *sessions.SessionS, concReqs *utils.ConcReqs) *SessionSv1 {
return &SessionSv1{
Ss: sS,
sS: sS,
concReqs: concReqs,
}
}
// SessionSv1 exports RPC from SessionSv1
type SessionSv1 struct {
Ss *sessions.SessionS
sS *sessions.SessionS
concReqs *utils.ConcReqs
}
func (ssv1 *SessionSv1) AuthorizeEvent(args *sessions.V1AuthorizeArgs,
rply *sessions.V1AuthorizeReply) error {
return ssv1.Ss.BiRPCv1AuthorizeEvent(nil, args, rply)
return ssv1.sS.BiRPCv1AuthorizeEvent(nil, args, rply)
}
func (ssv1 *SessionSv1) AuthorizeEventWithDigest(args *sessions.V1AuthorizeArgs,
rply *sessions.V1AuthorizeReplyWithDigest) error {
return ssv1.Ss.BiRPCv1AuthorizeEventWithDigest(nil, args, rply)
return ssv1.sS.BiRPCv1AuthorizeEventWithDigest(nil, args, rply)
}
func (ssv1 *SessionSv1) InitiateSession(args *sessions.V1InitSessionArgs,
rply *sessions.V1InitSessionReply) error {
return ssv1.Ss.BiRPCv1InitiateSession(nil, args, rply)
return ssv1.sS.BiRPCv1InitiateSession(nil, args, rply)
}
func (ssv1 *SessionSv1) InitiateSessionWithDigest(args *sessions.V1InitSessionArgs,
rply *sessions.V1InitReplyWithDigest) error {
return ssv1.Ss.BiRPCv1InitiateSessionWithDigest(nil, args, rply)
return ssv1.sS.BiRPCv1InitiateSessionWithDigest(nil, args, rply)
}
func (ssv1 *SessionSv1) UpdateSession(args *sessions.V1UpdateSessionArgs,
rply *sessions.V1UpdateSessionReply) error {
return ssv1.Ss.BiRPCv1UpdateSession(nil, args, rply)
return ssv1.sS.BiRPCv1UpdateSession(nil, args, rply)
}
func (ssv1 *SessionSv1) SyncSessions(args *utils.TenantWithOpts,
rply *string) error {
return ssv1.Ss.BiRPCv1SyncSessions(nil, &utils.TenantWithOpts{}, rply)
return ssv1.sS.BiRPCv1SyncSessions(nil, &utils.TenantWithOpts{}, rply)
}
func (ssv1 *SessionSv1) TerminateSession(args *sessions.V1TerminateSessionArgs,
rply *string) error {
return ssv1.Ss.BiRPCv1TerminateSession(nil, args, rply)
return ssv1.sS.BiRPCv1TerminateSession(nil, args, rply)
}
func (ssv1 *SessionSv1) ProcessCDR(cgrEv *utils.CGREventWithOpts, rply *string) error {
return ssv1.Ss.BiRPCv1ProcessCDR(nil, cgrEv, rply)
return ssv1.sS.BiRPCv1ProcessCDR(nil, cgrEv, rply)
}
func (ssv1 *SessionSv1) ProcessMessage(args *sessions.V1ProcessMessageArgs,
rply *sessions.V1ProcessMessageReply) error {
return ssv1.Ss.BiRPCv1ProcessMessage(nil, args, rply)
return ssv1.sS.BiRPCv1ProcessMessage(nil, args, rply)
}
func (ssv1 *SessionSv1) ProcessEvent(args *sessions.V1ProcessEventArgs,
rply *sessions.V1ProcessEventReply) error {
return ssv1.Ss.BiRPCv1ProcessEvent(nil, args, rply)
return ssv1.sS.BiRPCv1ProcessEvent(nil, args, rply)
}
func (ssv1 *SessionSv1) GetCost(args *sessions.V1ProcessEventArgs,
rply *sessions.V1GetCostReply) error {
return ssv1.Ss.BiRPCv1GetCost(nil, args, rply)
return ssv1.sS.BiRPCv1GetCost(nil, args, rply)
}
func (ssv1 *SessionSv1) GetActiveSessions(args *utils.SessionFilter,
rply *[]*sessions.ExternalSession) error {
return ssv1.Ss.BiRPCv1GetActiveSessions(nil, args, rply)
return ssv1.sS.BiRPCv1GetActiveSessions(nil, args, rply)
}
func (ssv1 *SessionSv1) GetActiveSessionsCount(args *utils.SessionFilter,
rply *int) error {
return ssv1.Ss.BiRPCv1GetActiveSessionsCount(nil, args, rply)
return ssv1.sS.BiRPCv1GetActiveSessionsCount(nil, args, rply)
}
func (ssv1 *SessionSv1) ForceDisconnect(args *utils.SessionFilter,
rply *string) error {
return ssv1.Ss.BiRPCv1ForceDisconnect(nil, args, rply)
return ssv1.sS.BiRPCv1ForceDisconnect(nil, args, rply)
}
func (ssv1 *SessionSv1) GetPassiveSessions(args *utils.SessionFilter,
rply *[]*sessions.ExternalSession) error {
return ssv1.Ss.BiRPCv1GetPassiveSessions(nil, args, rply)
return ssv1.sS.BiRPCv1GetPassiveSessions(nil, args, rply)
}
func (ssv1 *SessionSv1) GetPassiveSessionsCount(args *utils.SessionFilter,
rply *int) error {
return ssv1.Ss.BiRPCv1GetPassiveSessionsCount(nil, args, rply)
return ssv1.sS.BiRPCv1GetPassiveSessionsCount(nil, args, rply)
}
func (ssv1 *SessionSv1) Ping(ign *utils.CGREventWithOpts, reply *string) error {
@@ -122,22 +122,22 @@ func (ssv1 *SessionSv1) Ping(ign *utils.CGREventWithOpts, reply *string) error {
}
func (ssv1 *SessionSv1) ReplicateSessions(args *dispatchers.ArgsReplicateSessionsWithOpts, rply *string) error {
return ssv1.Ss.BiRPCv1ReplicateSessions(nil, args.ArgsReplicateSessions, rply)
return ssv1.sS.BiRPCv1ReplicateSessions(nil, args.ArgsReplicateSessions, rply)
}
func (ssv1 *SessionSv1) SetPassiveSession(args *sessions.Session,
reply *string) error {
return ssv1.Ss.BiRPCv1SetPassiveSession(nil, args, reply)
return ssv1.sS.BiRPCv1SetPassiveSession(nil, args, reply)
}
// ActivateSessions is called to activate a list/all sessions
func (ssv1 *SessionSv1) ActivateSessions(args *utils.SessionIDsWithArgsDispatcher, reply *string) error {
return ssv1.Ss.BiRPCv1ActivateSessions(nil, args, reply)
return ssv1.sS.BiRPCv1ActivateSessions(nil, args, reply)
}
// DeactivateSessions is called to deactivate a list/all active sessios
func (ssv1 *SessionSv1) DeactivateSessions(args *utils.SessionIDsWithArgsDispatcher, reply *string) error {
return ssv1.Ss.BiRPCv1DeactivateSessions(nil, args, reply)
return ssv1.sS.BiRPCv1DeactivateSessions(nil, args, reply)
}
// Call implements rpcclient.ClientConnector interface for internal RPC
@@ -148,20 +148,20 @@ func (ssv1 *SessionSv1) Call(serviceMethod string,
// ReAuthorize sends the RAR for filterd sessions
func (ssv1 *SessionSv1) ReAuthorize(args *utils.SessionFilter, reply *string) error {
return ssv1.Ss.BiRPCv1ReAuthorize(nil, args, reply)
return ssv1.sS.BiRPCv1ReAuthorize(nil, args, reply)
}
// DisconnectPeer sends the DPR for the OriginHost and OriginRealm
func (ssv1 *SessionSv1) DisconnectPeer(args *utils.DPRArgs, reply *string) error {
return ssv1.Ss.BiRPCv1DisconnectPeer(nil, args, reply)
return ssv1.sS.BiRPCv1DisconnectPeer(nil, args, reply)
}
// STIRAuthenticate checks the identity using STIR/SHAKEN
func (ssv1 *SessionSv1) STIRAuthenticate(args *sessions.V1STIRAuthenticateArgs, reply *string) error {
return ssv1.Ss.BiRPCv1STIRAuthenticate(nil, args, reply)
return ssv1.sS.BiRPCv1STIRAuthenticate(nil, args, reply)
}
// STIRIdentity creates the identity for STIR/SHAKEN
func (ssv1 *SessionSv1) STIRIdentity(args *sessions.V1STIRIdentityArgs, reply *string) error {
return ssv1.Ss.BiRPCv1STIRIdentity(nil, args, reply)
return ssv1.sS.BiRPCv1STIRIdentity(nil, args, reply)
}

50
apier/v1/sessionsbirpc.go
View File

@@ -73,7 +73,7 @@ func (ssv1 *SessionSv1) BiRPCv1AuthorizeEvent(clnt *rpc2.Client, args *sessions.
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1AuthorizeEvent(clnt, args, rply)
return ssv1.sS.BiRPCv1AuthorizeEvent(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1AuthorizeEventWithDigest(clnt *rpc2.Client, args *sessions.V1AuthorizeArgs,
@@ -84,7 +84,7 @@ func (ssv1 *SessionSv1) BiRPCv1AuthorizeEventWithDigest(clnt *rpc2.Client, args
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1AuthorizeEventWithDigest(clnt, args, rply)
return ssv1.sS.BiRPCv1AuthorizeEventWithDigest(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1InitiateSession(clnt *rpc2.Client, args *sessions.V1InitSessionArgs,
@@ -95,7 +95,7 @@ func (ssv1 *SessionSv1) BiRPCv1InitiateSession(clnt *rpc2.Client, args *sessions
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1InitiateSession(clnt, args, rply)
return ssv1.sS.BiRPCv1InitiateSession(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1InitiateSessionWithDigest(clnt *rpc2.Client, args *sessions.V1InitSessionArgs,
@@ -106,7 +106,7 @@ func (ssv1 *SessionSv1) BiRPCv1InitiateSessionWithDigest(clnt *rpc2.Client, args
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1InitiateSessionWithDigest(clnt, args, rply)
return ssv1.sS.BiRPCv1InitiateSessionWithDigest(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1UpdateSession(clnt *rpc2.Client, args *sessions.V1UpdateSessionArgs,
@@ -117,7 +117,7 @@ func (ssv1 *SessionSv1) BiRPCv1UpdateSession(clnt *rpc2.Client, args *sessions.V
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1UpdateSession(clnt, args, rply)
return ssv1.sS.BiRPCv1UpdateSession(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1SyncSessions(clnt *rpc2.Client, args *utils.TenantWithOpts,
@@ -128,7 +128,7 @@ func (ssv1 *SessionSv1) BiRPCv1SyncSessions(clnt *rpc2.Client, args *utils.Tenan
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1SyncSessions(clnt, &utils.TenantWithOpts{}, rply)
return ssv1.sS.BiRPCv1SyncSessions(clnt, &utils.TenantWithOpts{}, rply)
}
func (ssv1 *SessionSv1) BiRPCv1TerminateSession(clnt *rpc2.Client, args *sessions.V1TerminateSessionArgs,
@@ -139,7 +139,7 @@ func (ssv1 *SessionSv1) BiRPCv1TerminateSession(clnt *rpc2.Client, args *session
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1TerminateSession(clnt, args, rply)
return ssv1.sS.BiRPCv1TerminateSession(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1ProcessCDR(clnt *rpc2.Client, cgrEv *utils.CGREventWithOpts,
@@ -150,7 +150,7 @@ func (ssv1 *SessionSv1) BiRPCv1ProcessCDR(clnt *rpc2.Client, cgrEv *utils.CGREve
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ProcessCDR(clnt, cgrEv, rply)
return ssv1.sS.BiRPCv1ProcessCDR(clnt, cgrEv, rply)
}
func (ssv1 *SessionSv1) BiRPCv1ProcessMessage(clnt *rpc2.Client, args *sessions.V1ProcessMessageArgs,
@@ -161,7 +161,7 @@ func (ssv1 *SessionSv1) BiRPCv1ProcessMessage(clnt *rpc2.Client, args *sessions.
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ProcessMessage(clnt, args, rply)
return ssv1.sS.BiRPCv1ProcessMessage(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1ProcessEvent(clnt *rpc2.Client, args *sessions.V1ProcessEventArgs,
@@ -172,7 +172,7 @@ func (ssv1 *SessionSv1) BiRPCv1ProcessEvent(clnt *rpc2.Client, args *sessions.V1
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ProcessEvent(clnt, args, rply)
return ssv1.sS.BiRPCv1ProcessEvent(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1GetCost(clnt *rpc2.Client, args *sessions.V1ProcessEventArgs,
@@ -183,7 +183,7 @@ func (ssv1 *SessionSv1) BiRPCv1GetCost(clnt *rpc2.Client, args *sessions.V1Proce
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1GetCost(clnt, args, rply)
return ssv1.sS.BiRPCv1GetCost(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1GetActiveSessions(clnt *rpc2.Client, args *utils.SessionFilter,
@@ -194,7 +194,7 @@ func (ssv1 *SessionSv1) BiRPCv1GetActiveSessions(clnt *rpc2.Client, args *utils.
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1GetActiveSessions(clnt, args, rply)
return ssv1.sS.BiRPCv1GetActiveSessions(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1GetActiveSessionsCount(clnt *rpc2.Client, args *utils.SessionFilter,
@@ -205,7 +205,7 @@ func (ssv1 *SessionSv1) BiRPCv1GetActiveSessionsCount(clnt *rpc2.Client, args *u
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1GetActiveSessionsCount(clnt, args, rply)
return ssv1.sS.BiRPCv1GetActiveSessionsCount(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessions(clnt *rpc2.Client, args *utils.SessionFilter,
@@ -216,7 +216,7 @@ func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessions(clnt *rpc2.Client, args *utils
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1GetPassiveSessions(clnt, args, rply)
return ssv1.sS.BiRPCv1GetPassiveSessions(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessionsCount(clnt *rpc2.Client, args *utils.SessionFilter,
@@ -227,7 +227,7 @@ func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessionsCount(clnt *rpc2.Client, args *
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1GetPassiveSessionsCount(clnt, args, rply)
return ssv1.sS.BiRPCv1GetPassiveSessionsCount(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1ForceDisconnect(clnt *rpc2.Client, args *utils.SessionFilter,
@@ -238,7 +238,7 @@ func (ssv1 *SessionSv1) BiRPCv1ForceDisconnect(clnt *rpc2.Client, args *utils.Se
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ForceDisconnect(clnt, args, rply)
return ssv1.sS.BiRPCv1ForceDisconnect(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCv1RegisterInternalBiJSONConn(clnt *rpc2.Client, args string,
@@ -249,7 +249,7 @@ func (ssv1 *SessionSv1) BiRPCv1RegisterInternalBiJSONConn(clnt *rpc2.Client, arg
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1RegisterInternalBiJSONConn(clnt, args, rply)
return ssv1.sS.BiRPCv1RegisterInternalBiJSONConn(clnt, args, rply)
}
func (ssv1 *SessionSv1) BiRPCPing(clnt *rpc2.Client, ign *utils.CGREventWithOpts,
@@ -282,7 +282,7 @@ func (ssv1 *SessionSv1) BiRPCv1SetPassiveSession(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1SetPassiveSession(clnt, args, reply)
return ssv1.sS.BiRPCv1SetPassiveSession(clnt, args, reply)
}
func (ssv1 *SessionSv1) BiRPCv1ActivateSessions(clnt *rpc2.Client,
@@ -293,7 +293,7 @@ func (ssv1 *SessionSv1) BiRPCv1ActivateSessions(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ActivateSessions(clnt, args, reply)
return ssv1.sS.BiRPCv1ActivateSessions(clnt, args, reply)
}
func (ssv1 *SessionSv1) BiRPCv1DeactivateSessions(clnt *rpc2.Client,
@@ -304,7 +304,7 @@ func (ssv1 *SessionSv1) BiRPCv1DeactivateSessions(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1DeactivateSessions(clnt, args, reply)
return ssv1.sS.BiRPCv1DeactivateSessions(clnt, args, reply)
}
// BiRPCV1ReAuthorize sends the RAR for filterd sessions
@@ -316,7 +316,7 @@ func (ssv1 *SessionSv1) BiRPCV1ReAuthorize(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1ReAuthorize(clnt, args, reply)
return ssv1.sS.BiRPCv1ReAuthorize(clnt, args, reply)
}
// BiRPCV1DisconnectPeer sends the DPR for the OriginHost and OriginRealm
@@ -328,7 +328,7 @@ func (ssv1 *SessionSv1) BiRPCV1DisconnectPeer(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1DisconnectPeer(clnt, args, reply)
return ssv1.sS.BiRPCv1DisconnectPeer(clnt, args, reply)
}
// BiRPCV1STIRAuthenticate checks the identity using STIR/SHAKEN
@@ -340,7 +340,7 @@ func (ssv1 *SessionSv1) BiRPCV1STIRAuthenticate(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1STIRAuthenticate(clnt, args, reply)
return ssv1.sS.BiRPCv1STIRAuthenticate(clnt, args, reply)
}
// BiRPCV1STIRIdentity creates the identity for STIR/SHAKEN
@@ -352,7 +352,7 @@ func (ssv1 *SessionSv1) BiRPCV1STIRIdentity(clnt *rpc2.Client,
}
defer ssv1.concReqs.Deallocate()
}
return ssv1.Ss.BiRPCv1STIRIdentity(nil, args, reply)
return ssv1.sS.BiRPCv1STIRIdentity(nil, args, reply)
}
func (ssv1 *SessionSv1) BiRPCV1Sleep(clnt *rpc2.Client, arg *utils.DurationArgs,
@@ -363,7 +363,7 @@ func (ssv1 *SessionSv1) BiRPCV1Sleep(clnt *rpc2.Client, arg *utils.DurationArgs,
}
defer ssv1.concReqs.Deallocate()
}
time.Sleep(arg.DurationTime)
time.Sleep(arg.Duration)
*reply = utils.OK
return nil
}

4
dispatchers/core_it_test.go
View File

@@ -76,8 +76,8 @@ func testDspCoreLoad(t *testing.T) {
expNodeID = "ALL2"
}
dur := &utils.DurationArgs{
DurationTime: 500 * time.Millisecond,
Tenant: "cgrates.org",
Duration: 500 * time.Millisecond,
Tenant: "cgrates.org",
Opts: map[string]interface{}{
utils.OptsAPIKey: "core12345",
utils.OptsRouteID: "core1",

6
utils/coreutils.go
View File

@@ -946,9 +946,9 @@ type SetIndexesArg struct {
}
type DurationArgs struct {
DurationTime time.Duration
Opts map[string]interface{}
Tenant string
Duration time.Duration
Opts map[string]interface{}
Tenant string
}
// AESEncrypt will encrypt the provided txt using the encKey and AES algorithm