grpc

Documentation

Index

• type API
  • func NewAPI(daprID string, appChannel channel.AppChannel, stateStore state.Store, ...) API
• type Manager
  • func NewGRPCManager() *Manager
  • func (g *Manager) CreateLocalChannel(port, maxConcurrency int) (channel.AppChannel, error)
  • func (g *Manager) GetGRPCConnection(address string) (*grpc.ClientConn, error)
• type Server
  • func NewServer(api API, config ServerConfig, tracingSpec config.TracingSpec) Server
• type ServerConfig
  • func NewServerConfig(daprID string, hostAddress string, port int) ServerConfig

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)
	UpdateComponent(ctx context.Context, in *daprinternal_pb.Component) (*empty.Empty, 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)
	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(daprID string, appChannel channel.AppChannel, stateStore state.Store, pubSub pubsub.PubSub, directMessaging messaging.DirectMessaging, actor actors.Actors, sendToOutputBindingFn func(name string, req *bindings.WriteRequest) error, componentHandler components.ComponentHandler) 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) (channel.AppChannel, error)

CreateLocalChannel creates a new gRPC AppChannel

func (*Manager) GetGRPCConnection

func (g *Manager) GetGRPCConnection(address string) (*grpc.ClientConn, error)

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

type Server

type Server interface {
	StartNonBlocking() error
}

Server is an interface for the dapr gRPC server

func NewServer

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

NewServer returns a new gRPC server

type ServerConfig

type ServerConfig struct {
	DaprID      string
	HostAddress string
	Port        int
}

ServerConfig is the config object for a grpc server

func NewServerConfig

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

NewServerConfig returns a new grpc server config