Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateGRPCChannel ¶
func CreateGRPCChannel(host string, port int, conn *grpc.ClientConn) (channel.AppChannel, error)
CreateGRPCChannel currently unused
func GetDialAddressPrefix ¶
GetDialAddressPrefix returns a dial prefix for a gRPC client connections For a given DaprMode.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
Channel is a concrete AppChannel implementation for interacting with gRPC based user code.
func CreateLocalChannel ¶
func CreateLocalChannel(host string, port int, conn *grpc.ClientConn) *Channel
CreateLocalChannel creates a gRPC connection with user code.
func (*Channel) GetAppConfig ¶
func (g *Channel) GetAppConfig() (*config.ApplicationConfig, error)
GetAppConfig gets application config from user application.
func (*Channel) GetBaseAddress ¶
GetBaseAddress returns the application base address.
func (*Channel) InvokeMethod ¶
func (g *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest) (*invokev1.InvokeMethodResponse, error)
InvokeMethod invokes user code via gRPC.
type ClientConnCloser ¶
type ClientConnCloser interface {
grpc.ClientConnInterface
io.Closer
}
ClientConnCloser combines grpc.ClientConnInterface and io.Closer to cover the methods used from *grpc.ClientConn.
type Manager ¶
type Manager struct {
AppClient ClientConnCloser
// contains filtered or unexported fields
}
Manager is a wrapper around gRPC connection pooling.
func (*Manager) GetGRPCConnection ¶
func (g *Manager) GetGRPCConnection() (*grpc.ClientConn, func(), error)
func (*Manager) SetAuthenticator ¶
func (g *Manager) SetAuthenticator(auth security.Authenticator)
SetAuthenticator sets the gRPC manager a tls authenticator context.
func (*Manager) StartEndpointsDetection ¶
func (g *Manager) StartEndpointsDetection()
StartEndpointsDetection update function endpoints
Source Files