From 5927e964372b398a8ad771e63e48ef36f9472427 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Mon, 2 Nov 2020 17:20:31 +0200 Subject: [PATCH] Fixed some typos --- apier/v1/concreqs_it_test.go | 10 +++---- apier/v1/core.go | 2 +- apier/v1/sessions.go | 52 ++++++++++++++++++------------------ apier/v1/sessionsbirpc.go | 50 +++++++++++++++++----------------- dispatchers/core_it_test.go | 4 +-- utils/coreutils.go | 6 ++--- 6 files changed, 62 insertions(+), 62 deletions(-) diff --git a/apier/v1/concreqs_it_test.go b/apier/v1/concreqs_it_test.go index 5acdb1986..9f124dc37 100644 --- a/apier/v1/concreqs_it_test.go +++ b/apier/v1/concreqs_it_test.go @@ -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) diff --git a/apier/v1/core.go b/apier/v1/core.go index 20331c527..06419416e 100644 --- a/apier/v1/core.go +++ b/apier/v1/core.go @@ -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 } diff --git a/apier/v1/sessions.go b/apier/v1/sessions.go index 288da10c5..57762b947 100644 --- a/apier/v1/sessions.go +++ b/apier/v1/sessions.go @@ -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) } diff --git a/apier/v1/sessionsbirpc.go b/apier/v1/sessionsbirpc.go index 97fab0dc3..c6a5bdd76 100644 --- a/apier/v1/sessionsbirpc.go +++ b/apier/v1/sessionsbirpc.go @@ -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 } diff --git a/dispatchers/core_it_test.go b/dispatchers/core_it_test.go index 5cda64e09..81d1483f0 100644 --- a/dispatchers/core_it_test.go +++ b/dispatchers/core_it_test.go @@ -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", diff --git a/utils/coreutils.go b/utils/coreutils.go index 8ddd3040e..9fc15edb8 100644 --- a/utils/coreutils.go +++ b/utils/coreutils.go @@ -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