Sha256: 76584053333f32b3cd6d56bfeebfe058d2d4e33ec5727dc2bbe68e88e9b15508
Contents?: true
Size: 886 Bytes
Versions: 20
Compression:
Stored size: 886 Bytes
Contents
# frozen_string_literal: true
require_relative '../dapr'
require 'json'
require 'semantic_logger'
require 'dapr-client'
require 'dapr/proto/runtime/v1/dapr_services_pb'
module Rubyists
module Dapr
# The namespace for the Dapr client
module Client
include SemanticLogger::Loggable
DAPR_PORT = ENV.fetch('DAPR_GRPC_PORT', '5001')
DAPR_URI = ENV.fetch('DAPR_GRPC_HOST', 'localhost')
DAPR_STUB = ::Dapr::Proto::Runtime::V1::Dapr::Stub
def self.client
logger.info "Creating Dapr client for #{DAPR_URI}:#{DAPR_PORT}"
DAPR_STUB.new("#{DAPR_URI}:#{DAPR_PORT}", :this_channel_is_insecure)
end
def self.singleton
@singleton ||= client
end
def client
Rubyists::Dapr::Client.client
end
def singleton
@singleton ||= Rubyists::Dapr::Client.singleton
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems