GO-2023-1955: Dapr API token authentication bypass in HTTP endpoints in github.com/dapr/dapr

grpc

package

v0.4.0 Latest Latest Go to latest Published: Feb 13, 2020 License: MIT Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dapr/dapr

Links

Documentation ¶

Index ¶

type API
- func NewAPI(daprID string, appChannel channel.AppChannel, ...) API
type Manager
- func NewGRPCManager() *Manager
type Server
- func NewServer(api API, config ServerConfig, tracingSpec config.TracingSpec, ...) Server
type ServerConfig
- func NewServerConfig(daprID string, hostAddress string, port int) ServerConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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, stateStores map[string]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, 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 ¶ added in v0.4.0

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 NewServer ¶

func NewServer(api API, config ServerConfig, tracingSpec config.TracingSpec, authenticator auth.Authenticator) 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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL