Function getPostNodeChangeClient

common/nodes/core/handler-exec-struct.go:151–171

getPostNodeChangeClient finds or creates a new streamer to public PostNodeChanges events. If refresh is set, it will delete any previous instance and create a new one.

(ctx context.Context, serviceName string, refresh bool)

// getPostNodeChangeClient finds or creates a new streamer to public PostNodeChanges events.
// If refresh is set, it will delete any previous instance and create a new one.
func getPostNodeChangeClient(ctx context.Context, serviceName string, refresh bool) (tree.NodeChangesReceiverStreamer_PostNodeChangesClient, error) {
	if pncClients == nil {
		pncClients = make(map[string]tree.NodeChangesReceiverStreamer_PostNodeChangesClient)
		pncLocks = &sync.Mutex{}
	}
	pncLocks.Lock()
	defer pncLocks.Unlock()
	if refresh {
		delete(pncClients, serviceName)
	}
	if c, o := pncClients[serviceName]; o {
		return c, nil
	}
	cl := tree.NewNodeChangesReceiverStreamerClient(grpc2.ResolveConn(ctx, common.ServiceDataSyncGRPC_+serviceName))
	c, e := cl.PostNodeChanges(runtimecontext.ForkedBackgroundWithMeta(ctx))
	if e != nil {
		return nil, e
	}
	pncClients[serviceName] = c
	return c, nil
}

func (f *StructStorageHandler) publish(ctx context.Context, identifier string, eventType tree.NodeChangeEvent_EventType, node *tree.Node) {
	bi, er := nodes.GetBranchInfo(ctx, identifier)