export

package

v3.19.0-rc.0 Latest Latest Go to latest Published: Mar 27, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var SupportedDrivers = map[string]driver.Driver{
	dapr.Name: dapr.Connections,
}

This section is empty.

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

func NewSystem() *System

func (s *System) CloseConnection(connectionName string) error

func (s *System) Publish(_ context.Context, connectionName string, subject string, msg interface{}) error

func (s *System) UpsertConnection(ctx context.Context, config interface{}, connectionName string, newDriver string) error