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 {
	initOnce.Do(func() {
		client, err := newClient(clientTimeoutSec)
		if err != nil {
			panic(err)
		}

		clientInstance = client
	})

	return clientInstance
}