dapr_client/dapr.go

package dapr_client

import "sync"

var clientInstance *Client
var initOnce sync.Once
var clientTimeoutSec int64

func InitDAPR(timeoutSec int64) {
	clientTimeoutSec = timeoutSec
}

func DestroyDAPR() {
	if clientInstance != nil {
		destroyClient(clientInstance)
	}
}

func GetInstance() *Client {
	client, err := newClient(clientTimeoutSec)
	if err != nil {
		panic(err)
	}

	clientInstance = client

	return clientInstance
}