func NewInbound()

in internal/app/adapters/inbound/inbound_factory.go [34:45]


func NewInbound(config domain.InboundConfig) (ports.InboundEndpoint, error) {
	switch config.Protocol {
	case "file":
		return file.NewFileInboundEndpoint(
			config,
			nil,
		), nil
		
	default:
		return nil, ErrInboundTypeNotFound
	}
}