stale/nacl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: remove own types

Browse Source
This commit is contained in:
jar3b 2021-06-07 13:45:26 +03:00
parent 15e6c19222
commit e8cba551c7
1 changed files with 2 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
nacl.go
View File

@ -16,13 +16,6 @@ var (
stanLock = sync.Mutex{} stanLock = sync.Mutex{}
) )
type (
Msg = stan.Msg
NatsMsg = nats.Msg
Subscription = stan.Subscription
NatsSubscription = nats.Subscription
)
func SetupNatsWithCreds(host string, port int, credsFile string, closeHandler *grawt.CloseHandler) error { func SetupNatsWithCreds(host string, port int, credsFile string, closeHandler *grawt.CloseHandler) error {
natsLock.Lock() natsLock.Lock()
defer natsLock.Unlock() defer natsLock.Unlock()
@ -98,7 +91,7 @@ func SetupStan(clusterName string, clientId string, host string, port int, user
return nil return nil
} }
func FinalizeStan(subscriptions *[]Subscription) error { func FinalizeStan(subscriptions *[]stan.Subscription) error {
stanLock.Lock() stanLock.Lock()
defer stanLock.Unlock() defer stanLock.Unlock()
if StanClient == nil { if StanClient == nil {
@ -118,7 +111,7 @@ func FinalizeStan(subscriptions *[]Subscription) error {
return nil return nil
} }
func FinalizeNats(subscriptions *[]*NatsSubscription) error { func FinalizeNats(subscriptions *[]*nats.Subscription) error {
natsLock.Lock() natsLock.Lock()
defer natsLock.Unlock() defer natsLock.Unlock()
if NatsClient == nil { if NatsClient == nil {