Documentation
¶
Overview ¶
Package transport provides transport types and interfaces for the internal runtime. Transport implementations are now in github.com/drblury/protoflow/transport/*.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ChannelCapabilities = newtransport.ChannelCapabilities KafkaCapabilities = newtransport.KafkaCapabilities RabbitMQCapabilities = newtransport.RabbitMQCapabilities NATSCapabilities = newtransport.NATSCapabilities NATSJetStreamCapabilities = newtransport.NATSJetStreamCapabilities AWSCapabilities = newtransport.AWSCapabilities SQLiteCapabilities = newtransport.SQLiteCapabilities PostgresCapabilities = newtransport.PostgresCapabilities HTTPCapabilities = newtransport.HTTPCapabilities IOCapabilities = newtransport.IOCapabilities )
Predefined capability sets - aliased from the new transport package.
Functions ¶
This section is empty.
Types ¶
type Capabilities ¶ added in v0.4.1
type Capabilities = newtransport.Capabilities
Capabilities is an alias for the modular transport Capabilities.
func GetCapabilities ¶ added in v0.4.1
func GetCapabilities(transportName string) Capabilities
GetCapabilities returns the capabilities for a transport by name.
type CapabilitiesProvider ¶ added in v0.4.1
type CapabilitiesProvider = newtransport.CapabilitiesProvider
CapabilitiesProvider is an alias for the modular transport CapabilitiesProvider.
type Factory ¶
type Factory interface {
Build(ctx context.Context, conf *config.Config, logger watermill.LoggerAdapter) (Transport, error)
}
Factory abstracts how Protoflow initialises message transports.
func DefaultFactory ¶
func DefaultFactory() Factory
DefaultFactory returns the built-in transport factory that uses the modular transport registry.
Source Files
Click to show internal directories.
Click to hide internal directories.