grpc

Documentation

Index

• func GetFreePort() (int, error)
• type API
  • func NewAPI(appID string, appChannel channel.AppChannel, ...) API
• type Manager
  • func NewGRPCManager() *Manager
  • func (g *Manager) CreateLocalChannel(port, maxConcurrency int, spec config.TracingSpec) (channel.AppChannel, error)
  • func (g *Manager) GetGRPCConnection(address, id string, skipTLS, recreateIfExists bool) (*grpc.ClientConn, error)
  • func (g *Manager) SetAuthenticator(auth security.Authenticator)
• type Server
  • func NewAPIServer(api API, config ServerConfig, tracingSpec config.TracingSpec) Server
  • func NewInternalServer(api API, config ServerConfig, tracingSpec config.TracingSpec, ...) Server
• type ServerConfig
  • func NewServerConfig(appID string, hostAddress string, port int) ServerConfig

Functions

func GetFreePort

func GetFreePort() (int, error)

GetFreePort returns a free port from the OS

Types

type API

type API interface {
	CallActor(ctx context.Context, in *daprinternal_pb.CallActorEnvelope) (*daprinternal_pb.InvokeResponse, error)
	CallLocal(ctx context.Context, in *daprinternal_pb.LocalCallEnvelope) (*daprinternal_pb.InvokeResponse, error)
	PublishEvent(ctx context.Context, in *dapr_pb.PublishEventEnvelope) (*empty.Empty, error)
	InvokeService(ctx context.Context, in *dapr_pb.InvokeServiceEnvelope) (*dapr_pb.InvokeServiceResponseEnvelope, error)
	InvokeBinding(ctx context.Context, in *dapr_pb.InvokeBindingEnvelope) (*empty.Empty, error)
	GetState(ctx context.Context, in *dapr_pb.GetStateEnvelope) (*dapr_pb.GetStateResponseEnvelope, error)
	GetSecret(ctx context.Context, in *dapr_pb.GetSecretEnvelope) (*dapr_pb.GetSecretResponseEnvelope, error)
	SaveState(ctx context.Context, in *dapr_pb.SaveStateEnvelope) (*empty.Empty, error)
	DeleteState(ctx context.Context, in *dapr_pb.DeleteStateEnvelope) (*empty.Empty, error)
}

API is the gRPC interface for the Dapr gRPC API. It implements both the internal and external proto definitions.

func NewAPI

func NewAPI(appID string, appChannel channel.AppChannel, stateStores map[string]state.Store, secretStores map[string]secretstores.SecretStore, publishFn func(req *pubsub.PublishRequest) error, directMessaging messaging.DirectMessaging, actor actors.Actors, sendToOutputBindingFn func(name string, req *bindings.WriteRequest) error) API

NewAPI returns a new gRPC API

type Manager

type Manager struct {
	AppClient *grpc.ClientConn
	// contains filtered or unexported fields
}

Manager is a wrapper around gRPC connection pooling

func NewGRPCManager

func NewGRPCManager() *Manager

NewGRPCManager returns a new grpc manager

func (*Manager) CreateLocalChannel

func (g *Manager) CreateLocalChannel(port, maxConcurrency int, spec config.TracingSpec) (channel.AppChannel, error)

CreateLocalChannel creates a new gRPC AppChannel

func (*Manager) GetGRPCConnection

func (g *Manager) GetGRPCConnection(address, id string, skipTLS, recreateIfExists bool) (*grpc.ClientConn, error)

GetGRPCConnection returns a new grpc connection for a given address and inits one if doesn't exist

func (*Manager) SetAuthenticator

func (g *Manager) SetAuthenticator(auth security.Authenticator)

SetAuthenticator sets the gRPC manager a tls authenticator context

type Server

type Server interface {
	StartNonBlocking() error
}

Server is an interface for the dapr gRPC server

func NewAPIServer

func NewAPIServer(api API, config ServerConfig, tracingSpec config.TracingSpec) Server

NewAPIServer returns a new user facing gRPC API server

func NewInternalServer

func NewInternalServer(api API, config ServerConfig, tracingSpec config.TracingSpec, authenticator auth.Authenticator) Server

NewInternalServer returns a new gRPC server for Dapr to Dapr communications

type ServerConfig

type ServerConfig struct {
	AppID       string
	HostAddress string
	Port        int
}

ServerConfig is the config object for a grpc server

func NewServerConfig

func NewServerConfig(appID string, hostAddress string, port int) ServerConfig

NewServerConfig returns a new grpc server config