dapr

package

v3.19.2 Latest Latest Go to latest Published: Jun 17, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

View Source

const (
	Name = "dapr"
)

View Source

var Connections = &Dapr{
	openConnections: make(map[string]Connection),
}

View Source

var FakeConn = &FakeDapr{
	openConnections: map[string]FakeDaprConnection{},
}

func FakeConnection() (driver.Driver, func())

type Connection struct {
	// contains filtered or unexported fields
}

type Dapr struct {
	// contains filtered or unexported fields
}

Dapr represents driver to use Dapr.

func (r *Dapr) CloseConnection(connectionName string) error

func (r *Dapr) CreateConnection(_ context.Context, connectionName string, config interface{}) error

func (r *Dapr) Publish(_ context.Context, connectionName string, data interface{}, topic string) error

func (r *Dapr) UpdateConnection(_ context.Context, connectionName string, config interface{}) error

type FakeDapr struct {
	// contains filtered or unexported fields
}

func (r *FakeDapr) CloseConnection(connectionName string) error

func (r *FakeDapr) CreateConnection(ctx context.Context, connectionName string, config interface{}) error

func (r *FakeDapr) Publish(_ context.Context, _ string, _ interface{}, _ string) error

func (r *FakeDapr) UpdateConnection(_ context.Context, connectionName string, config interface{}) error

type FakeDaprConnection struct {
	// contains filtered or unexported fields
}